+ LV-j;!Rt^RIHt^RIt^RIt^RIHt^RIHt^RI H t ^RI H t ] 'd^RI t ^RIHtHt^RIHt^R IHt!R R 4t!R R 4tR R .tR#)zEAsync wrapper around :class:`ReadWriteLock` for use with ``asyncio``.) annotationsN)ThreadPoolExecutor)asynccontextmanager) TYPE_CHECKING) ReadWriteLock)AsyncGeneratorCallable)futures) TracebackTypec>]tRt^tRtRRltRRltRRltRtR #) AsyncAcquireReadWriteReturnProxyzEContext-aware object that releases the async read/write lock on exit.c V^8dQhRRRR/#)lockAsyncReadWriteLockreturnNone)formats"k/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/filelock/_async_read_write.py __annotate__-AsyncAcquireReadWriteReturnProxy.__annotate__s/Dc WnR#Nr)selfrs&&r__init__)AsyncAcquireReadWriteReturnProxy.__init__s rcV^8dQhRR/#)rrrr)rs"rrrs"4rc ""VP#5irrrs&r __aenter__+AsyncAcquireReadWriteReturnProxy.__aenter__syys c(V^8dQhRRRRRRRR/#) rexc_typeztype[BaseException] | None exc_valuezBaseException | None tracebackzTracebackType | Nonerrr)rs"rrrs2"","("( "  "rc V"VPP4GRjxL R#L5ir)rrelease)rr%r&r's&&&&r __aexit__*AsyncAcquireReadWriteReturnProxy.__aexit__s ii!!!s )')rN) __name__ __module__ __qualname____firstlineno____doc__rr"r*__static_attributes__rrrr r sO""rr c X]tRt^&tRtR'RRRRRRRR/RR lllt]R R l4t]R R l4t]RRl4t ]RRl4t ]RRl4t RRlt R'RR/RRlllt R'RR/RRllltRR/RRllt]R(RR/RRlll4t]R(RR/R R!lll4tR"R#ltR$R%ltR&tR#))ra Async wrapper around :class:`ReadWriteLock` for use in ``asyncio`` applications. Because Python's :mod:`sqlite3` module has no async API, all blocking SQLite operations are dispatched to a thread pool via ``loop.run_in_executor()``. Reentrancy, upgrade/downgrade rules, and singleton behavior are delegated to the underlying :class:`ReadWriteLock`. :param lock_file: path to the SQLite database file used as the lock :param timeout: maximum wait time in seconds; ``-1`` means block indefinitely :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately when the lock is unavailable :param is_singleton: if ``True``, reuse existing :class:`ReadWriteLock` instances for the same resolved path :param loop: event loop for ``run_in_executor``; ``None`` uses the running loop :param executor: executor for ``run_in_executor``. When ``None`` a dedicated single-thread executor is created and owned by this lock, ensuring every operation runs on the same thread (required for SQLite affinity); it is shut down by :meth:`close`. A caller-supplied executor is used as-is and never shut down here, so when no executor is passed remember to call :meth:`close` to release the owned one. .. versionadded:: 3.21.0 blockingT is_singletonloopNexecutorc4V^8dQhRRRRRRRRRR R R R R /#)r lock_filezstr | os.PathLike[str]timeoutfloatr3boolr4r5 asyncio.AbstractEventLoop | Noner6zfutures.Executor | Nonerrr)rs"rrAsyncReadWriteLock.__annotate__<sY G G) G G  G  G/ G* G  Grc ~\WW4R7VnWPnVRJVnT;'g \ ^R7VnR#))r3r4N) max_workers)r_lock_loop_owns_executorr _executor)rr8r9r3r4r5r6s&&&$$$$rrAsyncReadWriteLock.__init__<s9#9d  &$.!FF%7A%FrcV^8dQhRR/#)rrstrr)rs"rrr=Ls$$3$rc .VPP#)z$:returns: the path to the lock file.)r@r8r!s&rr8AsyncReadWriteLock.lock_fileKszz###rcV^8dQhRR/#)rrr:r)rs"rrr=Qs"""rc .VPP#)z:returns: the default timeout.)r@r9r!s&rr9AsyncReadWriteLock.timeoutPszz!!!rcV^8dQhRR/#)rrr;r)rs"rrr=Vs##$#rc .VPP#)z1:returns: whether blocking is enabled by default.)r@r3r!s&rr3AsyncReadWriteLock.blockingUszz"""rcV^8dQhRR/#)rrr<r)rs"rrr=[s6rc VP#)z<:returns: the event loop (or ``None`` for the running loop).)rAr!s&rr5AsyncReadWriteLock.loopZszzrcV^8dQhRR/#)rrzfutures.Executorr)rs"rrr=`s*rc VP#)zi:returns: the executor used for ``run_in_executor`` (a dedicated single-thread one if none was supplied).)rCr!s&rr6AsyncReadWriteLock.executor_s~~rc(V^8dQhRRRRRRRR/#)rfunczCallable[..., object]argsobjectkwargsrr)rs"rrr=ds0dd4dVdvdZ`drc "VP;'g\P!4pVPVP\ P !V.VO5/VB4GRjxL #L5ir)rAasyncioget_running_looprun_in_executorrC functoolspartial)rrVrWrYr5s&&*, r_runAsyncReadWriteLock._rundsSzz77W557))$..):K:KD:bSW:b[a:bccccsA!A*#A($A*c$V^8dQhRRRRRR/#rr9r:r3r;rr r)rs"rrr=hs";;%;4;Ss;rc "VPVPPWR7GRjxL \VR7#L5i)a Acquire a shared read lock. See :meth:`ReadWriteLock.acquire_read` for full semantics. :param timeout: maximum wait time in seconds; ``-1`` means block indefinitely :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately when the lock is unavailable :returns: a proxy that can be used as an async context manager to release the lock :raises RuntimeError: if a write lock is already held on this instance :raises Timeout: if the lock cannot be acquired within *timeout* seconds r3Nr)r`r@ acquire_readr rr9r3s&&$rrfAsyncReadWriteLock.acquire_readhs8ii //iLLL/T:: M+A>Ac$V^8dQhRRRRRR/#rcr)rs"rrr=zs";;5;D;Tt;rc "VPVPPWR7GRjxL \VR7#L5i)a Acquire an exclusive write lock. See :meth:`ReadWriteLock.acquire_write` for full semantics. :param timeout: maximum wait time in seconds; ``-1`` means block indefinitely :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately when the lock is unavailable :returns: a proxy that can be used as an async context manager to release the lock :raises RuntimeError: if a read lock is already held, or a write lock is held by a different thread :raises Timeout: if the lock cannot be acquired within *timeout* seconds reNr)r`r@ acquire_writer rgs&&$rrl AsyncReadWriteLock.acquire_writezs8ii 00'iMMM/T:: NriforceFc V^8dQhRRRR/#)rrnr;rrr)rs"rrr=s 9 9d 9t 9rc p"VPVPPVR7GRjxL R#L5i)a  Release one level of the current lock. See :meth:`ReadWriteLock.release` for full semantics. :param force: if ``True``, release the lock completely regardless of the current lock level :raises RuntimeError: if no lock is currently held and *force* is ``False`` )rnN)r`r@r))rrns&$rr)AsyncReadWriteLock.releases'ii **%i888s +646c$V^8dQhRRRRRR/#rr9z float | Noner3z bool | NonerzAsyncGenerator[None]r)rs"rrr=s"!!|!!`t!rc *"VfVPPpVfVPPpVPWR7GRjxL R5xVP 4GRjxL R#L$L TP 4GRjxL i;i5i)a[ Async context manager that acquires and releases a shared read lock. Falls back to instance defaults for *timeout* and *blocking* when ``None``. :param timeout: maximum wait time in seconds, or ``None`` to use the instance default :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately; ``None`` uses the instance default Nre)r@r9r3rfr)rgs&&$r read_lockAsyncReadWriteLock.read_locksw ?jj((G  zz**H;;; ! ,,. < !$,,. HA B A1 BA5B*A3+B3B5B B  BBc$V^8dQhRRRRRR/#rsr)rs"rrr=s"!! !+!au!rc *"VfVPPpVfVPPpVPWR7GRjxL R5xVP 4GRjxL R#L$L TP 4GRjxL i;i5i)a` Async context manager that acquires and releases an exclusive write lock. Falls back to instance defaults for *timeout* and *blocking* when ``None``. :param timeout: maximum wait time in seconds, or ``None`` to use the instance default :param blocking: if ``False``, raise :class:`~filelock.Timeout` immediately; ``None`` uses the instance default Nre)r@r9r3rlr)rgs&&$r write_lockAsyncReadWriteLock.write_locksw ?jj((G  zz**H   <<< ! ,,. = !$,,. rwcV^8dQhRR/#rrrr)rs"rrr=s 0 0T 0rc "VPVPP4GRjxL VP'dVPP RR7R#R#L65i)z Release the lock (if held) and close the underlying SQLite connection. After calling this method, the lock instance is no longer usable. NFwait)r`r@closerBrCshutdownr!s&rrAsyncReadWriteLock.closesNii (()))     NN # # # /  *s)A$A"A$!A$cV^8dQhRR/#r}r)rs"rrr=s000rc h\VRR4'dVPPRR7R#R#)rBFrN)getattrrCrr!s&r__del__AsyncReadWriteLock.__del__s. 4)5 1 1 NN # # # / 2r)rCr@rArB)r)r,r-r.r/r0rpropertyr8r9r3r5r6r`rfrlr)rrurzrrr1rrrrr&s* G  G " G26 G-1 G G$$""##d;$;;$;4;;$ 9U 9!W[!!(!X\!!( 000rr)r0 __future__rr[r^concurrent.futuresr contextlibrtypingr _read_writeroscollections.abcrr concurrentr typesr r r__all__rrrrsRK"1* & 8"#""$l0l0`' r