+ lHjVRt^RIHt^RIt^RIt^RIHt^tRRltRRlt RR lt R R lt R R lt RRlt R2RRlltRRltRRltRRltRRltRRltRRltRRltR3R R!lltR4R"R#lltR$R%ltR&R'ltR5R(R)/R*R+llltR,R-ltR.R/ltR0R1ltR#)6zAuto-continue: resume a turn killed by a process/machine death, plus queued-prompt drain and busy-submit handling. Bodies are rebound onto server.py's globals at install time (method_ctx.bind_module), so they reference server.py globals bare.) annotationsN) bind_modulecV^8dQhRR/#)returnztuple[bool, float, int])formats"F/home/ubuntu/.hermes/hermes-agent/tui_gateway/session_auto_continue.py __annotate__r s O O6 Oc\4PR4p\V\4'dVPR4MRp\V\4'dTM/p\ VPR\ 44p\VPR4RR7\RV4R ,\VPR 4^^R 73# \ \3d\ \ 4pLmi;i) zc(enabled, freshness window in seconds, max attempts) from ``desktop.auto_continue`` in config.yaml.desktop auto_continueNfreshness_minutesenabledT)defaultggN@ max_attempts) min_value) _load_cfgget isinstancedictfloat(_AUTO_CONTINUE_FRESHNESS_MINUTES_DEFAULT TypeError ValueErroris_truthy_valuemax_coerce_int_config_value)r cfgminutess r _auto_continue_configr!skooi(G*4Wd*C*C'++o &CC&&#BCB 35]^_ CGGI. =s3?PSW?W $SWW^%.__annotate__Zs+)+)T+)r c <R\\P4R,4 2p\S S4\SVRR7pV'dR SR &R #SR ,;_uu_4SPR4'g/SPR4'gSPR4'dR SR &R R R 4R #RSR&\P4SR&R R R 4\S S4e=\ PRS 4SR ,;_uu_4R SR&R SR &R R R 4R #SR ,;_uu_4SSR,uSR&SR&R R R 4^RI H pSPR4R8Hp\S4;_uu_4V 3RlpV!VRVR7\VS SS 3RR/V'dRRR//M/BR R R 4R # \d#\ P RS RR7RRR //pELi;i +'giEL ;i +'giR #;i +'giL;i +'giR #;i \d#p\RT4\S4R p?R #R p?ii;i) __auto_continue__ig^@)timeoutz'auto-continue agent build failed for %sTexc_infoerrormessagezagent build failedFrDN history_lockrunning_turn_cancel_requested _finalized last_activez.kickoff..announce}s#/3FLj0kl/3/r tui)platformrX display_kindrdisplay_metadatazauto-continue dispatch failed)inttime_start_agent_build _wait_agent Exceptionloggerwarningr_ensure_active_session_slotinfogateway.warning_notificationsrV_session_profile_runtime_scope_run_prompt_submit_notif_log_failure_notif_release_turn) riderrrVrXr^excattemptmarkerr#r.r;r\s r kickoff._maybe_schedule_auto_continue..kickoffZs<!#diikD&8"9!:; ? sG ,gsE:C 27G. /  ^ $ ${{9%%5M)N)NRYR]R]^jRkRk6;23% $"&GI %)YY[GM " % 'sG 4 @ KKVXc d((%* "6;23)  ^ $ $SZ[abj[k OG, -w7N/O% ) I$;< LJ/880$HuT"3WdmmXb*-Dl,SThjm 98; ? NNDcTXN YY(<=>C ? % $ $)(  $ $988 ) > D  ( ( )s}F=$.G-G-*G-:G- H9H-H<1H(3H<=)G*)G*- G>  H  H% ( H9 3H<9H<< I)I$$I)zauto-continue-)nameFzlauto-continue scheduled for session %s (attempt %d, interrupted %.0fs ago, writer pid %s: %s, reader pid %s)ruinterrupted_at) rr(read_turn_markermarker_writer_stateosgetpidrirlr!rer1r9_start_session_work) r;r#r.r2 writer_staterfreshness_secsragerwrurvr\s fff @@@r _maybe_schedule_auto_continuer:s {{8 *  !D"455> ::ot , ,'v.Lw6::l#;ryy{#J KLWJJ|,biik ;,A,C)G\ ))+|, ,C c*fZ.@L.P$ ,{{-..*.G &':&*,?x@P,QMGT+)+)X7>#)?@H.3*+ KK!"-wVZZ =UWcegenenepr w 0&2F GGr c V^8dQhRRRR/#)rr#rrr+r)rs"r r r sQQ4QCQr cVPR4p\V\4'd3\VPR4;'gR4P 4#R#) inflight_turnuserr/)rrrr+strip)r#turns& r _ac_inflight_originalrsF ;; 'D2Drop (``None``) a text-only self-duplicate of the live user text, or rewrite a merged slot ``"{original}\n\n{later}"`` to ``later`` so the correction survives without re-firing the original. Image-bearing and authored envelopes are left alone: chronology and the sender's own words are kept. Returns ``None`` to drop the envelope, or a (possibly rewritten) dict to keep. A merged slot ``"{original}\n\n{later}"`` (from ``_enqueue_prompt``'s consecutive text merge) is rewritten to just ``later`` so a later correction is not lost and the original is not re-fired (#84417). Nr\rrc3<"TF:pSPSV,4'gK#S\SV,4RxK< R#5iN) startswithlen).0seprr\s& r :_sanitize_queued_entry_vs_inflight_user..s7i~YadgYgIh+c(S.)*+~s AA)r )rrrr+nextr)rrrestr\s&f @r '_sanitize_queued_entry_vs_inflight_userrs eT " " 99V D uyy//599]3K3KS]^bdgShSh i~iko p v v xDtx/4qttzz|?SeqYp\aYpcikoYpqr c V^8dQhRRRR/#)rr#rrr,r)rs"r r r sBBdBtBr ca\V4;o'gR#VPR4pV3RlV'dV.M.\VPR4;'g.4,4p\YUu.uF q3fKVNK up4R#uupi)uTRemove server-queue copies of the live turn's original user text: a mid-turn ``prompt.submit`` of the same text queued while redirect was unavailable must not drain and restart the original. A mid-turn ``prompt.submit`` of the same text can land in ``queued_prompt`` when redirect is not yet available (model not active, build window, tool boundary). If the user then corrects the turn with a different prompt via redirect, that stale self-duplicate must not ``_drain_queued_prompt`` after the redirected turn completes — otherwise the original prompt restarts as a fresh agent turn (#84417). Nrc3<<"TFp\VS4xK R#5ir)r)rers& r r;_drop_queued_duplicates_of_inflight_user..s#^\17q(CC\sr)rrr _ac_set_queue)r#headcleanedcrs& @r rrsx.g6 6H 6 ;; 'D^#'$R4 DT8U8[8[Y[3\\^G'w@w!AAw@A@s 1B ;B c$V^8dQhRRRRRR/#)rr#rentriesrrr,r)rs"r r r s!,,4,$,4,r cV'd V^,MRVR&\V4^8dVR,VR&R#VPRR4R#)zGWrite ``entries`` back as queued_prompt (head) + queued_prompts (rest).Nr:NNr)rpop)r#rs&&r rrs>-4wqz$GO 7|a$+BK ! $d+r c(V^8dQhRRRRRRRR/#) rr;r+r#ragentrrr,r)rs"r r r s.ZZZtZCZDZr caaaaSRJ;'d \SR4oS'g\S4'gR#SR,;_uu_4SPR4'd RRR4R#RSR&RRR4RVVVV3Rllp\P VRRS 2R 7P 4R# +'giLG;i) a Interrupt a busy turn on a worker thread, never under ``history_lock`` (some providers can't apply ``interrupt()`` until a blocking call returns; inline it stalled ``session.resume``). At most one interrupt worker per session so repeated steering can't leak threads.N interruptrO_busy_interrupt_pendingTcV^8dQhRR/#rFr)rs"r r -_interrupt_busy_session..__annotate__s;;t;r c <\P!\4;_uu_4S'dSP4M\ 4PS4RRR4SR,;_uu_4RSR&RRR4R# +'giL1;i +'giR#;i SR,;_uu_4RSR&RRR4i +'gii;i;i)NrOFr) contextlibsuppressrhr_get_compute_host_supervisor)rr#r; use_agentsr r*_interrupt_busy_session..interrupts ;$$Y//%.!4P4R4\4\]`4a0((5:12)(0/)((((5:12)(((sF"B'2BB'0B B B' B$ 'C9C ? C C Czbusy-interrupt-)targetdaemonry)hasattr_session_uses_compute_hostr threadingThreadstart)r;r#rrrsfff @r _interrupt_busy_sessionrsT!AAge[&AI 7@@  ;;0 1 1  ! .2)* ! ;;Id?3%9PQWWY ! s B0,B00 C c 0V^8dQhRRRRRRRRRRR R /#) rr#rrrmethodr+ plain_textstatusrr<r)rs"r r r s9 ( (T (# (s (PS (]` (ep (r c,\W#4!V4'gR#TR,;_uu_4\Y4\T4\P 4TR&RRR4\ TRT/4# \dR#i;i +'giL0;i)uApply ``agent.(plain_text)`` (steer/redirect); on acceptance record the correction, scrub stale self-duplicates so the live turn's original text is not re-fired after settle, and return the ``status`` reply. None → caller falls through to the queue path.NrOrSr)getattrrh_record_inflight_correctionrre_ok)rrr#rrrrs&&&&&&r _ac_try_correctionrsu%j112  #G809!%  ! sXv& ''  sA1.B1 B?B B c V^8dQhRRRR/#rr#rrboolr)rs"r r r s44D4T4r c^VPR4'dR#VPR4p\\VRR4;'gR4;'g%\VPR4;'gR4pV'gR#\V4;_uu_4p\VRR 4p\ V4'g R R R 4R#V!V4pR R R 4\X\4;'d \T4# +'giL3;i \ d\ PR TRR 7R#i;i) u5True when a compression lock is held for this session's durable id. Context compression is interrupt-protected (#23975), but a correction that reaches the provider mid-compression still aborts it with ``explicit_interrupt`` — the user's follow-up kills the very turn that would answer it (#61042). The channel-side busy path demotes interrupt→queue for the same reason (gateway/run_busy.py ``_session_has_compression_in_flight``, #56391); this is the local-RPC twin. Both blocking reads run off the event loop so a large state.db never freezes the dispatcher. _manual_compress_activeTr session_idr/r.Fget_compression_lock_holderNz1compression in-flight check failed for session %srK) rr+r _session_dbcallablerhridebugrr)r#rr;db get_holderholders& r _session_compression_in_flightrs{{,-- KK E ge\2.44" 5 ^ ^W[[=W=]=][]9^C   ! !R %BDIJJ''" ! _F " fc " 3 3tF|3" !  H#X\ ]s<D C25D?C2D2 D =DD#D,+D,c(V^8dQhRRRRRRRR/#)rr#renveloperb str | Nonerr,r)rs"r r r $s)7<7 c(V^8dQhRRRRRRRR/#)rr#rris_dispatchingrrr<r)rs"r r r ^s*//t/T/SW/do/r cTVPR4p\V\4'd&\VPR4\4'gR#V'd,\ WPR4VPR44M4^RIHp\ WPR4VPR4VR/R7VPR4p\V\4'd&\VPR4\4'gR#WQR&\V4;_uu_4pVf RRR4R#\W04pVPWsR,4pVeVPWx4RRR4T# \d\PR RR 7L.i;i +'giT#;i) uRe-place a queued prompt's accept-time row at the transcript END before dispatching its turn. The accept-time write lands BEFORE the in-flight turn's assistant rows (raw ``[uA, uB, aA]``), and ``repair_alternation`` would glue the two user turns into one. So on drain: write an identical row with a fresh timestamp at the end via the normal ``_persist_submit_user_row`` — it slots ``session["_submit_user_row"]``, so the turn's ``_adopt_submit_user_row`` adopts it and the flush writes no second row (the exact existing contract) — then deactivate the early row (durable history, never deleted). Steady-state raw order: ``[uA, aA, uB, aB]``. Caller holds ``history_lock`` so a concurrent submit cannot interleave its own row between the two writes. rrNr\rrTrz0queued-prompt row re-placement deactivate failedrK)rrrrd_persist_submit_user_rowrrrrrdeactivate_messagerhrir) r#rrearlyrfreshrr3rs &&& r !_replace_queued_user_row_for_turnr^s] JJ) *E ud # # 599Y3G(M(M  **V*`aB **V*`2Ld1S U KK* +E ud # # 599Y3G(M(M!&  W   :    \(7C..s)4DEG"%%c3 $ L  \ LLKVZL [ \  $ Ls*F,8E.."FFFF F' c8V^8dQhRRRRRRRRRR R R R R RR /#)rr;r+r#rr\rrrrrr<rbrrr)rs"r r r sH6*6*#6*6*C6*C6*Y]6*%06*GQ6*]h6*r c V'dRM \4pVPR4p VR9d\V4'dRpVR,;_uu_4VPR4'g RRR4R#RVR &\VPR .44p V 'd.VR &RRR4X 'g+\ V4'd\ V4P 4MR p V 'dwV esR\V R4R\V R R 4RJ;'d \V R4/p RRRR/PVR4wrV 'd"W,'d\WWW4;peV#VR,;_uu_4VPR4'g9V 'd&V \VPR .44,VR &RRR4R#\W#WJVR7pVe\VVV4\P4VR&RRR4VR8XdV 'g \WV 4\VRR/4# +'giEL;i +'giLM;i)uApply ``display.busy_input_mode`` to a mid-turn prompt instead of rejecting it (rejection made clients busy-retry and drop sends): ``interrupt`` (default) → redirect, falling back to hard interrupt + queue; ``queue`` → queue only; ``steer`` → inject after the current atomic action. ``queued=True`` (client queue drain) forces queue mode: a "run after" message must NEVER become a live correction.queuersteerrrOrPNT_turn_user_inputattached_imagesr/_supports_active_turn_redirectFredirect)rrrSrr)rr)rsteered)r  redirectedNN)_load_busy_input_moderrr_is_text_only_busy_payload_coerce_message_textrrrrrrrerr)rrr;r#r\rrrrbmoderrr supportedrrresprs&&&&&&&& r _handle_busy_submitrs  7"7"9D KK E %%*H*Q*Q  {{9%% ! '+"#7;;'8"=> )+G% & !{{?7S7S'/23Y[w{{+;<BBCD $H -g @%  #*6& ' KK*D 1 !?Ejj>W>W]F=$9:]_MO  s. \F \m \4SwvaZ`aad f fgn o o((%* "$W-) '3C'1B1H1Hb0M0Mi0X0r0r\r,s t u"O  ^ $ $gkk/:;iiGKKPhDi@iJ%  7 3 C * ) ) ! $ ! &)(( :C@G$ % $sN(N( N($N(/A5N(AN<'N<A O .$s*YHX91z&#&666Q;6HXs..FTr recoverable)rMrr9 error_surface) rrrr+rr enumeraterallrdupdate)r#rrr0r1rMsnapshotrbrc raw_offsetsircorrection_pairsr6r7surfaces& r _inflight_snapshotrCsb ;; 'D dD ! !$((6*00b17793txx ?T?Z?ZXZ;[)DHH[12C8I8O8OR4P4V4V4Xu IeY YMH$((>"::,C@@\#/ dhh/A&BB"DII'+,<'=#$((/066BK$-dhh}.E.K.K$L`$LDAPSTUPVP\P\P^SQ1s;7G3GTR$L`2B"B1A11A"B 3YHXY333YHXY Y YK[-\K[iac&kK[-\H) *  eC0B0M0Mg,N\`aeaiaijwax\yz /!::gD A Ag(/_ % O` #C-\s#K:)K:? LL retire_markerTc 0V^8dQhRRRRRRRRR R R R /#) rr;r+r#rrMrr:zOptional[dict]rDrrr,r)rs"r r r /s<,, ,,$',8F,ae,qu,r c VPR4pVf\V\4'd\P!\ 4;_uu_4^RIHpT!T\\VRR4;'gR4\\VRR4;'gR4\VRR4R7pRRR4VR ,;_uu_4\WVR 7VPR 4;'g/p\VPR 4;'gR 4\VPR4;'gR4r\VPR^P44p RRR4X ;'g \XV4p Rp \P!\ 4;_uu_4\V X 4p RRR4RT RVe \V4M/RR R XRR/V'dRV/M/CV 'dRR/M/CV 'dRV /M/Cp V'd \V4\!RW 4R# +'giELj;i +'giL;i +'giL;i)a-Close a failed turn with the same ``status: "error"`` ``message.complete`` frame as the returned-error path, retaining the turn so a client that missed the frame recovers it from ``session.resume``'s ``inflight``. ``error_surface`` ({layer, code, retryable}) is classified from an exception if absent.rN)"build_error_surface_from_exceptionproviderr/modelapi_key)rHrIrJrO)r:rrMz turn failedr0colsr\usagerr9Tr:partialrenderedzmessage.complete)rr BaseExceptionrrrhagent.error_surfacerGr+r_fail_inflight_turnrdturn_error_textrender_message _get_usager4r])r;r#rMr:rDrrGrrNrMrKr\rNpayloads&&&&$ r _emit_terminal_turn_errorrV/s KK EE=!A!A   + + N>GE:r$B$H$Hb IQTU\]bdkmoUpUvUvtvQwy$79M,  G-H{{?+11rtxx0AAMBCQ\H]HcHcacDd7;;vr*+ !  = =og}=DH   Y ' '!$- (tW5;Lj&7RTV^`gi]j/=9Ypri'.9d#BiV^ZN nd + +  !.1 %(5F)J%Ka%O!" !  !  s 4A55 B c V^8dQhRRRR/#r.r)rs"r r r Xs,,T,k,r cVPR4p\V\4'd\VPR44MRpV'dRV/#R#)zThe accepted next-turn prompt without its transport handle, for the live-session projection (Desktop may reconnect while it is still queued).rr\r/rN)rrr_inflight_text)r#rrs& r _queued_prompt_snapshotraXsD[[ )F1;FD1I1I>&**V, -rD!FD>+t+r cV^8dQhRR/#rFr)rs"r r r `s000r c2\\4VRR7R#)zQPublish this module's helpers + handlers onto ``server``, rebound to its globals.)skipN)r6)rglobals)servers&r registerrg`s 6/r r)F)FNNr)__doc__ __future__rrr} method_ctxrrr!r(r4r9rrrrrrrrrrrrr!rCrVr]rargrr r rksG# #,.( O= )KQHhQ @r&B",Z, ( 4<7,hl,,: ,0r