Kiw6SrSSKJr SSKrSSKrSSKrSSKrSSKrSSKJ r SSK J r SSK J r SSKJrJrJrJr SS KJrJrJrJr SS KJr SS KJr SS KJr SS KJr \(a3SSK r SSK!J"r" SSK#J$r$ SSK%J&r& \ RNS:aSSKJ(r( OSSK)J(r( \RT"S5r+\ "SS\55r,"SS\,\ 5r-"SS5r."SS\5r/"SS\\/S9r0"SS \\05r1"S!S"\\05r2"S#S$\\05r3/S%Qr4g)&z1An asyncio-based implementation of the file lock.) annotationsN) dataclass)iscoroutinefunction)local) TYPE_CHECKINGAnyNoReturncast)_UNSET_FILE_MODE BaseFileLockFileLockContext FileLockMeta)Timeout) SoftFileLock) UnixFileLock)WindowsFileLock)Callable)futures) TracebackType) )SelffilelockcD\rSrSr%SrSrS\S'SrS\S'SrS \S 'S r g) AsyncFileLockContext$zGA dataclass which holds the context for a ``BaseAsyncFileLock`` object.Tboolrun_in_executorNfutures.Executor | Noneexecutor asyncio.AbstractEventLoop | Noneloop) __name__ __module__ __qualname____firstlineno____doc__r__annotations__r!r#__static_attributes__r$R/var/www/html/dynamic-report/venv/lib/python3.13/site-packages/filelock/asyncio.pyrr$s+Q!OT )-H%,.2D *1r,rc\rSrSrSrSrg)AsyncThreadLocalFileContext2z8A thread local version of the ``FileLockContext`` class.r$Nr%r&r'r(r)r+r$r,r-r/r/2sBr,r/cF\rSrSrSrSSjrS SjrS SjrSrg) AsyncAcquireReturnProxy6zDA context-aware object that will release the lock file when exiting.cXlgNlock)selfr8s r-__init__ AsyncAcquireReturnProxy.__init__9s r,c"# UR$7fr6r7r9s r- __aenter__"AsyncAcquireReturnProxy.__aenter__<syys cT# URR5IShvN gN7fr6)r8releaser9exc_type exc_value tracebacks r- __aexit__!AsyncAcquireReturnProxy.__aexit__?s ii!!!s (&(r7N)r8BaseAsyncFileLockreturnNone)rIrHrCztype[BaseException] | NonerDzBaseException | NonerEzTracebackType | NonerIrJ) r%r&r'r(r)r:r>rFr+r$r,r-r3r36s:N","("( "  "r,r3c x^\rSrSrS\S4SSSSSSSS.S U4SjjjjrS rU=r$) AsyncFileLockMetaHFT皙?Nblocking is_singleton poll_intervallifetimer#rr!c>U(aU (a Sn [U 5e[TU] UUUUUUUUU U U S9 n [SU 5$)Nz:run_in_executor is not supported when thread_local is True) lock_filetimeoutmode thread_localrRrSrTrUr#rr!rH) ValueErrorsuper__call__r )clsrWrXrYrZrRrSrTrUr#rr!msginstance __class__s r-r]AsyncFileLockMeta.__call__Is^ ONCS/ !7#%%'+$  '22r,r$)rWstr | os.PathLike[str]rXfloatrYintrZrrRrrSrrTrdrU float | Noner#r"rrr!r rIrH)r%r&r'r(r r]r+ __classcell__)ras@r-rMrMHs$" 3"#!%15 $,03)33 3  33333/33*3 33r,rMc P\rSrSrSrS\S4SSSSSSSS.SS jjjr\SS j5r\SS j5r \ RSS j5r \SS j5r SSSS.SSjjjr SSSjjr S SjrS!SjrS"SjrS#SjrS$SjrSrg)%rHkzD Base class for asynchronous file locks. .. versionadded:: 3.15.0 rOFTrPNrQc X@lX`l[R"U5UUUUUU U U S. n U(a[O[ "S0U D6Ulg)a Create a new lock object. :param lock_file: path to the file :param timeout: default timeout when acquiring the lock, in seconds. It will be used as fallback value in the acquire method, if no timeout value (``None``) is given. If you want to disable the timeout, set it to a negative value. A timeout of 0 means that there is exactly one attempt to acquire the file lock. :param mode: file permissions for the lockfile. When not specified, the OS controls permissions via umask and default ACLs, preserving POSIX default ACL inheritance in shared directories. :param thread_local: Whether this object's internal context should be thread local or not. If this is set to ``False`` then the lock will be reentrant across threads. :param blocking: whether the lock should be blocking or not :param is_singleton: If this is set to ``True`` then only one instance of this class will be created per lock file. This is useful if you want to use the lock object for reentrant locking without needing to pass the same object around. :param poll_interval: default interval for polling the lock file, in seconds. It will be used as fallback value in the acquire method, if no poll_interval value (``None``) is given. :param lifetime: maximum time in seconds a lock can be held before it is considered expired. When set, a waiting process will break a lock whose file modification time is older than ``lifetime`` seconds. ``None`` (the default) means locks never expire. :param loop: The event loop to use. If not specified, the running event loop will be used. :param run_in_executor: If this is set to ``True`` then the lock will be acquired in an executor. :param executor: The executor to use. If not specified, the default executor will be used. ) rWrXrYrRrTrUr#rr!Nr$)_is_thread_local _is_singletonosfspathr/r_context) r9rWrXrYrZrRrSrTrUr#rr!kwargss r-r:BaseAsyncFileLock.__init__ss_P!-) 9- * .  " O[/J`t/t/ /  r,c.URR$)z":returns: whether run in executor.)rorr=s r-r!BaseAsyncFileLock.run_in_executors}},,,r,c.URR$)z:returns: the executor.ror!r=s r-r!BaseAsyncFileLock.executors}}%%%r,c$XRlg)z[ Change the executor. :param futures.Executor | None value: the new executor or ``None`` Nru)r9values r-r!rvs"' r,c.URR$)z:returns: the event loop.)ror#r=s r-r#BaseAsyncFileLock.loops}}!!!r,)rR cancel_checkc # UcURRnUcURRnUcURRnUR=RS- sl[ U5nUR n[R"5nUR(dIUR5 [RSXV5 URUR5IShvN UR(a[RSXV5 O\URUUUUUUS9(a [!U5eSn[RXXb5 ["R$"U5IShvN M[+US9$NN![&a4 [)SURRS- 5URlef=f7f) a Try to acquire the file lock. :param timeout: maximum wait time for acquiring the lock, ``None`` means use the default :attr:`~BaseFileLock.timeout` is and if ``timeout < 0``, there is no timeout and this method will block until the lock could be acquired :param poll_interval: interval of trying to acquire the lock file, ``None`` means use the default :attr:`~BaseFileLock.poll_interval` :param blocking: defaults to True. If False, function will return immediately if it cannot obtain a lock on the first attempt. Otherwise, this method will block until the timeout expires or the lock is acquired. :param cancel_check: a callable returning ``True`` when the acquisition should be canceled. Checked on each poll iteration. When triggered, raises :class:`~Timeout` just like an expired timeout. :returns: a context object that will unlock the file when the context is exited :raises Timeout: if fails to acquire lock within the timeout period .. code-block:: python # You can use this method in the context manager (recommended) with lock.acquire(): pass # Or use an equivalent try-finally construct: lock.acquire() try: pass finally: lock.release() Nr z#Attempting to acquire lock %s on %szLock %s acquired on %s)rRr{rX start_timez2Lock %s not acquired on %s, waiting %s seconds ...rr7)rorXrRrT lock_counteridrWtime perf_counter is_locked_try_break_expired_lock_LOGGERdebug_run_internal_method_acquire_check_give_uprasynciosleep BaseExceptionmaxr3) r9rXrTrRr{lock_id lock_filenamer}r_s r-acquireBaseAsyncFileLock.acquiresP ?mm++G  }}--H   MM77M ""a'"T( &&(  ~~002MM"G`33DMMBBB>>MM":GS&&!%!-#) '"-00J cMImmM222'.'D11'C3 ),Q 0J0JQ0N)ODMM &  sPBGAF0F1+FGAF2F3F9 GFF>GGc# UR(aUR=RS-slURRS:XdU(aw[U5URp2[ R SX#5 URUR5IShvN SURl[ R SX#5 gggN.7f)z Release the file lock. The lock is only completely released when the lock counter reaches 0. The lock file itself is not automatically deleted. :param force: If true, the lock counter is ignored and the lock is released in every case. r rz#Attempting to release lock %s on %sNzLock %s released on %s) rror~rrWrrr_release)r9forcerrs r-rABaseAsyncFileLock.releases >> MM & &! + &}}))Q.%)+D4>> CW\// >>>-. * 6O 38 ?sBCC /Cc# [U5(aU"5IShvN gUR(aMUR=(d [R"5nURUR U5IShvN gU"5 gNkN7fr6)rrr#rget_running_loopr!)r9methodr#s r-r&BaseAsyncFileLock._run_internal_method,sb v & &(NN  ! !99: 8 8 :D&&t}}f= = = H  >s"B B AB ;B <B  B cSn[U5e)z Replace old __enter__ method to avoid using it. NOTE: DO NOT USE `with` FOR ASYNCIO LOCKS, USE `async with` INSTEAD. :returns: none :rtype: NoReturn z>Do not use `with` for asyncio locks, use `async with` instead.)NotImplementedError)r9r_s r- __enter__BaseAsyncFileLock.__enter__5sO!#&&r,cB# UR5IShvN U$N7f)z/ Acquire the lock. :returns: the lock object N)rr=s r-r>BaseAsyncFileLock.__aenter__Bs lln  s c@# UR5IShvN gN7f)z Release the lock. :param exc_type: the exception type if raised :param exc_value: the exception value if raised :param traceback: the exception traceback if raised N)rArBs r-rFBaseAsyncFileLock.__aexit__Lsllns c`[R"[5 UR=(d [R "5nUR 5(dURURSS95 OURURSS95 SSS5 g!,(df  g=f)z'Called when the lock object is deleted.T)rN) contextlibsuppress RuntimeErrorr#rr is_runningrun_until_completerA create_task)r9r#s r-__del__BaseAsyncFileLock.__del__\sr   .99: 8 8 :D??$$'' 4 (@A  D!9: / . .s A;B B-)rorlrk)rWrcrXrdrYrerZrrRrrSrrTrdrUrfr#r"rrr!r rIrJ)rIr)rIr )rxr rIrJ)rIr")NN) rXrfrTrfrRz bool | Noner{zCallable[[], bool] | NonerIr3)F)rrrIrJ)rzCallable[[], Any]rIrJ)rIr )rIrrK)rIrJ)r%r&r'r(r)r r:propertyrr!setterr#rrArrr>rFrr+r$r,r-rHrHks$" : "#!%15 $,0: ): :  :  : : : : : /: : *:  : x--&&__''"" !%&*O2 !%26 O2O2$O2  O2 0 O2 !O2bP& ',((    ;r,rH) metaclassc\rSrSrSrSrg)AsyncSoftFileLockifz.Simply watches the existence of the lock file.r$Nr1r$r,r-rrfs8r,rc\rSrSrSrSrg)AsyncUnixFileLockijzHUses the :func:`fcntl.flock` to hard lock the lock file on unix systems.r$Nr1r$r,r-rrjsRr,rc\rSrSrSrSrg)AsyncWindowsFileLockinzNUses the :func:`msvcrt.locking` to hard lock the lock file on windows systems.r$Nr1r$r,r-rrnsXr,r)r3rrrrH)5r) __future__rrrloggingrmr dataclassesrinspectr threadingrtypingrrr r _apir r rr_errorr_softr_unixr_windowsrsyscollections.abcr concurrentrtypesr version_infortyping_extensions getLoggerrrr/r3rMrHrrr__all__r$r,r-rs7" !'55OO%("# 7"*   J '  2? 2  2C"6C""$ 3 3Fx; 0Ax;v9 &79S &7SY?,=Y r,