| 165 | acquired = released = False |
| 166 | |
| 167 | class AioFileLock(BaseAsyncFileLock): |
| 168 | async def _acquire(self) -> None: # ty: ignore[invalid-method-override] |
| 169 | nonlocal acquired |
| 170 | acquired = True |
| 171 | self._context.lock_file_fd = 1 |
| 172 | |
| 173 | async def _release(self) -> None: # ty: ignore[invalid-method-override] |
| 174 | nonlocal released |
| 175 | released = True |
| 176 | self._context.lock_file_fd = None |
| 177 | |
| 178 | lock = AioFileLock(str(tmp_path / "a")) |
| 179 | await lock.acquire() |
no outgoing calls
searching dependent graphs…