ybj^=SSKJr SSKrSSKrSSKrSSKJr SSKJr SSK J r SSK J r J r JrJr SSKJrJr SS KJr SS KJr SS KJrJrJrJr SS KJr SS KJrJ r \(a-SSK!r!SSK"J#r# SSK$J%r% \!RLS:aSSKJ'r' OSSK(J'r' \Sr)\Sr*\"SS9"SS55r+\"SS9"SS55r,\"SS55r-"SS5r."SS\.\5r/"S S!\5r0/S"Qr1g)#) 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) )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-ڋ/tmp/claude-0/-home-danvics-docker-quiz/c1e0577a-e42c-4a3d-b1ea-3edd61103a4e/scratchpad/stt/lib/python3.13/site-packages/filelock/_lease.pyr$r$"s@N J  E> r5r$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/r0r1r2r3r4r-r5r6r8r8,sZ N Kr5r8cD\rSrSr%SrSrS\S'SrS\S'SrS\S 'S r g) _LeaseClaim4zNThe 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/r0r1r2r(r3rArBr4r-r5r6r=r=4s%XE:)-J&-#'I 'r5r=c"\rSrSrSrSSjrSrg)_LeaseClaimHolder=z,Holds the claim its owning context acquired.c"[5UlgN)r=claimselfs r6__init___LeaseClaimHolder.__init__Cs  ] r5)rHNreturnNone)r.r/r0r1r2rKr4r-r5r6rDrD=s 6 #r5rDc\rSrSrSrSrg)_ThreadLocalLeaseClaimHolderGz:A thread local version of the ``_LeaseClaimHolder`` class.r-N)r.r/r0r1r2r4r-r5r6rQrQGsDr5rQc^\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$)+ SoftFileLeaseKa 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 >[U[5(d[U[[45(d#S[ U5R 3n[ U5e[U5(aUS::aSU<3n[U5eUcUS- nSUs=:aU:dO SU<3n[U5e[TU]("U40UD6 X l X0l X@l UR5(a[O[ "5Ulg)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 rz0lease_duration must be positive and finite, got NrzBheartbeat_interval must be positive and below lease_duration, got ) isinstancerXintfloattyper. TypeErrorr ValueErrorsuperrK_lease_duration_heartbeat_interval_on_compromiseis_thread_localrQrD_claims)rJr'r[r\r]kwargsmsg __class__s r6rKSoftFileLease.__init__ps. nd + +:nsTYl3[3[I$~J^JgJgIhiCC. ''>Q+>D^DVWCS/ !  %!/!!3 %66VWiVlmCS/ ! -f--#5 +-1,@,@,B,B (HY Y+  r5c.URR$rG)rjrHrIs r6_claimSoftFileLease._claims||!!!r5cUR$)zEThe staleness in seconds after which a contender may take this claim.)rfrIs r6r[SoftFileLease.lease_durations###r5c.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. )rpr(rIs r6r(SoftFileLease.tokens{{   r5c.URR$)z} The loss of claim the heartbeat observed. :returns: the :class:`LeaseCompromise`, or ``None`` while the claim still holds )rprArIs r6rASoftFileLease.compromises{{%%%r5cj>URnUR5 [R"S5=UlnSUl[ TU]5 URR=nb-URR=nbURXXB5 gSUlg![a SUlef=f)N) rp_stop_heartbeatsecrets token_hexr(rAre_acquire BaseException_context lock_file_fdlock_file_fd_identity_start_heartbeat)rJrHr(fdidentityrms r6r}SoftFileLease._acquires  %//33 e  G   --,, ,B 9 ;; ;H?  ! !%X =EK EK  s BB2cd>UR5 SURl[TU]5 grG)rzrpr(re_releaserJrms r6rSoftFileLease._releases&    r5cx>[TU]5RURRUR S9$)N)r(r[)re_published_record_replacerpr(rfrs r6rSoftFileLease._published_records2w(*33$++:K:K\`\p\p3qqr5c>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)NrVz holds a lease of z s but this contender configured z:s; every contender for a path must agree on lease_duration) _read_peerre_try_break_stale_lockmoder[rfr'rrOSErrorrpidhostnamestartrtime)rJpeerownermtimeinorlrms r6r#SoftFileLease._try_break_stale_locks OO% %D . G ) +  c ::    4#7#7 7>>""4U5I5I4LLl''**df (, ,g eiiEE;   yy{U"d&:&::;  sAD/*rs"  !::))%MM")(! 7"!,NO34 $!!! $ (( (##E#4eEG2&G2T r5