Loj0;SSKJr SSKrSSKrSSKrSSKJr SSKJr SSK J r J r J r J r SSKJrJr SSKJr SS KJr SS KJrJrJrJr SS KJr SS KJrJr \(a-SSKrSS K J!r! SSK"J#r# \RHS:aSSKJ%r% OSSK&J%r% \Sr'\Sr(\"SS9"SS55r)\"SS9"SS55r*\"SS55r+"SS5r,"SS\,\ 5r-"SS \5r./S!Qr/g)") annotationsN)suppress) dataclass)EventThreadcurrent_threadlocal) TYPE_CHECKINGLiteral)LeaseSettingsMismatch)owner_is_stale)MarkerSoftFileLock OwnerMode OwnerRecord parse_marker)_read_lock_file)break_lock_filetouch)Callable) LockOptions) )Unpack)marker-missing owner-changedrefresh-failed)oklost transientT)frozencF\rSrSr%SrS\S'S\S'S\S'SrS \S 'S rg) LeaseCompromise!z6Why a held lease stopped being this process's to hold.str lock_filetokenCompromiseReasonreasonNOSError | Noneerror)__name__ __module__ __qualname____firstlineno____doc____annotations__r+__static_attributes__r,I/mnt/workspace/venv-train/lib/python3.13/site-packages/filelock/_lease.pyr#r#!s@N J  E> r4r#c.\rSrSr%SrS\S'S\S'Srg) _Heartbeat+zPA running heartbeat and the event that stops it, which only ever exist together.rthreadrstopr,N)r-r.r/r0r1r2r3r,r4r5r7r7+sZ N Kr4r7cD\rSrSr%SrSrS\S'SrS\S'SrS\S 'S r g) _LeaseClaim3zNThe state of one claim: its token, its heartbeat, and how that claim was lost.N str | Noner'LeaseCompromise | None compromisez_Heartbeat | None heartbeatr,) r-r.r/r0r1r'r2r@rAr3r,r4r5r<r<3s%XE:)-J&-#'I 'r4r<c"\rSrSrSrSSjrSrg)_LeaseClaimHolder<z,Holds the claim its owning context acquired.c"[5UlgN)r<claimselfs r5__init___LeaseClaimHolder.__init__Bs  ] r4)rGNreturnNone)r-r.r/r0r1rJr3r,r4r5rCrC<s 6 #r4rCc\rSrSrSrSrg)_ThreadLocalLeaseClaimHolderFz:A thread local version of the ``_LeaseClaimHolder`` class.r,N)r-r.r/r0r1r3r,r4r5rPrPFsDr4rPc^\rSrSr%SrSrS\S'SrS\S'S rS \S 'S S S S.SU4Sjjjr \ S Sj5r \ S!Sj5r \ S"Sj5r \ S#Sj5rS$U4SjjrS$U4SjjrS%U4SjjrS$U4SjjrS&SjrS'SjrS$SjrS(SjrS)SjrS*SjrSrU=r$)+ SoftFileLeaseJa Existence lock whose claim expires, so a peer may take it while the previous holder still runs. A lease trades mutual exclusion for progress. The holder publishes a claim and refreshes it every ``heartbeat_interval`` seconds; a contender takes the marker once it is ``lease_duration`` seconds stale. Nothing stops the expired holder: it keeps running, and it keeps using whatever the lock protects. Treat the lease as a hint about who *should* be working, not as a guarantee that only one worker is. To make a protected resource reject a superseded holder, that resource must be linearizable and must fence on a monotonic generation it controls. :attr:`token` names a claim; it does not fence one. Where overlap is unacceptable, use :class:`StrictSoftFileLock ` instead. Every contender for a path must agree on ``lease_duration``. A contender that finds a claim published under a different duration raises :class:`LeaseSettingsMismatch ` rather than apply its own expiry to a peer that never agreed to it. Expiry reclaims less on Windows, which refuses to rename or delete a file another process holds open. A peer there takes an expired claim only once the previous holder's process exits and its handle closes; a holder that lives on but stops refreshing keeps the marker. Unix reclaims the marker either way. ``on_compromise`` fires from the heartbeat thread when a refresh fails, or when the marker vanishes or names another owner. The holder should stop touching the protected resource when it runs. Because it runs on that thread, a ``release()`` inside it only takes effect when the lease was built with ``thread_local=False``; the default thread-local context hides the claim from every thread but the one that acquired it, so the release does nothing. Signal the acquiring thread instead when the context stays thread-local. .. versionadded:: 3.30.0 leaser _owner_modeFbool_lifetime_supportedz(lease_duration sets when a lease expiresr%_lifetime_unsupported_reasong>@N)lease_durationheartbeat_interval on_compromisec  >US::aSU<3n[U5eUcUS- nSUs=:aU:dO SU<3n[U5e[TU]"U40UD6 X lX0lX@lUR 5(a[O["5Ul g)a' Create a lease. :param lease_duration: seconds of marker staleness after which a contender may take the claim. Every contender for the path must pass the same value. :param heartbeat_interval: seconds between refreshes. Defaults to a third of ``lease_duration``, leaving room for two missed refreshes before a peer may take the claim. Must be shorter than ``lease_duration``. :param on_compromise: called from the heartbeat thread with a :class:`LeaseCompromise` when the claim is lost. :param kwargs: every other :class:`BaseFileLock ` option, ``timeout`` and ``mode`` among them. The metaclass passes them all by keyword, and taking them here lets :class:`AsyncSoftFileLease ` add the async plumbing a fixed signature would hide. rz%lease_duration must be positive, got NrzBheartbeat_interval must be positive and below lease_duration, got ) ValueErrorsuperrJ_lease_duration_heartbeat_interval_on_compromiseis_thread_localrPrC_claims)rIr&rZr[r\kwargsmsg __class__s r5rJSoftFileLease.__init__os. Q 9.9KLCS/ !  %!/!!3 %66VWiVlmCS/ ! -f--#5 +-1,@,@,B,B (HY Y+  r4c.URR$rF)rdrGrHs r5_claimSoftFileLease._claims||!!!r4cUR$)zEThe staleness in seconds after which a contender may take this claim.)r`rHs r5rZSoftFileLease.lease_durations###r4c.URR$)z The token naming the claim this process published. :returns: the token while the lease is held, ``None`` otherwise. It identifies a claim; it does not fence one. )rjr'rHs r5r'SoftFileLease.tokens{{   r4c.URR$)z} The loss of claim the heartbeat observed. :returns: the :class:`LeaseCompromise`, or ``None`` while the claim still holds )rjr@rHs r5r@SoftFileLease.compromises{{%%%r4c0>URnUR5 [R"S5=UlnSUl[ TU]5 URR=nb.URR=nbURXXB5 ggg)N) rj_stop_heartbeatsecrets token_hexr'r@r__acquire_context lock_file_fdlock_file_fd_identity_start_heartbeat)rIrGr'fdidentityrgs r5rwSoftFileLease._acquires  %//33 e --,, ,B 9 ;; ;H?  ! !%X =? 9r4cd>UR5 SURl[TU]5 grF)rtrjr'r__releaserIrgs r5rSoftFileLease._releases&    r4cx>[TU]5RURRUR S9$)N)r'rZ)r__published_record_replacerjr'r`rs r5rSoftFileLease._published_records2w(*33$++:K:K\`\p\p3qqr4c>UR5=nc[TU] 5 gUup#nURS:wagURUR :wa6UR SUR<SUR <S3n[U5e[[5 [URURUR5(a [UR X45 SSS5 g[R"5U- UR :a[UR X45 SSS5 g!,(df  g=f)NrUz holds a lease of z s but this contender configured z:s; every contender for a path must agree on lease_duration) _read_peerr__try_break_stale_lockmoderZr`r&r rOSErrorrpidhostnamestartrtime)rIpeerownermtimeinorfrgs r5r#SoftFileLease._try_break_stale_locks OO% %D . G ) +  c ::    4#7#7 7>>""4U5I5I4LLl''**df (, ,g eiiEE;   yy{U"d&:&::;  sAD/*)rMr?rL)rMr)rMz%tuple[OwnerRecord, float, int] | None) rGr<r|intr}tuple[int, int]r'r%rMrN) rGr<r|rr}rr'r%r:rrMrN) rGr<r|rr}rr'r%rMz&tuple[_RefreshOutcome, OSError | None]) rGr<r)r(r+r*r'r%rMrN)r-r.r/r0r1rVr2rXrYrJpropertyrjrZr'r@rwrrrrr{rtrrrr3 __classcell__)rgs@r5rSrSJs<%K$!&%(R #R !%+/BF ' )'  ' ) ' @ ' &'  ' ' R""$$!!&& > r<< D "      0 "    0 0 2 2! 2 2  2  2 2r4rS)r(r#rS)0 __future__rrrur contextlibr dataclassesr threadingrrrr typingr r _errorr _identityr_markerrrrr_softr_utilrrsyscollections.abcr_apir version_infortyping_extensionsr(_RefreshOutcomer#r7r<rCrPrS__all__r,r4r5rs"  !::))%MM")(! 7"!,NO34 $!!! $ (( (##E#4eE}2&}2@ r4