KiRp%SSKJr SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSK r SSK J r J r SSK Jr SSKJr SSKJrJrJr SSKJr SS KJr S rS \S '\(a/SS KJr SSKJr SSKJ r \RBS:aSSKJ"r" OSSK#J"r" \RH"S5r%\RLS:Xa\RNRPO\RNRRr*"SS\5r+\+"5r,"SS5r-\"SS55r."SS\.\5r/"SS\ 5r0"SS\Rb\0S 9r2/S!Qr3g)") annotationsN)ABCMetaabstractmethod) dataclass)local) TYPE_CHECKINGAnycast)WeakValueDictionary)Timeoutint_UNSET_FILE_MODE)Callable) TracebackType) ReadWriteLock) )Selffilelockwin32c,^\rSrSrSU4SjjrSrU=r$)_ThreadLocalRegistry+c0>[TU]5 0UlgN)super__init__held)self __class__s O/var/www/html/dynamic-report/venv/lib/python3.13/site-packages/filelock/_api.pyr_ThreadLocalRegistry.__init__,s $& )r returnNone)__name__ __module__ __qualname____firstlineno__r__static_attributes__ __classcell__r"s@r#rr+s ''r%rcF\rSrSrSrSSjrS SjrS SjrSrg) AcquireReturnProxy7zDA context-aware object that will release the lock file when exiting.cXlgrlock)r!r5s r#rAcquireReturnProxy.__init__:s26 r%cUR$rr4r!s r# __enter__AcquireReturnProxy.__enter__=s yyr%c8URR5 gr)r5releaser!exc_type exc_value tracebacks r#__exit__AcquireReturnProxy.__exit__@s r%r4N)r5BaseFileLock | ReadWriteLockr'r()r'rCr>ztype[BaseException] | Noner?zBaseException | Noner@zTracebackType | Noner'r() r)r*r+r,__doc__rr9rAr-r%r#r1r17s:N7,((   r%r1cv\rSrSr%SrS\S'S\S'S\S'S \S 'S\S 'S rS \S'S rS\S'SrS\S'Sr g )FileLockContextIzBA dataclass which holds the context for a ``BaseFileLock`` object.str lock_filefloattimeoutrmodeboolblocking poll_intervalN float | Nonelifetimez int | None lock_file_fdr lock_counterrF) r)r*r+r,rE__annotations__rSrTrUr-rFr%r#rHrHIsML NN IN"Hl! $L*#L#r%rHc\rSrSrSrSrg)ThreadLocalFileContextiz8A thread local version of the ``FileLockContext`` class.rFN)r)r*r+r,rEr-rFr%r#rXrXisBr%rXcv^\rSrSr%S\S'S\S4SSSSS .S U4S jjjjrS rU=r$) FileLockMetam&WeakValueDictionary[str, BaseFileLock] _instancesrTF皙?NrP is_singletonrQrSc x>U(GaURR[U55n U (aXJR54X*R4X:R R 4XZR4XzR4XR4S.n U R5V V Vs0sHun upX:wdMXU4_M nn n nU(d [SU 5$SnUS- nUR5HunupUSUSUSU S3- nM [U5eUUUUUUUS .U En[R"UR5R nUR5VVs0sHunnUU;dMUU_M nnn["TU]H"U40UD6n U(aXR[U5'[SU 5$s snn n fs snnf) N) thread_localrMrNrPrQrS BaseFileLockzGSingleton lock instances cannot be initialized with differing argumentsz Non-matching arguments: z z (existing lock has z but z was passed))rMrNrcrPrarQrS)r^getrJis_thread_localrM_contextrNrPrQrSitemsr ValueErrorinspect signaturer parametersr__call__)clsrKrMrNrcrPrarQrSkwargsinstanceparams_to_checkname passed_param set_paramnon_matching_paramsmsg param_name all_paramspresent_paramskeyvalue init_paramsr"s r#rmFileLockMeta.__call__ps ~~))#i.9H%13K3K3M$N ')9)9:!#4#4#9#9:!)+<+< =&35K5K%L!)+<+< = #Y o%( (*     !**3<<8CC4>4D4D4F`4Fjc5#Q_J_zsEz4F `7#I== -5NN3y> *NH--M'>as"F/4F/ F6*F6rF)rKstr | os.PathLike[str]rMrLrNrrcrOrPrOrarOrQrLrSrRror r'rd) r)r*r+r,rVrrmr-r.r/s@r#r[r[ms66 $! ?."#!%?.)?.?. ?.  ?.?.?.?.?.?. ?.?.r%r[c^\rSrSr%SrS\S'S(U4SjjrS\S4SSS S S .S)S jjjrS*S jr \ S*Sj5r \ S+Sj5r \ S,Sj5r \ RS-Sj5r \ S*Sj5r\RS.Sj5r\ S,Sj5r\RS/Sj5r\ S0Sj5r\RS1Sj5r\ S2Sj5r\ S*Sj5rS2SjrS3Sjr\S3Sj5r\S3Sj5r\ S*Sj5r\ S2Sj5r\S4S j5rS5S S S S!.S6S"jjjrS7S8S#jjrS9S$jrS:S%jr S3S&jr!S'r"U=r#$);rdaH Abstract base class for a file lock object. Provides a reentrant, cross-process exclusive lock backed by OS-level primitives. Subclasses implement the actual locking mechanism (:class:`UnixFileLock `, :class:`WindowsFileLock `, :class:`SoftFileLock `). r]r^c D>[TU]"S0UD6 [5Ulg)z'Setup unique state for lock subclasses.NrF)r__init_subclass__r r^)rnror"s r#rBaseFileLock.__init_subclass__s !+F+,.r%rTFr_Nr`cX@lX`l[R"U5UUUUUS.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. )rKrMrNrPrQrSNrF)_is_thread_local _is_singletonosfspathrXrHrg) r!rKrMrNrcrPrarQrSros r#rBaseFileLock.__init__sRD!-) 9- * " EQ*@Ve*e)pio)p r%cUR$)z?:returns: a flag indicating if this lock is thread local or not)rr8s r#rfBaseFileLock.is_thread_locals$$$r%cUR$)zY :returns: a flag indicating if this lock is singleton or not .. versionadded:: 3.13.0 )rr8s r#raBaseFileLock.is_singletons!!!r%c.URR$)z:returns: path to the lock file)rgrKr8s r#rKBaseFileLock.lock_files}}&&&r%c.URR$)zK :returns: the default timeout value, in seconds .. versionadded:: 2.0.0 )rgrMr8s r#rMBaseFileLock.timeouts}}$$$r%c8[U5URlg)zM Change the default timeout value. :param value: the new value, in seconds N)rLrgrMr!r{s r#rMrs!&e  r%c.URR$)zM :returns: whether the locking is blocking or not .. versionadded:: 3.14.0 rgrPr8s r#rPBaseFileLock.blocking}}%%%r%c$XRlg)zJ Change the default blocking value. :param value: the new value as bool Nrrs r#rPr%"' r%c.URR$)zO :returns: the default polling interval, in seconds .. versionadded:: 3.24.0 rgrQr8s r#rQBaseFileLock.poll_interval/s}}***r%c$XRlg)zP Change the default polling interval. :param value: the new value, in seconds Nrrs r#rQr9s', #r%c.URR$)zj :returns: the lock lifetime in seconds, or ``None`` if the lock never expires .. versionadded:: 3.24.0 rgrSr8s r#rSBaseFileLock.lifetimeCrr%c$XRlg)zg Change the lock lifetime. :param value: the new value in seconds, or ``None`` to disable expiration Nrrs r#rSrMrr%cnURR[:XaS$URR$)z/:returns: the file permissions for the lockfileirgrNrr8s r#rNBaseFileLock.modeWs+ **.>>uVDMMDVDVVr%c<URR[:g$)z::returns: whether the file permissions were explicitly setrr8s r#has_explicit_modeBaseFileLock.has_explicit_mode\s}}!!%555r%cnURR[:XaS$URR$)ue:returns: the mode for os.open() — 0o666 when unset (let umask/ACLs decide), else the explicit modeirr8s r# _open_modeBaseFileLock._open_modeas) **.>>uVDMMDVDVVr%cFURR=ncg[R"[5 [ R "5[ R"UR5R5R- U:a SSS5 gURS[R"53n[ R"UR5RU5 [ R"U5R5 SSS5 g!,(df  g=f)zVRemove the lock file if its modification time exceeds the configured :attr:`lifetime`.Nz.break.)rgrS contextlibsuppressOSErrortimepathlibPathrKstatst_mtimergetpidrenameunlink)r!rS break_paths r#_try_break_expired_lock$BaseFileLock._try_break_expired_lockes .. .H 7    )yy{W\\$..9>>@IIIHT* )!NN+7299;-@J LL ( / / ; LL $ + + - * ) )sADA7D D c[e)zjIf the file lock could be acquired, self._context.lock_file_fd holds the file descriptor of the lock file.NotImplementedErrorr8s r#_acquireBaseFileLock._acquirep "!r%c[e)z>Releases the lock and sets self._context.lock_file_fd to None.rr8s r#_releaseBaseFileLock._releaseurr%c2URRSL$)z :returns: A boolean indicating if the lock file is holding the lock currently. .. versionchanged:: 2.0.0 This was previously a method and is now a property. N)rgrTr8s r# is_lockedBaseFileLock.is_lockedzs}}))55r%c.URR$)zQ:returns: The number of times this lock has been acquired (but not yet released).)rgrUr8s r#rUBaseFileLock.lock_counters}})))r%cUSLa[RSX5 gUb#U"5(a[RSX5 gSUs=::a[R"5U- :aO g[RSX5 gg)NFz+Failed to immediately acquire lock %s on %sTz(Cancellation requested for lock %s on %srz"Timeout on acquiring lock %s on %s)_LOGGERdebugr perf_counter)lock_id lock_filenamerP cancel_checkrM start_times r#_check_give_upBaseFileLock._check_give_upss u  MMG `  #  MMDg ]  :$++- : : MM> Wr%)poll_intervallrPrc UcURRnUcURRnUbSn[R"U[ SS9 UnUbUOURR nUR=RS- sl[U5nURn[U5n URRS:H=(a& UR(+=(a US:=(a Un U (aW[RRU 5=n b5X:wa0UR=RS-slSUS3n[U5e[ R""5n UR(d6UR%5 [&R)S Xx5 UR+5 UR(a[&R)S Xx5 OTUR-UUUUUU S 9(a [/U5eS n[&R)XgX5 [ R0"U5 MURRS:XaU[RU '[9US 9$![2an [5SURRS- 5URlURRS:Xa [RR7U S5 ef=f)a Try to acquire the file lock. :param timeout: maximum wait time for acquiring the lock, ``None`` means use the default :attr:`~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:`~poll_interval` :param poll_intervall: deprecated, kept for backwards compatibility, use ``poll_interval`` instead :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() .. versionchanged:: 2.0.0 This method returns now a *proxy* object instead of *self*, so that it can be used in a with statement without side effects. Nz+use poll_interval instead of poll_intervall) stacklevelr rzDeadlock: lock 'z' is already held by a different FileLock instance in this thread. Use is_singleton=True to enable reentrant locking across instances.z#Attempting to acquire lock %s on %szLock %s acquired on %s)rPrrMrz2Lock %s not acquired on %s, waiting %s seconds ...r4)rgrMrPwarningswarnDeprecationWarningrQrUidrK _canonicalr _registryr re RuntimeErrorrrrrrrrr sleep BaseExceptionmaxpopr1) r!rMrQrrPrrvrr canonical would_blockexistingrs r#acquireBaseFileLock.acquires]\ ?mm++G  }}--H  %?C MM#1a @*M)6)B  HcHc  ""a'"T( }- mm00A5idnn:LiQX[\Q\iai  (:(:9(EEHRW_Wj MM & &! + &"=/2=>  s# #&&(  ~~002MM"G`MMO>>MM":GS&&!%!-#) '"-00J cMI =)'2 == % % *(/INN9 %!t,, ),Q 0J0JQ0N)ODMM &}}))Q.""9d3   s*A/I$AI$$A8KcUR(aUR=RS-slURRS:XdU(a[U5URp2[ R SX#5 UR5 SURl[RR[U5S5 [ R SX#5 ggg)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) rrgrUrrKrrrrr rr)r!forcerrs r#r<BaseFileLock.release s >> MM & &! + &}}))Q.%)+D4>> CW\ -. *"":m#r s"  '!++' #(#* 7"*   J '!$  7RWW__RWW=M=M '5' ! " $  >C_eCB.7B.JI!:..,I!X  r%