+ j 4:Rt^RIHt^RIt^RIt^RIt^RIt^RIHt^RI H t ^RI H t H t Ht^RIHtHtHtHt^RIHtHtHtHtHtHt^RIHt] 'd^R IHtHt^R I H!t!^R I"H#t#^R IH$t$] !R 4t%]!R4t&!RR4t'!RR4t(RR.t)R#)zEAsync wrapper around :class:`ReadWriteLock` for use with ``asyncio``.) annotationsN)ThreadPoolExecutor)asynccontextmanager) TYPE_CHECKING ParamSpecTypeVar)_append_exception_context_ensure_current_process_fork_transition_register_fork_object)_BackendOutcome _capture_call _drain_future_future_result_raise_cancelled_error_wait_until_done) ReadWriteLock)AsyncGeneratorCallable)futures) TracebackType)AcquireReturnProxy_P_Rc ]tRt^(tRtR5RRRRRRRR/RR lllt]R R l4t]R R l4t]RRl4t ]RRl4t ]RRl4t ] R6RR/RRlll4t ] R6RR/RRlll4tRRltR5RR/RRllltR5RR/RRllltRR/R R!lltR"R#ltR$R%ltR&R'ltR(R)ltR*R+lt]R,R-l4tR.R/ltR0R1ltR2R3ltR4tR#)7AsyncReadWriteLocka Async wrapper around :class:`ReadWriteLock` for use in ``asyncio`` applications. This wrapper dispatches every blocking SQLite operation to a thread pool via ``loop.run_in_executor()`` because Python's :mod:`sqlite3` module has no async API. It delegates reentrancy, upgrade/downgrade rules, and singleton behavior 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`` this lock creates and owns a dedicated single-thread executor so every operation runs on the same thread (SQLite affinity requires this) and shuts it down in :meth:`close`. This lock uses a caller-supplied executor as-is and never shuts it down, so after passing no executor call :meth:`close` to release the owned one. .. versionadded:: 3.21.0 blockingT is_singletonloopNexecutorc4V^8dQhRRRRRRRRRR R R R R /#) lock_filezstr | os.PathLike[str]timeoutfloatrboolrr asyncio.AbstractEventLoop | Nonerzfutures.Executor | NonereturnNone)formats"[/home/luca/screen-checking/.venv/lib/python3.14/site-packages/filelock/_async_read_write.py __annotate__AsyncReadWriteLock.__annotate__>sP(()((  (  (/(*( (c  \P!4pWpnRVnRVn\ V4\ 4;_uu_4\WW4R7VnWPn VRJVn T;'g \^R7Vn \P!4V8wdRp\V4hRRR4R# +'giR#;i)F)rrN) max_workersz:AsyncReadWriteLock construction cannot continue after fork)osgetpid _creator_pid_fork_invalidated_closedr r r_lock_loop_owns_executorr _executor RuntimeError) selfr"r#rrrr creator_pidmsgs &&&$$$$ r+__init__AsyncReadWriteLock.__init__>siik '!& d#   &yHhDJJ"*d"2D %JJ);)JDNyy{k)R"3''*    s A$B66 C cV^8dQhRR/#)r!r'strr))r*s"r+r,r-Ws$$3$r.c .VPP#)zThe path to the lock file.)r6r"r;s&r+r"AsyncReadWriteLock.lock_fileVszz###r.cV^8dQhRR/#)r!r'r$r))r*s"r+r,r-\s"""r.c .VPP#)zThe default timeout.)r6r#rCs&r+r#AsyncReadWriteLock.timeout[szz!!!r.cV^8dQhRR/#r!r'r%r))r*s"r+r,r-as##$#r.c .VPP#)z'Whether blocking is enabled by default.)r6rrCs&r+rAsyncReadWriteLock.blocking`szz"""r.cV^8dQhRR/#)r!r'r&r))r*s"r+r,r-fs6r.c VP#)z2The event loop (or ``None`` for the running loop).)r7rCs&r+rAsyncReadWriteLock.loopeszzr.cV^8dQhRR/#)r!r'zfutures.Executorr))r*s"r+r,r-ks*r.c VP#)z_The executor used for ``run_in_executor`` (a dedicated single-thread one if none was supplied).)r9rCs&r+rAsyncReadWriteLock.executorjs~~r.c$V^8dQhRRRRRR/#r!r#z float | Nonerz bool | Noner'zAsyncGenerator[None]r))r*s"r+r,r-ps"77|77`t7r.c `"VfVPPpVfVPPpVPWR7GRjxL RpR5xTP T4GRjxL R#L( \d pTphRp?ii;iL TP T4GRjxL 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 Nr)r6r#r acquire_read BaseException_release_in_contextr;r#r body_errorerrors&&$ r+ read_lockAsyncReadWriteLock.read_lockos ?jj((G  zz**H;;;+/  7  **:6 6 6 < J   7$**:6 6 6`A B. A5 B.A7B..B /B.7 B BB  B B.B+$B'%B++B.c$V^8dQhRRRRRR/#rSr))r*s"r+r,r-s"77 7+7au7r.c `"VfVPPpVfVPPpVPWR7GRjxL RpR5xTP T4GRjxL R#L( \d pTphRp?ii;iL TP T4GRjxL 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 NrU)r6r#r acquire_writerWrXrYs&&$ r+ write_lockAsyncReadWriteLock.write_locks ?jj((G  zz**H   <<<+/  7  **:6 6 6 = J   7$**:6 6 6r^c V^8dQhRRRR/#)r!rZBaseException | Noner'r(r))r*s"r+r,r-s4HTr.c "VP4GRjxL R#L \dpTe \Y!4hRp?ii;i5iN)releaserWr)r;rZ release_errors&& r+rX&AsyncReadWriteLock._release_in_contexts9 ,,.  %)-D  s.A  A A;AAc$V^8dQhRRRRRR/#r!r#r$rr%r' AsyncAcquireReadWriteReturnProxyr))r*s"r+r,r-s";;%;4;Ss;r.c "VP4VP\P!VPP WR74GRjxL \ 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 rUNlock)_raise_if_unusable _run_acquire functoolspartialr6rVrmr;r#rs&&$r+rVAsyncReadWriteLock.acquire_readsO ! 1 1$**2I2I7 fggg/T:: hAA$A"A$c$V^8dQhRRRRRR/#rlr))r*s"r+r,r-s";;5;D;Tt;r.c "VP4VP\P!VPP WR74GRjxL \ 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 rUNro)rqrrrsrtr6rarmrus&&$r+ra AsyncReadWriteLock.acquire_writesO ! 1 1$**2J2JG ghhh/T:: irwforceFc V^8dQhRRRR/#)r!r{r%r'r(r))r*s"r+r,r-s99d9t9r.c "\4VP'dR#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`` N)r{)r _inherited_runr6rh)r;r{s&$r+rhAsyncReadWriteLock.releases9 ! ??? ii **%i888sA A A AcV^8dQhRR/#r!r'r(r))r*s"r+r,r-s[[T[r.c "\4VP'dR#VP'dR#VPVPP 4p\ V4GRjxL \T4RTnTP'dK\P!\ P"!TP$P&RR74GRjxL R#R#Lt \PdWp\T4GRjxL M# \dp\Y#4Rp?MRp?ii;iRTnTP4hRp?ii;iLx5i)z Release the lock (if held) and close the underlying SQLite connection. After calling this method, the lock instance is no longer usable. NTwait)r r~r5_submitr6closerasyncioCancelledErrorrrWr_shutdown_owned_executorrr8 to_threadrsrtr9shutdown)r; close_future cancellationr[s& r+rAsyncReadWriteLock.closes ! ???  <<< ||DJJ$4$45  "<0 0 0 |$     ##I$5$5dnn6M6MTX$YZ Z Z  1%%  <#L111  <&|;; <DL  ) ) +   [s}0E'EC )C*C .A'EEEC E 6D DD  E D+ D&!E&D++EE  Ec V^8dQhRRRR/#)r!acquirez Callable[[], AcquireReturnProxy]r'r(r))r*s"r+r,r-s''*J't'r.c "VPV4p\V4GRjxL \T4R#L \Pdp\ T4GRjxL M# \ dp\ Y44Rp?MRp?ii;i\ TPTPP44GRjxL h \ dp\ Y44Rp?hRp?ii;iRp?ii;i5irg) rrrrrrWrr6rhr)r;racquire_futurerr[s&& r+rrAsyncReadWriteLock._run_acquiresg. ">2 2 2 ~& 3%%  <#N333  <&|;; < <#DLL1C1C$DEEE ! <&|;;  < sC)757 C)7C& A"AA"!C!" B- A=8C!=BC!1B>7B:8B>=C!> C CC!CC!!C&&C)c(V^8dQhRRRRRRRR/#) r!funcCallable[_P, _R]args_P.argskwargs _P.kwargsr'rr))r*s"r+r,r- s* & &/ & &9 &Y[ &r.c $"VP!V.VO5/VBp\V4GRjxL \T4#L \Pd?p\ T4GRjxL h \ dp\ YV4Rp?hRp?ii;iRp?ii;i5irg)rrrrrrWrr)r;rrrfuturerr[s&&*, r+rAsyncReadWriteLock._run sd4T4V4 "6* * *f%% +%%  <#F+++ ! <&|;;  < saB:8: B:B A%A!A%$B% B0 B;BBBB  Bc(V^8dQhRRRRRRRR/#) r!rrrrrrr'z#asyncio.Future[_BackendOutcome[_R]]r))r*s"r+r,r-s,  $ -4 @I , r.c  VP;'g\P!4PVP\ \ P!V.VO5/VB4#rg)r7rget_running_looprun_in_executorr9r rsrt)r;rrrs&&*,r+rAsyncReadWriteLock._submitsN 88g668II NN    d 4T 4V 4  r.cV^8dQhRR/#rr))r*s"r+r,r-"s00$0r.c fVP'dVPPRR7R#R#)FrN)r8r9rrCs&r+r+AsyncReadWriteLock._shutdown_owned_executor"s(     NN # # # / r.cV^8dQhRR/#rIr))r*s"r+r,r-'sJJDJr.c nVP;'g#\P!4VP8g#rg)r4r1r2r3rCs&r+r~AsyncReadWriteLock._inherited&s'%%II8I8I)IIr.cV^8dQhRR/#rr))r*s"r+r,r-*s00D0r.c \4VP'dRVP R2p\V4hVP'dRp\ P !V4hR#)zAsyncReadWriteLock on z4 was invalidated by fork(); construct a new instancez$Cannot operate on a closed database.N)r r~r"r:r5sqlite3ProgrammingError)r;r=s& r+rq%AsyncReadWriteLock._raise_if_unusable*sT! ???*4>>*::noCs# # <<<8C**3/ / r.cV^8dQhRR/#rr))r*s"r+r,r-3s&&D&r.c RVnR#)TN)r4rCs&r+_reset_after_fork_in_child-AsyncReadWriteLock._reset_after_fork_in_child3s !%r.cV^8dQhRR/#rr))r*s"r+r,r-6s000r.c \P!4\VRR48Xd4\VRR4'dVPP RR7R#R#R#)r3Nr8Fr)r1r2getattrr9rrCs&r+__del__AsyncReadWriteLock.__del__6sJ 99;'$= ='$P`bgBhBh NN # # # /Ci =r.)r5r3r9r4r6r7r8)rg)__name__ __module__ __qualname____firstlineno____doc__r>propertyr"r#rrrrr\rbrXrVrarhrrrrrrr~rqrr__static_attributes__r)r.r+rr(sL*(  ( " (26(-1((0$$""##7W[7707X\770;$;;&;4;;&9U9 [<' & 0JJ0&00r.rc>]tRtRtRtRRltRRltRRltR tR #) rmi=zEContext-aware object that releases the async read/write lock on exit.c V^8dQhRRRR/#)r!rprr'r(r))r*s"r+r,-AsyncAcquireReadWriteReturnProxy.__annotate__@s/Dr.c WnR#rgro)r;rps&&r+r>)AsyncAcquireReadWriteReturnProxy.__init__@s r.cV^8dQhRR/#)r!r'rr))r*s"r+r,rCs"4r.c ""VP#5irgrorCs&r+ __aenter__+AsyncAcquireReadWriteReturnProxy.__aenter__Csyys c(V^8dQhRRRRRRRR/#) r!exc_typeztype[BaseException] | None exc_valuere tracebackzTracebackType | Noner'r(r))r*s"r+r,rFs2"","("( "  "r.c V"VPP4GRjxL R#L5irg)rprh)r;rrrs&&&&r+ __aexit__*AsyncAcquireReadWriteReturnProxy.__aexit__Fs ii!!!s )')roN) rrrrrr>rrrr)r.r+rmrm=sO""r.rm)*r __future__rrrsr1rconcurrent.futuresr contextlibrtypingrrr_apirr r r _asyncr r rrrr _read_writercollections.abcrr concurrentrtypesrrrrrrm__all__r)r.r+rsK" 1*44 '8"#(t_ T]R0R0j""&' r.