+ jHjKRt^RIt^RIt^RIHt^RIHt]P!]4t Rt Rt Rt RR/R lt R tR tR#) aIA local receipt's compression catch-up (#140060), committed off the owner loop. ``adopt_untracked_compression`` takes the writer lock, up to ``_WRITE_PATIENCE_S`` when contended. On the owner loop that stalls every profile it serves (streams, controls, admissions), including during a hot-profile activation. So the async paths that restore a receipt (boot and hot-profile recovery, a socket's first read) commit the catch-up in a worker first, and the restore that follows only reads. A restore reached synchronously on the loop hands it to a tracked worker (``schedule_adoption``). N)partial)RuntimeStoreErrorcV\P!4R# \dR#i;i)FT)asyncioget_running_loop RuntimeErrorC/home/ubuntu/.hermes/hermes-agent/gateway/session_local_adoption.py on_owner_loopr s,  "  s  ((c^RIHp^RIHpV!W4^,pVPP 4;_uu_4pV!WT4eTMRuuRRR4# +'giR#;i \ \\\3dR#i;i)z_*sid*'s stored receipt when a catch-up would commit for it on this owner, else None. Read-only.) owned_receipt)adoptable_compressionN) gateway.session_local_recoveryr hermes_state_local_lineagerdb _read_ctxKeyError TypeError ValueErrorAttributeError) authoritysidr rreceiptconns&& r _duersj<@ /2 \\ # # % %3DBN7TX& % % % i^ <s.1A,A A, A) #A,)A,,B  B cP^RIHpV!VPVPWR7R#))adopt_untracked_compression)epoch session_idexpectedN)rrrr)rrrrs&&& r _adoptr"&sF IOOPSfr trackedTcJ"\W4pVfR#\\WV4pV'd^RIHpV!W4GRjxL R#\ P !V4GRjxL R#L&L \d,p\PRYP4Rp?R#Rp?ii;i5i)zCommit *sid*'s due catch-up in a worker, so the restore that follows only reads. ``tracked=False``: an authority still being built, not yet published for retirement to join.N) tracked_writez0Local session %s compression catch-up failed: %s) rrr"gateway.session_runtime_workersr%r to_threadrloggerwarningreason)rrr#rwriter%excs&&$ r adopt_before_restorer-+s9"G FIG 4E\  E 1 1 1##E* * * 2 * \I3PZPZ[[\s]#B#A*A&A*B#A*A( A*$B#&A*(A** B 5 BB#B  B#cf"^RIHpV!V4Fp\WRR7GRjxL K R#L 5i)z_Boot and hot-profile recovery: every receipt's due catch-up, before ``recover_local_sessions``.)local_receipt_idsF)r#N)rr/r-)rr/rs& r adopt_local_compressionsr0=s*@ +"95AAA,As "1/ 1caaa^RIHp\SRR4pVf /;pSnSV9d VS,P 4'gR#\ P RS4VVV3RlpV!SV!44VS&R#)zA sync restore on the owner loop found *receipt*'s catch-up due: commit it in a tracked worker, then publish the session on the loop. One worker per session at a time.)track_mutation_local_adoptionsNzHLocal session %s: committing its compression catch-up off the owner loopc<"\P!\SSS4GRjxL \SRR4'g^RIHpV!SS4R#R#L* \ d-p\PRSTP4Rp?R#Rp?ii;i5i)NretiringF)restore_local_sessionz:Local session %s paused after its compression catch-up: %s) rr'r"getattrrr6rr(r)r*)r6r,rrrs r adopt_then_publish-schedule_adoption..adopt_then_publishOs| j##FIsGD D D9j%88P%i59 E! j NNWY\^a^h^h i i js>B  AA&A B A B !B>B B  B )r&r2r7r3doner(info)rrrr2pendingr8sfff r schedule_adoptionr=Dsq?i!3T:G/11), g~gcl//11 KKZ\_`j")-?-ABGCLr )__doc__rlogging functoolsrhermes_state_runtimer getLogger__name__r(r rr"r-r0r=rr r rDsR2   8 $ g \$\$BCr