| 1103 | entered, release, finished = threading.Event(), threading.Event(), threading.Event() |
| 1104 | |
| 1105 | class BlockingTransitionLock(BaseFileLock): |
| 1106 | def _acquire(self) -> None: |
| 1107 | entered.set() |
| 1108 | release.wait(timeout=5) |
| 1109 | self._context.lock_file_fd = None |
| 1110 | |
| 1111 | _release = _acquire |
| 1112 | |
| 1113 | def acquire() -> None: |
| 1114 | try: |