+ jHjRt^RIt^RIHtRtRtRtRtRRltRt R t RR R R R/R llt Rt Rt RtRtRtR#)zLPhysical worker liveness and cooperative Stop across every served authority.N)all_authoritiesc#2"\VR/4P4Fswr\\VRR4RR4;'g/pVPpVPR4fKHVfKNVP 4'dKfWVR,3xKu R#5i)sessions event_streamN executionexecution_generation)getattritemstaskgetdone) authoritysidliverr s& D/home/ubuntu/.hermes/hermes-agent/gateway/session_runtime_workers.pyexecuting_sessionsrsY B7==? GD.$?dSYYWY yy ==/ 0 <AQZ^ZcZcZeZeY'=>> > @sAB&B,BBca\VR/4o\V4p\RV44pV\V3RlV44,\RV44,#)zWCount claims absent from the ordinary agent map, including pre-bootstrap managed turns._running_agentsc3"TFFp\VR/4P4F$pVPP4'*xK& KH R#5i_managed_workersN)rvaluesclosedis_set).0r workers& r )uncounted_runtime_work..sIUk ' 3Er J Q Q Sfmm**,,, S-ksAAc3<"TFAp\V4F/wr#pVPS9;'dV\VR/49xK1 KC R#5ir)rrouter)rr rr_runnings& rrrsU`!,IAST]A^A**G3mm79VhjlCm8mmA^n!,s +A A c3|"TF2p\\V44\\V44,xK4 R#5iN)lenmutation_tasks side_agents)rr s& rrrs/l`kS\#nY/03{97M3NNN`ks:<)rrsum)runner authoritiesmanagedr!s& @runcounted_runtime_workr+spf/4G!&)KUkUUG c`!,`` `l`kll mnc^RIHp\\VR/4P 44UUu.uFwr#V!V4'dKW#3NK upp#uuppi)z``(thread, holder)`` for each detached side agent (/bg, /btw, preview restart) whose thread has not unwound (``gateway/session_tui_side.py`` ``_spawn``). A stopped ``/btw`` whose fork is gone (``_SideQuestionStop.abandoned``) is no longer owner work.) _abandoned _side_agents)gateway.session_tui_sider.listrr )r r.threadholders& rr&r&sS437 >[]8^8d8d8f3g '3gf% V 3g '' 's AAc ^RIHp^p\V4FNp\V4F<wrVV'gKV^,fKV\ V!V^,V44, pK> KP V#)zHard-interrupt every counted side agent's holder across served authorities (the stop drain waits for them, so its timed-out interrupt must reach them). Returns how many.request_hard_interrupt)agent.interrupt_compatr6rr&bool)r(reasonr6countr r r3s&& rinterrupt_side_agentsr;#s\> E$V, $Y/IAv&)/4VAYGHH0- Lr,cP\\VRR4RR4pVe V!4R#R#)aRe-publish the runner's in-flight count when owner work it counts (a drain, a tracked mutation, a mailbox operation) ends: the agent-slot release that last wrote ``gateway_state.json`` ran while that work was still live, so without this write the persisted count never returns to zero.r(N_persist_active_agents)r)r _taskpersists&& rpersist_work_countr@/s- gi48:RTXYG r,c0\VRR4m\VRR4mpVUu.uFq"P4'dKVNK up#uupi)_mutation_tasks_bot_mailbox_operations)rr )r tasksr s& rr%r%9sF lgi!2B7 l')Mfhj:k lE" 6UT))+DDU 66 6s AAcaa\SRR4oSf\4;oSn\P!V4pSP V4VV3RlpVP V4V#)rBNc<SPV4VP4'gVP4\S4R#r#)discard cancelled exceptionr@)r r rEs&rfinished track_mutation..finishedDs. d~~ NN 9%r,)rsetrBasyncio create_taskaddadd_done_callback)r operationr rKrEsf& @rtrack_mutationrS>s[ I0$ 7E },/E1 )   y )D IIdO&  8$ Kr,orderedFaftercaaaaa "\VRR4o S'd!S f\P!4;o VnV VVV3Rlp\ W!44pSf\P !V4GRjxL #\P !V4GRjxL pS!T4T#L-L \P dT3RlpTPT4hi;i5i)aRun a synchronous ledger write (``write()``) in a worker thread, off the owner loop. A held SQLite writer (``_WRITE_PATIENCE_S``) must not freeze every session, timer, socket, Stop and approval. The write and its loop-side follow-up (``then(result)``, sync or a coroutine: publication, scheduling, the claim's execution stamp) are one task tracked like ``track_mutation``, so retirement joins it, and shielded, so a cancelled caller cannot separate a commit from it. ``ordered`` writes (admissions) commit in call order, as they did on the loop: worker threads alone would let a later input take an earlier FIFO position. ``after(result)`` (an admission's drain scheduling) runs in the CALLER's own step once the write returns, as it did when admission was synchronous: the caller registers its delivery waiter before any drain it scheduled can claim, settle or pause that admission. A caller cancelled while the commit is in flight hands ``after`` to the commit's completion instead, so a committed row is never stranded without a drain._ordered_writesNc<"S'dCS;_uu_4GRjxL \P!S4GRjxL pRRR4GRjxL M\P!S4GRjxL pSfX#S!X4p\P!V4'd VGRjxL #T#LLkL] +GRjxL 'giLU;iL\L*5ir#)rN to_thread iscoroutine)resultfollowedorderrTthenwrites rruntracked_write..run`s uu&0077uu#,,U33F <M<!(!4!4X!>!>X~LHL7uuu4s}CB"CB(B$B( CB& C'C(-CCCC$B(&C(C .B1/ C :C < CCc<VP4'g-VP4fS!VP44R#R#R#r#)rIrJr[)r rUs&rlatetracked_write..lateps3>>##(8(@dkkm$)A#r,)rrNLockrWrSshieldCancelledErrorrQ) r r_r^rTrUr`r r[rcr]s &ffdd @r tracked_writerhMs I0$ 7E5=,3LLN: ) M M )SU +D }^^D)))~~d++ &M M*+  ! ! % t$ s<A,C3B!4C9B%B#B% C#B%%.CCca\WV4o\P!VPV44VnSe"VPP V3Rl4R#R#)Nc,<\\S44#r#)r1physical_workers)r r s&r#start_turn_worker..s>Ny>Y9Zr,)track_turn_workerrN ensure_future_run_in_executor_with_context executor_taskrQ)r(r agent_holderrun_syncr s&&&&@rstart_turn_workerrtysP!&,?I"001U1UV^1_`F ../Z[r,c^RIHpV!V4pVe=\VRR4pVf /;qTn\ \ V44W3V\ V4&V#))active_authorityN _turn_workers)gateway.session_authoritiesrwrrxr1rkid)r(rrrrwr workerss&&& rrnrnsX< (I)_d; ?02 2G- i ()%46  r,c#"\VR/4p\VP44F1wpwr4VPP 4'dWK,W43xK3 R#5i)rxN)rr1r worker_doner)r r{keyrr3s& rrkrksRi"5G!%gmmo!6 f    $ $ & & . "7sAA c&^RIHp^RIHpV!VRR7.\ V4O\ V4OF,wr4V'gKV^,fKV!V^,R4K. \ VR/4P4FpVP4K R#)rv)stop_authority_turnsr5T) in_processNzProfile runtime is stopping_cron_cancellations) gateway.run_runtimerr7r6rkr&rrrM)r rr6r r3cancels& rstop_authority_workrsz8=t4L' 2L[5KL  6fQi+ "6!9.K LM)%:B?FFH Ir,c"\P!4P4V,p\V4\ \ V44'g?\ \ V44'g%\V4'g\V4'gR#\P!4P4V8d \R4h\P!R4GRjxL KL5i)TNz0Profile workers did not stop; ownership retainedg?) rNget_running_looptimerr1rkrr%r& TimeoutErrorsleep)r timeoutdeadlines&& rjoin_authority_workrs'')..07:H I&%i011$?QR[?\:]:]&y11+i:P:P   # # % * * , 8QR RmmC   sCC&C$C&r#)__doc__rNryrrr+r&r;r@r%rSrhrtrnrkrrrDr,rrs`R7?n' 7 ))T)X\ ! !r,