+ iHj[4Rt^RIHt^RIt^RIt^RIt^RIHt^RIt^RI t ^RI t ^RI H t ^RI t ^RIt^RIt^RIHt] P$!]4tRsRtRt!R R ]4tRR ltR t!R R4t!RR4t^RIHt^RI H!t!!RR]]!4t"R#)zExplicit worker persistence facade; never opens the canonical SQLite store. This first operation family is deliberately NOT a complete SessionDB substitute. No existing cron/child/compute consumer is switched until its inventory is covered. ) annotationsN)ThreadPoolExecutor)Path) make_user_dirFc\#)aA successful self-registration makes this interpreter compute-only. Process-scoped (not ContextVar): import-time recovery and fresh helper threads must not regain owner-ledger access. This is cooperative runtime ownership, not OS confinement or an authorization credential. )_worker_process@/home/ubuntu/.hermes/hermes-agent/agent/runtime_session_store.pyis_worker_processr s  r c\WRR7F:wr#VP4F!wrEVfVPVR4KWRV&K# K< R#)z\Mirror the owner's in-place row stamps onto the worker's dicts (None = the owner popped it).T)strictN)zipitemspop)messagesrmessage annotationkeyvalues&& r apply_row_annotationsr%sF"8F$**,JC} C&$ - Gr c]tRt^.tRtR#)WorkerPersistenceErrorrN)__name__ __module__ __qualname____firstlineno____static_attributes__rr r rr.sr rcj\P!^4.r!Ve\V4V8dyVPP RR4pVP R4'g8VP V RVPP RVP 24VPpKRPV4#)zmodule:function:line of the frames above this store (its own frames skipped), never locals or argument values: best-effort callers swallow the guard's raise (#139029).r?zagent.runtime_session_:z <- ) sys _getframelen f_globalsget startswithappendf_codeco_namef_linenof_backjoin)limitframeframesmodules& r _caller_summaryr12sMM!$b6  F e 3$$Z5  !9:: MMVHAell&:&:%;1U^^s#  "&&(G >W X X\`{{7;;>% BIIK /()?@ @ H>OP*8<wsQRbc0?t[_ ab yyr c VPRuqnVeH\P!\4;_uu_4VPP 4RRR4R#R# +'giR#;irc)rz contextlibsuppressOSErrorrIclose)rSrzs& r rWorkerRPC._dropsL))Ti  $$W-- .- ---s A!! A2 c VP;_uu_4VP4RRR4R# +'giR#;irc)rxrrSs&r rWorkerRPC.closes YYY JJLYYYs 0 A c \P!4\PRV\P !4P \44\R4h \dMi;i^RI H pTP;_uu_4T;P^, un TPp\P!RRRTRTRT/4pTP!4pTP#YE4M> Td5TP%4TP!4pTP#YE4Mi;iTP'^4pM \(dTP%4hi;iRT9d#\TR,P+R R 44hTR9d,TP+R 4\,P.!48XdR sTR ,uuRRR4# +'giR#;i)z:synchronous_rpc_on_event_loop: %s on thread %s; caller: %ssynchronous_rpc_on_event_loop)ConnectionClosedjsonrpcz2.0rWmethodparamserrorrpersistence_failedrTr<N)zworker.registerz worker.adopt)r5r6loggerwarningrNcurrent_threadrGr1rr7websockets.exceptionsrrxrerXdumpsrrdrrormr%rrr)rSrrrrerrzresponses&&, r __call__WorkerRPC.__call__s J  $ $ & NNW!9#;#;#=#B#BODU W()HI I     ; YYY OOq OJjj)UD*hPVX`bh!ijG '')3IIj2'3JJL++-DIIj2 3 <<+    (",Xg->-B-B9Nb-cdd<<EARVXV_V_VaAa"&H%3YYYs[A A-,A- AGE C21E28D-*E,D--EGEA&G G! )ryrvrzrxreN) rrrrrqrTrrrrrrr r rsrsvs  < #&r rs)RuntimeSessionCompressionMixin)RuntimeSessionLifecycleMixinc2]tRt^tRtRtR4RR5/RlltRtRtRt R t R t R t R6R lt RR RR/RltRR RRRRRRRRRRRRRR/RltRR RR/RltRtRtR tR7R!ltR"tR#tR$tR%tR&tR'tR(tR)tR*tR4R+ltR,tR-t R.t!R/t"R0t#R1t$R2t%R3t&R#)8RuntimeSessionStoreaSynchronous durable results with a private byte-bounded retry journal. A failed write remains pending, and failure is sticky until explicit retry or adoption. Local queue acceptance is never returned as canonical commit. Pending journals live outside age-pruned cache trees. TN max_bytesc Wn\V4VnWPn\P !4VnRVn\V4R, Vn \VPPRRRR7VPPP4'g!VPP4'd \R4h\P!VPPR4^RIHpVPPR, pVP4'd \R4hVP%RR R 7Vn\P!VR 4V!VP&4'g&VP&P)4\R 4hVPP+4'dVPP-4P.V8d \R 4h\0P2!VPP5RR 74VnVP6R,VP8gpV'dVP9V4M4RpRVPR^R./VnVP;VP64VP6R,'dVP=4V'd&VP\V48wd \R4h\?4'd%VP@'d^RI!H"p V !V4R#R#R# \FdTP&P)4hi;i)Nz pending.jsoniT)modeparentsexist_ok unsafe_outbox)_try_acquire_file_lockz owner.lockza+zutf-8)encoding outbox_in_use outbox_fullz utf-8-sigscopeF next_sequencependingoutbox_scope_mismatch)bind_worker_delegation_store)$rpcr]rrrNRLockrxfailurerpathrparent is_symlinkrrchmodgateway.statusropen _outbox_ownerrexistsstatst_sizerXrY read_textjournal_reconcile_adopted_save retry_pendingr binds_delegation_ledgertools.async_delegation_workerrr_) rSrr outbox_diradoptedrr lock_path reconciledrs &&&&&$ r rTRuntimeSessionStore.__init__sc%[ "OO%  $~5 dii&&UD4P 99   & & ( (DII,@,@,B,B(9 9 !!5)9II$$|3    ! !(9 9&^^D7^C E"%d&8&899    $ $ &(9 9 yy!!99>>#++i70??#zz$))*=*={*=*ST !\\'2djj@ ++G4" '_aTVW  4<<(||I&&""$djjDK7--DEE ""t'C'C'CV,T2(D"     $ $ &  s-)L, BL,AL,9L,AL,L,,'Mc aaVPR,VPuoo\S4RR0, p\V\4'Ed\S4\S48wEg\ ;QJd VV3RlV4F 'gK RM RM!VV3RlV44'EgxVP R4SP R48wEgRVP R4SP R48wEg,VP R4SP R48wEgVP R 4SP R48wgVP R 4R 8wg\SP R44\Jg\SP R44\JgSR,SR,8grSR,SR,8wdh\ ;QJd-R VPR ,4F 'gK RM" RM!R VPR ,44'g \R4h\ VP\ SSR,R7R7pVPV4VR,VnW0nR#)a,Carry a retained outbox across verified owner replacement. ``adopted`` is the separately authenticated ``worker.adopt`` result for the requested scope; never self-adopt. Only the owner epoch (forward) and the physical target may differ from the journal (a same-epoch restart can still find the target rotated). Pending entries replay under the journal's own target with the adopted epoch, so an exact lost-ACK retry resolves its original receipt instead of creating a second one; the constructor then requires the replayed scope to equal the adopted one. repoch session_idc3J<"TFpSV,SV,8gxK R#5ircr).0rnewolds& r 9RuntimeSessionStore._reconcile_adopted..s=us3x3s8+us #TF execution_id generation owner_epochstatusrunningc38"TFqR,R8HxK R#5i) operationzcompression.publishNr)rentrys& r rr$sGfMdE+&*??MdsrrrrN) rrsetr\r]anyr%typeintrr)rSrfixed candidaterrs&& @@r r&RuntimeSessionStore._reconcile_adopteds<<($**SCG\227D))SXS-A3=u=333=u===;;~.#''.2II;;|, 0EE;;|, 0EE;;}-1AAW[[QYEZ^gEg()4SWWW=M8NVY8Yw<#g,. %\)::33GfMQ\\ZcMdGf333GfMQ\\ZcMdGfDfDf()@A AT#S\-JK  9w'  r c JVPP'd \R4h\P!VRRR R7P 4p\ V4VP8dRVn\VP4h^RI H pV!VPVRRRR7R #) outbox_closedTF) ensure_ascii allow_nan separatorsr)atomic_write_bytesz .pending-r) tmp_prefixr fsync_dirN),r ) rclosedrrXrencoder#rrutilsrr)rSrencodedrs&& r rRuntimeSessionStore._save,s{    $ $ $(9 9**W45U_`ggi w<$.. ((DL(6 6,499g+E]abr c JWPR,8wd \R4hR#)rpermission_deniedN)rrrSrs&&r _sessionRuntimeSessionStore._session7s" L1 1()<= = 2r c  VP;_uu_4VP'd\VP4hVPR,'d \R4hRVPR,RVRV/p\P !\P !VP44pVR,P\P !\P !VRR744VR;;,^, uu&VPV4Y@nTP4^,uuRRR4# \dp\T4TnhRp?ii;i +'giR#;i) rpending_receiptsequencerrpayloadF)rN) rxrrrrXrYrr'rr_strr)rSrrrrr`s&&& r _applyRuntimeSessionStore._apply;s YYY|||,T\\::||I&&,->??o!> YXacjkE 4::dll#;E"> E EEE"" E3 c \VP;_uu_4.pVPR,'dVPR,^,pVP!R/VPBVBp\ VPVPR,R,R7pVP WC4pVP V4VR,VnW@nVPV4KRTn TuuRRR4# \dp\T4Tn hRp?ii;i +'giR#;i)r:NN)rrN)zworker.persist) rxrrrr]_compression_receipt_journalrr'r_rr)rSresultsrr<rr`s& r r!RuntimeSessionStore.retry_pendingMs YYYG ll9-- LL3A6E!XXN$**NNF $T\\4<< ;RSU;V WI $ A A) TIJJy)!*7!3DJ#,LNN6*. DL!Y "3x  YYs4DC6B0C6" D6 DDDD D+ c  VP;_uu_4\VP\VPVR7R7pVP V4VR,VnW nRVnRRR4R# +'giR#;i)zIInstall only a separately verified worker.adopt result; never self-adopt.rrrN)rxr]rrrr)rSrrs&& r adoptRuntimeSessionStore.adopt`sV YYYT\\djj1NOI JJy !"7+DJ$LDL YYYs AA88 B r@c VPV4Ve \R4hVfVR8wdVPWVWF4#VPRRVRV/4p\ W'R,4VR,#)Nunsupported_operationr!ztranscript.appendrturn_lease_holderrcount)rr_append_compression_messagesrr)rSrrcompression_lock_holderr$ chunk_rowsturn_lease_ttl_secondsr<s&&&&&&& r append_messages_batch)RuntimeSessionStore.append_messages_batchis| j!  !()@A A " .2HE2Q44ZKb!; ;0:xI\^o2pqh}(=>gr ttl_seconds patience_sc ^VPV4VPRRVRV/4R,#)z turn.acquireholderr,rrrrSrr/r,r-s&&&$$r try_acquire_session_turn_lease2RuntimeSessionStore.try_acquire_session_turn_leaseus. j!{{>Hfm[+YZ[bccr wait_secondsg @poll_interval_secondsg?on_waitwait_notice_interval_secondsg.@ should_abortacquire_patience_sg? on_contendedc >^RIHp V PWVW4WVVWV R7 #))SessionCompressionMixin)r,r4r5r6r7r8r9r:)hermes_state_compressionr=acquire_session_turn_lease) rSrr/r,r4r5r6r7r8r9r:r=s &&&$$$$$$$$ r r?.RuntimeSessionStore.acquire_session_turn_leaseys5 E&AA$TZ#"7)E%% B' 'r c ^VPV4VPRRVRV/4R,#)z turn.renewr/r,rr0r1s&&&$$r refresh_session_turn_lease.RuntimeSessionStore.refresh_session_turn_leases. j!{{<(FM;)WXY`aar c 2VPRRVRV/4R#)z turn.cleanuprFr/Nr)rSrr/s&&&r release_session_turn_lease.RuntimeSessionStore.release_session_turn_leases NXz8V$LMr c LVPV4VPRV4R#)z usage.mainNr0)rSrusages&&,r queue_token_counts&RuntimeSessionStore.queue_token_countss j! L%(r c `VPV4VPR\W2R74R#)zusage.auxiliary)taskN)rrr])rSrrMrIs&&&,r record_auxiliary_usage*RuntimeSessionStore.record_auxiliary_usages" j! %tE'=>r c VP;_uu_4VP'd\VP4hVPR,'d \R4hRRR4R# +'giR#;i)rrNT)rxrrr)rSris&&r flush_token_counts&RuntimeSessionStore.flush_token_countssM YYY|||,T\\::||I&&,->?? YYYsAA, A,, A= c BVPV4PR4#)title get_sessionr%rs&&r get_session_title%RuntimeSessionStore.get_session_titles +//88r c VVPV4VPR/4R,#)zsession.tail_rolerr0rs&&r latest_conversation_role,RuntimeSessionStore.latest_conversation_roles% j!{{.3G<+$&  dPUdbfd 'E ' '7: 'DH ')- '<@ 'UX ' 'bEb^bbN)?9 =Q? 'WY]gZ H:: 3+r r))#rq __future__rr5rr8concurrent.futuresrrXloggingrpathlibrrKr!rNhermes_dir_aclr getLoggerrrrr rr7rr1rBrDrs!agent.runtime_session_compressionragent.runtime_session_lifecyclerrrr r rs #1   (   8 $% \  F$##LY&Y&xMIY+8:VY+r