+ jHjKRt^RIHt^RIt^RIt^RIt^RIt^RIHt^RI H t H t H t H t ^RIHt] 'd ^RIHtHt]P&!R4t]!4tRtR R lt!R R 4tR#) aSessionStore storage plumbing: per-profile SessionDB handle resolution and the routing-index load/save paths (state.db gateway_routing primary, sessions.json legacy mirror). Mixin split out of ``gateway/session.py``; bound onto ``SessionStore`` via the MRO.) annotationsN)Path) TYPE_CHECKINGAnyDictOptional)atomic_json_write) SessionEntry SessionSourcezgateway.sessionaLEGACY MIRROR of the gateway routing index (the primary copy lives in the gateway_routing table in ~/.hermes/state.db). Maps messaging session keys (agent:main::...) to active session IDs. This is NOT the session list. ALL sessions (CLI, TUI, and gateway) live in ~/.hermes/state.db and are shown by `hermes sessions list` and `/sessions`. Disable this file with `gateway.write_sessions_json: false` in config.yaml.c V^8dQhRRRR/#)exc BaseExceptionreturnbool)formats"@/home/ubuntu/.hermes/hermes-agent/gateway/session_persistence.py __annotate__r#sMM}MMcN\V\4;'dR\V49#)zCTest-isolation guard: must stay a loud failure and is never cached.zlive-system guard) isinstance RuntimeErrorstr)r s&r_is_live_system_guardr#s! c< ( L L-@CH-LLrc]tRt^(tRtRtRRL/RRlltRMRRlltRMR R lltR t ] R 4t ] PR Rl4t ] R4t RRltRRltRRltRRltRRltRRltRRltRRltR R!ltR"R#lt]R$R%l4tR&R'ltR(R)ltR*R+lt]R,R-l4tR.R/ltR0R1ltR2R3lt R4R5lt!R6R7lt"R8R9lt#R:R;lt$R<R=lt%R>R?lt&R@RAlt'RBRClt(RDRElt)RFRRGRH/RIRJllt*RKt+R#)NSessionPersistenceMixinzWSessionStore storage plumbing: SessionDB handle resolution and routing-index load/save.c `VP;_uu_4\V4p\VPP 44F%wr4VP V9gKVPVK' VFpVP PVR4K! RRR4R# +'giR#;i)zBPublish committed retirement; durable fences reject delayed saves.N)_locksetlist_entriesitems session_id_session_owner_hintspop)self session_idstargetskeyentrysids&& rretire_runtime_sessions/SessionPersistenceMixin.retire_runtime_sessions+s{ ZZZ+&G"4==#6#6#89 ##w. c*:))--c48 ZZZsAB6B B- expiringcV^8dQhRR/#r rNoner)rs"rr$SessionPersistenceMixin.__annotate__5s D Dd Drc ZVPR4pVf \R4hV!WVR7R#)aDurably retire *session_ids* in the routing index's own database (fences + route drop in one transaction). A delete committed in another profile's store fences only that store; the shared index lives in the launch home, so its saves need the fence here too, keyed by the deleting profile's routing *namespace* (``retire_gateway_routes``). Raises when the routing store cannot take the fence: the delete must not report success.retire_gateway_routesNz,routing store unavailable for deletion fence) namespacer.)_routing_db_methodr)r&r'r5r.retires&&$$ rfence_retired_routes,SessionPersistenceMixin.fence_retired_routes5s0 (()@A >MN N{(CrNcV^8dQhRR/#r0r)rs"rrr2@sCCtCrc  VPpVPR, pVeVP4'gR#^RIHpVfRM \ V4pVP R\P4;_uu_4\VRRR7;_uu_4p\P!V4pRRR4\X\4'g RRR4R#/pVP4Fwr\V \4'dV PR4MRp V P!R 4'gH\V \"4'd2VeW9g(V!W)\P$!RV /44'dKWV &K \'V4\'V48d\)W8R R 7RRR4R# +'giEL;i +'giR#;i) aDrop from an existing sessions.json every route a routing save now skips as retired (``route_retired``, the check ``replace_gateway_routing_entries`` applies), only those naming *session_ids* when given. Runs whatever ``write_sessions_json`` says and never creates the file: the mirror is derived, and a retired route left in it would come back through the next start's legacy import once a prune's fence ages out. sessions.jsonN route_retired _save_lockr utf-8-sigencodingr#_mode) _routing_db sessions_direxists hermes_state_mutation_retirementr>r_lazy threadingLockopenjsonloadrdictr"get startswithrdumpslenr) r&r'db sessions_filer>r(fdatakeptr)r*r+s && rstrip_retired_mirror_routes3SessionPersistenceMixin.strip_retired_mirror_routes@sR   ))O; :]1133 B%-$3{3C ZZ inn 5 5mS;??1yy|@dD)) 6 5 D"jjl 1;E41H1Heii -dNN3''z#s/C/CH[`c`r,Rdjj,PSAT6UVV %I + 4y3t9$!-EB6 5???6 5 5s8;F<F( )F<AF<)AF<0.F<( F9 3 F<< G cV^8dQhRR/#)r db_pathOptional[Path]r)rs"rrr2Zs[[[rc aa^RIHp^RIHoVe \ V4M\ V!44oVV3RlpVP P SV\R7#)aSessionDB for the active profile scope. ``db_path`` pins the store; otherwise ``_default_db_path()`` follows the context-local HERMES_HOME (resolved per call so multiplexed profiles reach their own store). Handles are cached per path; failed opens enter a bounded backoff during which callers keep using the JSONL fallback. Resolving here rather than once in ``__init__`` is the whole fix for #88532: it lets the scoping that the multiplexed inbound path already performs actually reach session storage. )_default_db_path)acquirec|<S!S4# \d&p\T4'g\RT 24hRp?ii;i)zL[gateway] Warning: SQLite session store unavailable, falling back to JSONL: N) Exceptionrprint)ercpaths r_openHSessionPersistenceMixin._open_session_db_for_active_scope.._openhsB t}$ ,Q//hijhklm s ; 6;) non_cacheable) hermes_staterbhermes_state_registryrcr_db_handle_cacherSr)r&r_rbrircrhs&& @@r!_open_session_db_for_active_scope9SessionPersistenceMixin._open_session_db_for_active_scopeZsJ 21 ' 3tG}>N>P9Q $$((uDY(ZZrc $\VR\4#)zKReturn the explicitly pinned DB (``store._db = x``), else ``_DB_UNPINNED``. _db_pinned)getattr _DB_UNPINNEDr&s&r _pinned_db"SessionPersistenceMixin._pinned_dbrst\<88rc ZVP4pV\JdVP4#T#)a%The SessionDB for the active profile scope, or a pinned override. Assigning ``store._db`` pins that value for every subsequent read (tests install a fake or disable the DB with ``store._db = None``); unpinned, each read resolves the scope so a multiplexed profile's writes reach its own store.)rvrtro)r&pinneds& r_dbSessionPersistenceMixin._dbvs, ";A\;Qt557]W]]rcV^8dQhRR/#r0r)rs"rrr2s  D rc WnR#N)rr)r&values&&rrzr{src VP4pV\JdV#\VRR4pVf VP#VP VR, R7# \ dR#i;i)u The one store that owns the routing index, whatever scope is active. ``_entries`` is one flat dict holding every profile's keys, so it must persist to ONE file (``_routing_home``), not whichever profile is scoped — otherwise a mid-turn rewrite and the unscoped startup load see different copies and crash markers under a secondary profile go unrecovered. A pinned handle still wins; bare test instances lacking the handle cache report no DB. Reading it through ``_db`` made that file whichever profile happened to be scoped at the time: a whole-index rewrite during one profile's turn copied every other profile's routing rows into that profile's store, and startup — which runs unscoped — then loaded a different copy than the one the last writer produced. See #66887. _routing_homeNstate.dbr_)rvrtrsrzrore)r&ryhomes& rrH#SessionPersistenceMixin._routing_dbsi"  %Mt_d3 |xx99$BS9T T  sAA A#"A#c V^8dQhRRRR/#)r session_key Optional[str]rr)rs"rrr2sHH-HMHrc \VPRR4'gR#VPV4pV'dVR8XdR#T#)uThe non-default profile that owns *session_key*, or None (ambient store is authoritative: multiplexing off, or legacy ``agent:main``). Deliberately does NOT cover "that profile has no directory" — ownership and resolvability are separate questions for ``_db_for_key``.multiplex_profilesFNdefault)rsconfig_profile_from_session_key)r&rprofiles&& r_named_profile_for_key.SessionPersistenceMixin._named_profile_for_keys?t{{$8%@@00="g&:tGGrc V^8dQhRRRR/#)r rrrr`r)rs"rrr2s>rc ,VPV4pVfR#VPpW#9d W2,#Rp^RIHpHpV!V4'd\ V!V44pTeYCT&T# \ d#p\PRY4RpRp?L2Rp?ii;i)zZHERMES_HOME of the profile owning *session_key*, or None (no named owner or unresolvable).N)get_profile_dirprofile_existsz)Could not resolve profile home for %r: %s) r_profile_home_cachehermes_cli.profilesrrrreloggerdebug)r&rrcacherrrr s&& r_profile_home_for_key-SessionPersistenceMixin._profile_home_for_keys--k: ?((  > !#  Kg&&OG45  !'N   LLDk WD sA& A&& B1BBcV^8dQhRR/#)r rrr)rs"rrr2s&&}&rc VP4pV\JdV#VPV4pVfU\VRR4pVe\VPRR4'g VP #VP VR, R7#VPV4pVf\PRW14R#VP VR, R7# \dR#i;i \dR#i;i)u(The SessionDB holding *session_key*'s rows, whatever scope is active (the owning profile is encoded in the key). ``_db`` follows the ambient HERMES_HOME that only the inbound message path installs; unscoped background work (expiry watcher) would otherwise write profile rows into the ROOT store until the stale-route self-heal drops a live conversation. Background work runs unscoped while operating on every profile's keys out of the single process-wide ``_entries`` dict — ``_session_housekeeping_watcher`` is the clearest case — so it reads and writes the ROOT store for rows that actually live under ``profiles//state.db``. The two writers then drift apart on the same logical session until the routing index disagrees with the row and the #54878 self-heal drops a live conversation (#66887). NrrFrrzggateway.session: profile %r has no resolvable home (key %r); refusing to fall back to the ambient store) rvrtrrsrrzrorerrwarning)r&rryr routing_homers&& r _db_for_key#SessionPersistenceMixin._db_for_keys"  %M--k: ?#4$?L#74;;@TV[+\+\xx ==lU_F_=``))+6 < NN,-4 C 99$BS9T T    s$-C 4C CC C.-C.c V^8dQhRRRR/#)r r#rrr)rs"rrr2s S SM Sm Src V'gR#\VPP44F"pVPV8XgKVPu# \ VRR4;'g/PV4# \ dL3i;i)zThe routing key that owns *session_id*, or None. The published index is authoritative; ``_session_owner_hints`` covers the window where ownership is proven but routing not yet published. Deliberately lock-free: several callers already hold ``_lock``.Nr$)r r!valuesr#rrersrS)r&r#r*s&& r_owner_key_for_session_id1SessionPersistenceMixin._owner_key_for_session_ids~ dmm2245##z1 ,,,6 4d;AArFFzRR   s4A; A;A;; B B cV^8dQhRR/#)r r#rr)rs"rrr2sLL]Lrc jV'g VP#VPVPV44#)zThe SessionDB holding *session_id*'s row (owner from the index or a pre-published hint; unknown ids fall back to the ambient store).)rzrr)r&r#s&&r_db_for_session_id*SessionPersistenceMixin._db_for_session_ids,88O > >z JKKrcV^8dQhRR/#r0r)rs"rrr2s 0 0d 0rc HRRlpVPPV4R#)a Close every SessionDB handle this store opened (one per path). Closing only ``store._db`` would strand secondary profiles' handles with their WAL lock held ('database is locked' on restart). Drained under the lock, closed outside it; a pinned handle is the pinner's.cV^8dQhRR/#r0r)rs"rrBSessionPersistenceMixin.close_all_db_handles..__annotate__s S S$ Src^RIHpV!V4R# \d"p\P RT4Rp?R#Rp?ii;i))release_or_closez-SessionDB close error during handle sweep: %sN)rmrrerr)rWrr s& r_close._closes7 > S $ S LcRR Ss >9>N)rn close_all)r&rs& rclose_all_db_handles,SessionPersistenceMixin.close_all_db_handless S ''/rcV^8dQhRR/#r0r)rs"rrr2s)))rc VP;_uu_4VP4RRR4R# +'giR#;i)z4Load sessions index from disk if not already loaded.N)r_ensure_loaded_lockedrus&r_ensure_loaded&SessionPersistenceMixin._ensure_loadeds# ZZZ  & & (ZZZs 0 A c V^8dQhRRRR/#)r rrrOptional[SessionEntry]r)rs"rrr2 s...1G.rc XVP4VPPV4#)zALoad the index and return the entry for *session_key*. Lock held.)rr!rS)r&rs&&r _entry_locked%SessionPersistenceMixin._entry_locked s# ""$}}  --rcV^8dQhRR/#r rrr)rs"rrr2s***rc \\VP4P44# \d\TP4u#i;i)z~Namespace for this store's gateway_routing rows: the resolved sessions_dir, so stores with different dirs never share entries.)rrrIresolvererus&r_routing_scope&SessionPersistenceMixin._routing_scopesF *tD--.6689 9 *t(() ) *s+. AAcV^8dQhRR/#)r namerr)rs"rrr2s44s4rc n\VP;'gRVR4p\V4'dV#R#)zHBound ``_routing_db.`` if the handle exists and has it, else None.N)rsrHcallable)r&rmethods&& rr6*SessionPersistenceMixin._routing_db_methods3))11T4>!&))v3t3rcV^8dQhRR/#rr)rs"rrr2shhchrc BR\VRV4 RT;'gR RV 2#)zgateway_chat_labels:r:)rs)platformscope_idchat_ids&&&r_chat_labels_meta_key-SessionPersistenceMixin._chat_labels_meta_keys0%gh&J%K1X^^Y[L\\]^e]fggrc V^8dQhRRRR/#)r sourcer rrr)rs"rrr2 s   4 rc VPR4pVfR#V!VPVPVPVP4\ P !VPVP.44R#)aPersist *source*'s ``chat_name`` / ``chat_topic`` as the chat's current labels, at the moment they are observed; True once written. A session origin cannot answer "what is this chat called now": it is written when its session is created, which can be after a newer observation (a delayed first turn), and a reset inherits it under a fresh ``created_at``. False when there is no database handle right now (open failed, backoff, JSONL fallback): nothing was written, so the caller must not treat these labels as recorded.set_metaFT) r6rrrrrPrU chat_name chat_topic)r&rsetters&& rrecord_chat_labels*SessionPersistenceMixin.record_chat_labels sb((4 >t))&//6??FNN[zz6++V->->?@ BrcV^8dQhRR/#)r rzOptional[tuple]r)rs"rrr2/s % %/ %rc VPR4pVf \R4hV!VPWV44pV'gR#\P!V4wrgWg3#)zThe ``(chat_name, chat_topic)`` last recorded for a chat, or None when none was. Raises when the store cannot be read, including when there is no database handle right now: "unreadable now" is not "never labelled".get_metaNzsession database unavailable)r6 LookupErrorrrPloads)r&rrrgetterrawrrs&&&& r chat_labels#SessionPersistenceMixin.chat_labels/s[((4 ><= =T//GLM $ 3 $$rcV^8dQhRR/#)r rrr)rs"rrr2<s4rc :VPR4pVfR#V!VP4R7P4F*wr#VPW#4pVfKW@PV&K, R# \ d"p\ PRT4Rp?R#Rp?ii;i)zvLoad state.db routing entries into ``_entries``; False when there is no loader or the load failed (warned). Lock held.load_gateway_routing_entriesNFscopeTz1gateway.session: state.db routing load failed: %s)r6rr"_routing_entry_from_jsonr!rerr)r&loaderr) entry_jsonr*rgs& r_load_routing_rows_locked1SessionPersistenceMixin._load_routing_rows_locked<s(()GH > #)0C0C0E#F#L#L#N55cF$).MM#&$O  NNNPQ R sJ "32C$I_I_Ia' / JJL4!7>>x446 ))+!xNN#grvNwxs"D"D)(D)c V^8dQhRRRR/#)r r rrintr)rs"rrr2xs&&4&C&rc  ^RIHpVPR, p^pVP4'gV#\ VRRR7;_uu_4p\ P !V4pRRR4^pXP4FwrVPR4'gWP9dK.\V \4'g-\PRV\V 4P4Kp^R IHp VP$p V e8V !W\ P&!R V R ,/44'd V^, pKVP(!V 4VPV&V^, pK V'd(V'd \P1R Yw^8XdR MR4V# +'giEL>;i \*\,\.3d#p \PR Y4Rp ? EKbRp ? ii;i \2dp \5RT 24Rp ? T#Rp ? ii;i)zLegacy import: sessions.json fills only keys the DB lacks. Lock held. Returns how many mirror entries it skipped as retired routes.rr<r@rArBNrDz8Skipping invalid session entry %r: expected dict, got %sr=r#z%Skipping invalid session entry %r: %sz\gateway.session: imported %d legacy sessions.json entr%s missing from state.db routing tableyiesz,[gateway] Warning: Failed to load sessions: )rr rIrJrOrPrQr"rTr!rrRrrtype__name__rKr>rHrUrrrrinforerf) r&r r rXretiredrYrZimportedr)rr>rWrgs && rr4SessionPersistenceMixin._import_legacy_sessions_jsonxs 1))O; ##%%N FmS;??1yy|@H#'::<>>#&&#*>!*d33NNRTWZ(113 TN))B~-):l+CDBF+G+G1  )5)?)? )KDMM#&MH#$0(N -.61}RWY ;@??*#Hi8TNN#JCSST  F @D E E FssG& F"B G&-A F+8G&:(F+" G&.G&6G& F( " G&+G#GG&G##G&& H 1HH cV^8dQhRR/#r0r)rs"rrr2sdrc tVP'gR#.p^pVPP4Fwr4VPV4pVfKVPVP4pVeVP R4fKPVP W4V4pVR8XdVPV4K|VfKWpPV&V^, pK TFpTPTK T'g T'dTP4R#R# \d"p\PRT4Rp?R#Rp?ii;i)zRemove routing entries whose session has ended in state.db (startup, lock held). Stale == ``end_reason IS NOT NULL``; rows absent from the DB are kept; a ``None`` DB handle is a no-op; DB errors are non-fatal.N end_reasonprunez@gateway.session: stale-entry pruning skipped due to DB error: %s) r!r"r get_sessionr#rS_stale_entry_verdictappendrerrr ) r& stale_keysrecovered_keysr)r*rWrowverdictr s & rr 4SessionPersistenceMixin._prune_stale_sessions_lockeds}}}   "mm113 %%c*:nnU%5%56;#'',"7"?33CDg%%%c*()0MM#&"a'N4$C c"  JJL(   NN]_b c  sBD 6D D7D22D7cV^8dQhRR/#)r r)rr)rs"rrr2s999rc ^RIHpVPV4pVeYWRP8XdR#^RIpVP V4pWWn\ P RWPVR,V4V#RpVPe%VPWPV!4RR7pVeVPVP8wd\ P RWPVR,VP4VP'd<VPVP4VP8XdVPVn V#Ve+\ PR VPWR,4R#\ P R WPVR,4R # \d-p \ PRYPT 4Rp ? R#Rp ? ii;i) zjFor a routing entry whose row has ended: ``"prune"``, a replacement entry (repoint), or None (keep as-is).)_nowNzugateway.session: repointing stale sessions.json entry %r from ended %s (end_reason=%r) to its local receipt target %srT)rrnowraise_on_lookup_errorzRgateway.session: recovery lookup failed for stale sessions.json entry %r -> %s: %szfgateway.session: repointing stale sessions.json entry %r from ended %s (end_reason=%r) to recovered %szdgateway.session: reopened ended session %s for sessions.json entry %r (end_reason=%r); keeping routezfgateway.session: pruning stale sessions.json entry %r -> %s (end_reason=%r); left by a crashed gatewayr)gateway.session_lifecycler(_local_receipt_targetr#copyrrorigin_recover_session_from_dbrer prompt_pin_compression_tip_for_session_idr) r&r)r*r#r( local_targetr- repointedrecovered_entryr s &&&& rr,SessionPersistenceMixin._stale_entry_verdicts 311%8  #///  %(I#/ NNABEGWGWL!< 1  << # "&"?"? #LLdf\`#@#b  &?+E+EIYIY+Y NN2368H8H#lJ[** ,44U5E5EF/JdJdd.3-=-=*" "  & KK1272B2BC\IZ \ !$&6&6L8I KC  !#3#3S:  s#F!! G,!GGcV^8dQhRR/#)r rdict[str, Any]r)rs"rrr2sNN>Nrc VPP4UUu/uFwrWP4bK upp#uuppi)z1Serializable snapshot of ``_entries``. Lock held.)r!r"to_dict)r&r)r*s& rr)SessionPersistenceMixin._entries_as_dictss47;}}7J7J7LM7L]]_$7LMMMs=cV^8dQhRR/#r0r)rs"rrr2sEEtErc BVP!VP4!R#)z;Persist the routing index while the caller holds ``_lock``.N)_persist_routing_data_snapshot_routing_lockedrus&rr SessionPersistenceMixin._saves ""D$A$A$CDrcV^8dQhRR/#)r rrr)rs"rrr2s(((rc L\VR^4^,VnVP#)zBump and return the shared routing counter (lock held). Full snapshots AND single-entry fast saves MUST allocate from this one counter: the stale-write protection is a total order over serialization times and silently breaks otherwise._routing_generation)rsrBrus&r_next_routing_generation_locked7SessionPersistenceMixin._next_routing_generation_lockeds'$+41F#JQ#N '''rcV^8dQhRR/#r0r)rs"rrr2 s//T/rc F\VRR4p\VRR4'gVfR#VPR4pVfR#V!VP4R7pTP 4pTP4FjwrgTPYg4pTfKYa9dTPPYh4K?Ye9dKGYV,Y,8XgK\YPT&Kl RTn RTn R# \d"p\P RT4Rp?R#Rp?ii;i) z  4#6#6#89G((*&}}OC 99#JM$" ((<#.%2 c" /#'*.'#  NNXZ] ^  sC44 D ?DD cV^8dQhRR/#)r rztuple[dict[str, Any], int]r)rs"rrr2'sPP*DPrc bVP4VP4VP43#)z:Capture immutable routing data and a monotonic generation.)rrrCrus&rr>0SessionPersistenceMixin._snapshot_routing_locked's+ 002%%')M)M)OOOrc$V^8dQhRRRRRR/#)r rZr7 generationrrr1r)rs"rrr2,s!(,(,.(,c(,d(,rc  ~VPR\P4;_uu_4V\VR^48:d RRR4R#\VRR4pV'd=VP 4F(wpwrVWR8gK\ P !V4W&K* RpVPR4pVeT!VP 4U U u/uFwrV \ P!V 4bK up p VP4R7p RpV 'd,VP 4U U u/uFwrW9gK WbK pp p \VR R4'g V'gVPV4W nV'd;VP 4U U Uu.uFwp wrW8:gKV NK upp p FpW4K RRR4R#uup p iuup p i \d!p \PR T 4Rp ? LRp ? ii;i \d*p T'gh\PR T 4Rp ? LRp ? ii;iuupp p i +'giR#;i) zASerialize all whole-index writers through one durable write lock.r?_persisted_routing_generationN_fast_persisted_entriesFreplace_gateway_routing_entriesrTz1gateway.session: state.db routing save failed: %srzKgateway.session: sessions.json mirror save failed after state.db commit: %s)rLrMrNrsr"rPrr6rUrrerr_save_sessions_jsonrS)r&rZrQfast_persistedr)revisionrdb_savedreplacerkvrr revrDs&&& rr=-SessionPersistenceMixin._persist_routing_data,s ZZ inn 5 5WT+JANN6 5 %T+DdKN3A3G3G3I/C/(,$(JJz$: 4JH../PQH#]&TZZ\'R\TQ4::a=(8\'RZ^ZmZmZopG#H15RAQRt3T::( #,,T22< .1?1E1E1G]1G+!Xc3K\AA1G]C&+^K6 5(S S ]NN#VX[\\] !##NN!## #^K6 5 5sH+0H+<3H+0F?"F3'!F? F? F9 +F9 1F?4H+G-!"H+ H$ H$ H+3 F?? G* G% H+%G**H+- H!8HH+H!! H++ H< c V^8dQhRRRR/#)r rZr7rr1r)rs"rrr2Vswww4wrc T\VPR, R\/VCRR7R#)zLWrite the legacy sessions.json mirror of the routing index (atomic + fsync).r<_READMErErFN)rrI_SESSIONS_JSON_README)r&rZs&&rrV+SessionPersistenceMixin._save_sessions_jsonVs&$++o= K`?idh?ipuvrcV^8dQhRR/#r0r)rs"rrr2Zs55t5rc VP;_uu_4VP4wrRRR4VPXX4R# +'giL$;i)zESnapshot latest state under ``_lock`` and persist after releasing it.N)rr>r=)r&rZrQs& r _save_entries%SessionPersistenceMixin._save_entriesZs9 ZZZ#<<> D ""44Zs A A r lock_heldFc(V^8dQhRRRRRRRR/#) r rrrzOptional[dict[str, Any]]rhrrr1r)rs"rrr2`s,+!+!+!/G+!+!$(+!rc nV'd\P!4M VPpT;_uu_4VPP V4pVf RRR4R#Ve \ V4MVP 4p\P!V4VP4rRRR4VPR4p V eVPR\P4;_uu_4\VR^4X8d RRR4R#VPR\ 4p V P V4p V eV ^,V8d RRR4R#V !VXVP4R7W3W&RRR4R#VeFV;_uu_4VP'4p RRR4\ V4X V&VP)V X4R#VP+4R# +'giEL4;i +'giR#;i \ d!p \"P%RY4Rp ? LRp ? ii;i +'giL;i)uPersist ONE routing entry via UPSERT — the per-turn fast path (a full rewrite fsyncs a multi-MB sessions.json). The key -> session_id mapping never changes here: structural transitions use the full rewrite (which also refreshes the sessions.json mirror; it may lag in metadata only). The revision comes from the shared routing generation counter; under ``_save_lock`` the upsert is skipped if a full snapshot or a newer fast save of this key already persisted (the reverse case lives in ``_persist_routing_data``). No DB or a failed upsert falls back to the full rewrite. ``entry_data`` persists a candidate BEFORE it is published to the live entry (failure-atomic transitions); the fallback carries it too.Nsave_gateway_routing_entryr?rSrTrzagateway.session: single-entry routing save failed for %r (%s); falling back to full index rewrite) contextlib nullcontextrr!rSrRr9rPrUrCr6rLrMrNrsrrerrrr=rf)r&rrrhguardr* serializedrrXsaverrW persistedr fallback_datas&&$$ r _save_entry#SessionPersistenceMixin._save_entry`s-6 &&(4:: UMM%%k2E}U.8-Cj)J#'::j#94;_;_;a ''(DE   ?ZZ inn==t%DaHHT>=&*ZZ0I4%PN . 2 2; ?I ,11I >=+z9L9L9NO3;2HN/>  ! $ 6 6 8 )-j)9M+ &  & &}h ?    ?UU>= ?,-8?? ? sl!GAG(G6)G"=G6:G"G6 G")G6H$ G " G3 -G63G66 H!HH!$ H4 )rrrrSrrrBrr~),r __module__ __qualname____firstlineno____doc__r,r8r\rorvpropertyrzrrHrrrrrrrrrr6 staticmethodrrrrrrrr rrr rCrr>r=rVrfrs__static_attributes__rrrrr(s9a9 Dr DC4[09^^ ZZ  .H.&P SL 0) . *4 hh  %   ,@&P@9vNE(/:P (,Tw5 +!JN+!+!+!rr)rx __future__rrlloggingrPrMpathlibrtypingrrrrutilsrrr r getLoggerrobjectrtrbrrrrrrsgD# 55#;   , -x EM c !c !r