+ j>^RIHt^RIt^RIt^RIt^RIHt^RIHt^RI H t ^RI H t H t HtHt^RIHtHt^RIHt^R IHt^R IHtHtHtHt^R IHt^R IHtH t ]'d/^RI!t!^R I"H#t#^RI$H%t%]!PLR8d^RIH't'M^RI(H't']R,t)]R ,t*]!RR7!RR44t+]!RR7!RR44t,]!RR44t-!RR4t.!RR].]4t/!RR]4t0.R!Ot1R#)") annotationsN)suppress) dataclass)isfinite)EventThreadcurrent_threadlocal) TYPE_CHECKINGLiteral)LeaseSettingsMismatch)owner_is_stale)MarkerSoftFileLock OwnerMode OwnerRecord parse_marker)_read_lock_file)break_lock_filetouch)Callable) LockOptions)UnpackT)frozencH]tRt^$t$RtR]R&R]R&R]R&RtR]R &R tR#) LeaseCompromisez6Why a held lease stopped being this process's to hold.str lock_filetokenCompromiseReasonreasonNOSError | Noneerror)__name__ __module__ __qualname____firstlineno____doc____annotations__r"__static_attributes__r#P/home/luca/screen-checking/.venv/lib/python3.14/site-packages/filelock/_lease.pyrr$s@N J  E> r+rc0]tRt^.t$RtR]R&R]R&RtR#) _HeartbeatzPA running heartbeat and the event that stops it, which only ever exist together.rthreadrstopr#N)r$r%r&r'r(r)r*r#r+r,r.r..sZ N Kr+r.cF]tRt^6t$RtRtR]R&RtR]R&RtR]R&R t R#) _LeaseClaimzNThe state of one claim: its token, its heartbeat, and how that claim was lost.N str | NonerLeaseCompromise | None compromisez_Heartbeat | None heartbeatr#) r$r%r&r'r(rr)r5r6r*r#r+r,r2r26s%XE:)-J&-#'I 'r+r2c&]tRt^?tRtRRltRtR#)_LeaseClaimHolderz,Holds the claim its owning context acquired.cV^8dQhRR/#returnNoner#)formats"r, __annotate___LeaseClaimHolder.__annotate__Es##$#r+c $\4VnR#N)r2claimselfs&r,__init___LeaseClaimHolder.__init__Es  ] r+)rCN)r$r%r&r'r(rFr*r#r+r,r8r8?s6 ##r+r8c]tRt^ItRtRtR#)_ThreadLocalLeaseClaimHolderz:A thread local version of the ``_LeaseClaimHolder`` class.r#N)r$r%r&r'r(r*r#r+r,rIrIIsDr+rIcVa]tRt^Mt$RtRtR]R&RtR]R&RtR ]R &R R R RRR/RV3Rlllt ] RRl4t ] RRl4t ] RRl4t ] RRl4tRV3RlltRV3RlltRV3RlltR V3R!lltR"R#ltR$R%ltR&R'ltR(R)ltR*R+ltR,R-ltR.tV;t#)/ SoftFileLeasea 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_reasonlease_durationg>@heartbeat_intervalN on_compromisec 0V^8dQhRRRRRRRRR R R R /#) r;rzstr | os.PathLike[str]rQfloatrRz float | NonerSz(Callable[[LeaseCompromise], None] | NonekwargszUnpack[LockOptions]r<r=r#)r>s"r,r?SoftFileLease.__annotate__rsG* * )*  * ) * @ * &*  * r+c <\V\4'g\V\\34'g$R\ V4P 2p\ V4h\V4'dV^8:dRV: 2p\V4hVf V^, p^Tu;8dV8gMRV: 2p\V4h\SV`(!V3/VBW n W0n W@n VP4'd\M\ !4VnR#)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. z5lease_duration must be a finite positive number, not z0lease_duration must be positive and finite, got NzBheartbeat_interval must be positive and below lease_duration, got ) isinstancerNintrUtyper$ TypeErrorr ValueErrorsuperrF_lease_duration_heartbeat_interval_on_compromiseis_thread_localrIr8_claims)rErrQrRrSrVmsg __class__s&&$$$, r,rFSoftFileLease.__init__rs. nd + +:nsTYl3[3[I$~J^JgJgIhiCC. ''>Q+>D^DVWCS/ !  %!/!!3 %66VWiVlmCS/ ! -f--#5 +-1,@,@,B,B (HY Y+  r+cV^8dQhRR/#)r;r<r2r#)r>s"r,r?rWs"" "r+c .VPP#rB)rcrCrDs&r,_claimSoftFileLease._claims||!!!r+cV^8dQhRR/#)r;r<rUr#)r>s"r,r?rWs$$$r+c VP#)zEThe staleness in seconds after which a contender may take this claim.)r_rDs&r,rQSoftFileLease.lease_durations###r+cV^8dQhRR/#)r;r<r3r#)r>s"r,r?rWs!!z!r+c .VPP#)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. )rirrDs&r,rSoftFileLease.tokens{{   r+cV^8dQhRR/#)r;r<r4r#)r>s"r,r?rWs&&2&r+c .VPP#)z} The loss of claim the heartbeat observed. :returns: the :class:`LeaseCompromise`, or ``None`` while the claim still holds )rir5rDs&r,r5SoftFileLease.compromises{{%%%r+cV^8dQhRR/#r:r#)r>s"r,r?rWs$r+c t<VPpVP4\P!^4;VnpRVn\ SV`4TPP;pe0TPP;peTPYYB4R#RTnR# \d RTnhi;i)N) ri_stop_heartbeatsecrets token_hexrr5r^_acquire BaseException_context lock_file_fdlock_file_fd_identity_start_heartbeat)rErCrfdidentityres& r,rzSoftFileLease._acquires  %//33 e  G   --,, ,B 9 ;; ;H?  ! !%X =EK EK  s B##B7cV^8dQhRR/#r:r#)r>s"r,r?rWs$r+c f<VP4RVPn\SV`4R#rB)rwrirr^_releaserEres&r,rSoftFileLease._releases&    r+cV^8dQhRR/#)r;r<rr#)r>s"r,r?rWsrr;rr+c ~<\SV`4PVPPVP R7#))rrQ)r^_published_record_replacerirr_rs&r,rSoftFileLease._published_records2w(*33$++:K:K\`\p\p3qqr+cV^8dQhRR/#r:r#)r>s"r,r?rWs<>""4U5I5I4LLl''**df (, ,g  eiiEE;   yy{U"d&:&::;   s&A E9AE E cV^8dQhRR/#)r;r<z%tuple[OwnerRecord, float, int] | Noner#)r>s"r,r?rWsAr+c \\\4;_uu_4\VP4wrp\ V4;peWBV3uuRRR4#RRR4R# +'giR#;irB)rrr]rrr)rEcontentrrrs& r,rSoftFileLease._read_peers] gz * *"1$.."A GC%g..;S(+ *;+ + *s +A A/ c ,V^8dQhRRRRRRRRR R /#) r;rCr2rrZrtuple[int, int]rrr<r=r#)r>s"r,r?rWs1kso^afjr+c \4p\VPWW4V3R\P!4 2RR7p\ We4VnVP4R#)zfilelock-lease-T)targetargsnamedaemonN)rr_refresh_until_stoppedosgetpidr.r6r)rErCrrrr0r/s&&&&& r,rSoftFileLease._start_heartbeatsRw..Xd3"299;-0  %V2 r+cV^8dQhRR/#r:r#)r>s"r,r?rW s D D Dr+c 8VPpVP;pfR#VPP4RVnVPP eCVP\ 4Jd)VPPVPR7R#R#R#)N)timeout) rir6r0setr/identr joinr`)rErCr6s& r,rwSoftFileLease._stop_heartbeat s~  (I 1     ! ! -)2B2B.JZ2Z    ! !$*B*B ! C3[ -r+c 0V^8dQhRRRRRRRRR R R R /#) r;rCr2rrZrrrrr0rr<r=r#)r>s"r,r?rWsF "      r+c \P!4pVPVP4'gVP WW44wrxVR8XdR#VR8Xd\P!4pK\\P!4V, VP VP, 8gKVP VRW4R#R#)lostNokrefresh-failed)r monotonicwaitr`_refresh_claimr__report_compromise) rErCrrrr0 last_successoutcomer"s &&&&&& r,r$SoftFileLease._refresh_until_stoppeds~~' ))D4455!00HLNG& $#~~/ !L0D4H4H4KcKc4cc''/?N6r+c ,V^8dQhRRRRRRRRR R /#) r;rCr2rrZrrrrr<z&tuple[_RefreshOutcome, OSError | None]r#)r>s"r,r?rW0s< "    0 r+c \P!VP4pTP TP3T8wdTP TRRT4R#\TPTR7R# \d pTP TRYd4RuRp?#Rp?i\ dpRT3uRp?#Rp?ii;i \ dpRT3uRp?#Rp?ii;i)marker-missingN transient owner-changed)r)rN)rN) rlstatrFileNotFoundErrorrrst_devst_inor)rErCrrrstr"s&&&&& r,rSoftFileLease._refresh_claim0s &$..)B IIryy !X -  # #E?D% H  & $..R (!  # #E+;U J  &% % & &% % &sS A/B3/ B0:BB0 B0!B0"B+%B0+B03 C >CC C c ,V^8dQhRRRRRRRRR R /#) r;rCr2r rr"r!rrr<r=r#)r>s"r,r?rWHs< 2 2 2! 2 2  2  2r+c \VPWBVR7VnVPeVPVP4R#R#))rrr r"N)rrr5ra)rErCr r"rs&&&&&r,r SoftFileLease._report_compromiseHs?+T^^5glm    *    0 0 1 +r+)rcr`r_ra)r$r%r&r'r(rMr)rOrPrFpropertyrirQrr5rzrrrrrrwrrrr* __classcell__)res@r,rKrKMs<%K$!&%(R #R* !% * ,0 * CG * * X""$$!!&&( rr<<< D00 2 2r+rK) )rrrevicted)rrr)rrrK)2 __future__rrrxr contextlibr dataclassesrmathr threadingrrr r typingr r _errorr _identityr_markerrrrr_softr_utilrrsyscollections.abcr_apir version_infortyping_extensionsr_RefreshOutcomerr.r2r8rIrK__all__r#r+r,rs"  !::))%MM")(! 7"!,YZ34 $!!! $ (( (##E#4eEG2&G2T r+