+ jHjf$Rt^RIt^RIt^RIt^RIHtHt]P!]4t Rt Rt RRlt !RR] 4t!R R 4t!R R 4t!R R4tR#)uPer-session turn lease — serializes the [load history -> run -> flush] region. Busy guards are keyed by ROUTING KEY but the transcript is owned by SESSION_ID, and ``switch_session()`` makes key->id many-to-one (/resume from a second chat, CLI-continuity, delegation pinning, topic tip-walks), so two keys could interleave flushes on one transcript (``user;user`` wedge). The lease serializes per RESOLVED session_id: acquired right before the transcript load, released in the dispatch layer's ``finally``; identity-checked release; a timed-out waiter fails CLOSED (:class:`TurnLeaseTimeoutError`); only idle entries evict. Limits: CLI-continuity processes are outside this lock; mid-turn rotation alias is closed by ``rebind``. N)DictOptionalig@c(V^8dQhRRR\/#)holderzOptional[TurnLeaseToken]return)tuple)formats"7/home/ubuntu/.hermes/hermes-agent/gateway/turn_lease.py __annotate__r sKK3KKcFV'dVPVP3#R#)?)rr) owner_key generation)rs&r _holder_descrs 4:F  f// 0J Jr cBaa]tRt^ toRtV3RlV3RlltRtVtV;t#)TurnLeaseTimeoutErrorzXLease held for the full wait budget; fail-closed: caller must not enter the turn region.c2<V^8dQhRS[RS[RS[RS[/#)r session_idrr wait_seconds)strintfloat)r __classdict__s"r r "TurnLeaseTimeoutError.__annotate__#s0YY3YcYsYZ_Yr c z<WuVnVnW4uVnVn\SV`RVR RV RV RV R2 4R#)z turn lease wait timed out after z.0fz s on session z for routing key z (gen )N)rrrrsuper__init__)selfrrrr __class__s&&$$$r rTurnLeaseTimeoutError.__init__#sU*4'-7** ;L;M]&<'8 6*UVX Yr )rrrr) __name__ __module__ __qualname____firstlineno____doc__r__static_attributes____classdictcell__ __classcell__)r!rs@@r rr sbYYYr rcLa]tRt^*toRtRtV3RlRltV3RlRltRtVt R#)TurnLeaseTokenzgHeld-lease handle from :meth:`SessionTurnLeaseRegistry.acquire`; ``released`` makes release idempotent.c 4<V^8dQhRS[RS[RS[RRRR/#)rrrrlease _SessionLeaserN)rr)r rs"r r TurnLeaseToken.__annotate__0s233CP_dhr cJWVuVnVnVnRVnW@nR#)FN)rrrreleasedr.)r rrrr.s&&&&&r rTurnLeaseToken.__init__0s%;ER\8  r c <V^8dQhRS[/#rr)r)r rs"r r r07sLL#Lr c tRVP: RVP: RVP RVP R2 #)zTurnLeaseToken(session_id=z , owner_key=z , generation=z , released=r)rrrr2r s&r __repr__TurnLeaseToken.__repr__7sA,T__,?|DNNK]^"oo.k$--K Lr )rr.rr2rN) r#r$r%r&r' __slots__rr8r(r)rs@r r,r,*s(OILLr r,cRa]tRt^ELL,))+ r c<V^8dQhRR/#r>r?)r rs"r r rVYs((T(r c $a\SP4SP, ^,;p^8:dR#\RSPP 44V3RlR7pVRVFpSPP VR4K! R#)zVDrop oldest idle entries to fit a new lease under the cap; never a held/contended one.Nc3R"TFwrVP'gKVxK R#5ir_)rO).0sidls& r 7SessionTurnLeaseRegistry._evict_idle..]sH)=vsss)=s' 'c><SPV,P#r_)rYrH)rhr s&r 6SessionTurnLeaseRegistry._evict_idle..^sdll3&7&A&Ar )key)lenrYr[sorteditemspop)r overflowrOrhsf r ra$SessionTurnLeaseRegistry._evict_idleYssDLL)D,=,==A AHa G H););)=HAC ?C LL  S$ '#r timeoutNc X<V^8dQhRS[RS[RS[RS[S[,RS[S[,/#)rrrrrvr)rrrrr,)r rs"r r rVbs?'''-0'>A'LTUZO' . !'r c "V'gR#V'dV^8d \V4M\pVPV4p\W\ V4VR7pVP P 4'dh\P!RWV.\VP4OVP'd'\P!4VP, MRN5!V;P^, un \P!VP P!4VR7GRjxL T;P^,un Yvn \P!4;Tn TnT#LG \"d=\P$!RYQY#.\TP4O5!\'YY5R7Rhi;i T;P^,un i;i5i)zAcquire the lease for ``session_id``, waiting if held. Raises :class:`TurnLeaseTimeoutError` when the wait budget expires; None for a falsy id.N)r.uturn lease contention on session %s: routing key %s (gen %s) waiting behind in-flight turn held by routing key %s (gen %s, held %.0fs) — two routing keys are mapped to one session_id (#64934); serializing this turn behind the previous turn's flush)rvuturn lease wait timed out after %.0fs on session %s (waiter: routing key %s gen %s; holder: routing key %s gen %s) — failing closed: refusing to run this turn UNSERIALIZED against the still-held lease)rrrg)rDEFAULT_LEASE_WAITrbr,rrErNloggerwarningrrrGrFrIrCwait_foracquire TimeoutErrorerrorrrH)r rrrrvwaitr.tokens&&$$$ r r} SessionTurnLeaseRegistry.acquirebs !(Wq[uW~>P##J/zc*oUS ::     NNz  P 5A4N  P 493D3D3D e///$  P !# (""5::#5#5#7F F F  " "a ' " .2iik9EO  G e LL<)  V;Gu||:T  V (J[`d e  e  " "a ' "sCGC G63E3)E1*E3/AG1E33AF::F==GGc<<V^8dQhRS[S[,RS[RS[/#)rrnew_session_idr)rr,rrL)r rs"r r rVs'H^4cdr c Ve+VP'gV'dW!P8XdR#VPpVPVJdR#VPP V4pVehWCJdcVP 'gQ\P!RVPW!PVP.\VP4OVN5!R#W0PV&\P!4Vn W!nR#)aEAlias a HELD lease onto ``new_session_id`` after mid-turn rotation (compression) so the flush target stays serialized: the SAME ``_SessionLease`` is registered under the new id (old mapping idle-evicts later), only the holder may rebind, the token follows. A live lease on the new id: log loudly, keep the old id (fail-open).Futurn lease rebind blocked: session %s rotated to %s mid-turn (holder: routing key %s gen %s) but the target session's lease is already live (holder: routing key %s gen %s) — keeping the lease on the old id; transcript writes on %s may interleave (#64934 rotation-alias edge)T)r2rr.rrYr`rOrzr{rrrrFrH)r rrr.existings&&& r rebindSessionTurnLeaseRegistry.rebinds MU^^^>!%5%55  <rsp  !   8 $KYLYLL$ ] ]iir