+ lHj$Rt^RIHt^RIt^RIHtHt]!4tRRltRRlt RR lt R R lt R R lt RRlt RR/RRlltRRRR/RRllt]P !RR7!RR44tRRltRRltRR ltR!R"ltRXR#R$lltR%R&ltR'R(ltR)RR*R/R+R,lltR-R.lt]P !RR7!R/R044tR1R2ltR3R4ltR5R6ltR7R8ltR9R:lt RYR;R<llt!R=R>lt"R?R@lt#RARBlt$RCRDlt%RERFlt&RGRHlt'RIt(RJRKlt)RLRMlt*RNRRORRPRRQRRRRRSRRR/RTRUllt+RVRWlt,R#)ZaThe prompt turn: ``_run_prompt_submit`` and the per-phase helpers it drives. Bodies are rebound onto server.py's globals at install time (method_ctx.bind_module), so they reference server.py globals bare. Turn shape (one fresh daemon thread): admit -> crash marker -> bind scopes -> resolve message -> run_conversation -> commit history / message.complete -> goal & loop hooks -> release scopes -> post-turn follow-ups (queued prompt, goal continuation, notifications). ) annotationsN)HandlerRegistry bind_modulec$V^8dQhRRRRRR/#)responseAny successfulboolreturn)formats"GHNNL#FMM#NO3I[[!DENH>4((   0 1_ D   v &) 3  J 7 7>--j!<AABH8";;=227J  :xZ[|8]34 OQ Q NNMNN KK3T: 998 7s +&H H report_ownership_refusalTc<V^8dQhRRRRRRRRR R R R R RRRRR/ #)rsidrrrtextr image_pathslist[str] | Nonequeued_prompt_generation int | None display_kind str | Nonedisplay_metadata dict | Nonerlr r ztuple[list[str], Any] | Noner )r s"rrrts^;; ;;#&;5E;(;8B;";AE;Qm;rc VPR4pVPR4'g\W4;p e\PRVPR4;'gT\ V RR4;'gR4VR,;_uu_4R VR &VP R R4RRR4V'd\ R VR \V 4/4R#VR,;_uu_4VPR4'g%Vez\VPR^44V8wdZR VR &VP R R4VPR4'd!VPR4VJd \V4RRR4R#\VfVPR.4MT4p Vf.VR&VPR4p \V \4'dV PR4R 8Xd\WWVR7VR,p V fR VR &M:\P\ 4;_uu_4V P#4RRR4RRR4X ffVPR4;'g\$p \PRVPR4;'gTV 4\'WV RRRRRR/R7R#X V 3# +'giEL;i +'giL;i +'giL;i)uOwnership + liveness gate every turn source must cross; ``(images, agent)`` or None. Synthesized turns (auto-continue, wake-ups) call ``_run_prompt_submit`` directly — the bypass that once let a second backend run a duplicate turn.active_session_lease_closingNz6Refusing turn for session %s at _run_prompt_submit: %srIr[refused history_lockFrunning_submit_user_rowerrormessage_queued_prompt_generationattached_images inflight_turnr8)rtrvr agent_errorz4Refusing turn for session %s: no agent attached (%s)layerruntimecodeagent_init_failed retryableT error_surface)r!_ensure_active_session_slotloggerinfor r]_emitrrM_release_active_session_slotlistrAr_start_inflight_turnrarbrOclear_interruptAGENT_MISSING_FOR_TURN_emit_terminal_turn_error)rnrrorprrrtrvrl held_leaseownership_refusalimagesinflightrr[s&&&&&&&$ r_admit_prompt_turnrts34J ;;z " "=XY\=f(f(9's D KK & - -# %x 6 C C) E^ $ $!&GI  KK*D 1% $ '3C0A,B C D  ;;z " " $ 0GKK ;Q?@D\\!&GI  KK*D 1{{:&&7;;7M+NV`+`-W5 ! K0/3 ! s>J,!A)K !K6B(KK /K, J= K K K# auto_continuenotification_categoryc ,V^8dQhRRRRRRRRR R /#) rrrrorrr rrur rr )r s"rrrs1SD/9EHrc\V4p\VPR4;'gR4p\VP R^4;'g^4pVP RR4;'gTp\ V\4'dVP 4'dVR,;_uu_4WPR&RRR4\WEV3RVR V/VR 8XdR R /M/BVR,;_uu_4\VPR 44pRRR4X'd \WE4V# +'giLu;i +'giL8;i) a[Write the durable crash marker; returns the session key it was written under (compression can rotate session_key mid-turn). A surviving marker means the process died mid-turn. The key is published before the disk write so an interrupt racing startup can retire it; the post-write cancel check closes the inverse race (Stop landed first, no file).rIr_auto_continue_attempt_auto_continue_promptNr|_active_turn_marker_keyrYr diagnosticr_turn_cancel_requested) _session_homerr!rMr]rAr"record_turn_startr clear_turn_marker) rrorr marker_home marker_keymarker_attempt marker_textmarker_cancelleds &&$$ r_record_turn_markerrs  (KW[[/5526J%=qAFFQGN++5t<DDK+s## (9(9(;(; ^ $ $1;- .%+; P P(5 P!6 E6|DKM P^ $ $#GKK0H$IJ %  k 6 % $ % $s.D (D3 D0 3 E )slotsc]tRt^t$RtRtR]R&]P!] R7t R]R&Rt R]R&Rt R]R &Rt R]R &R tR#) _TurnScopeszOReset tokens for the thread/context scopes a turn binds (filled incrementally).Nrapprovaldefault_factoryrsession_tokenshomesecretterminalr )r2 __module__ __qualname____firstlineno____doc__r__annotations__ dataclassesfieldrrrrr__static_attributes__r rrrrsBYHc&,,TBNDBD#FCHcrrc$V^8dQhRRRRRR/#)rpromptrr list[str]r r )r s"rrrs!44c4944rc ^RIHpHp^RIHp\ V4wrgV!WgV!4\ VRR4R7p\ VRR4R8XdRpTR 8wd \Y4#X!Y4wrT 'd)\R \T 4 R2\PR 7\;QJdRT 4F 'gK RM RM !RT 44'dT #\Y4# \d+p \R T 2\PR 7RpR p ? LR p ? ii;i \d)p \RT 2\PR 7R p ? LqR p ? ii;i)zRun message for a turn with attached images: "native" content parts, or "text" path references the agent analyzes in-loop (never blocking submit on vision calls). Decision table: agent/image_routing.py.)build_native_content_partsdecide_image_input_mode load_configrequested_providerr)rapi_modecodex_app_serverrozA[tui_gateway] image_routing decision failed, defaulting to text: r.Nnativez.[tui_gateway] native image attachment skipped z unreadable path(s)c3H"TFqPR4R8HxK R#5i)r1 image_urlNr!).0ps& r %_route_turn_images..s;UuuV} +Us "TFz:[tui_gateway] native attach failed, falling back to text: )agent.image_routingrrhermes_cli.configr_active_image_routing_identityr rOr0r3r4_build_image_ref_messagelenany) rrrrr_tui_load_config _provider_modelmode_img_excpartsskippeds &&& r_route_turn_imagesrs8 [E:5A & /1&u.BBGI 5*b )-? ?D  x'77 3FC  @WNabZZ ! 3;U;333;U; ; ;L < $F 33#  QRZQ[\::   J8*U::  sCA C!AD$D8DD! D, DD E $EE cV^8dQhRR/#)rr ztuple[Any, bool]r )r s"rrrs  + rca\4p\4'gVR3#\4PRR4'd \ 4^RIHoHpRV3RllpW!VR73# \dTR3u#i;i)zArm voice-mode turn audio; ``(tts_queue, thinking_started)``. ``_tts_stream_begin`` goes first: cutting a still-speaking previous turn IS this turn's barge-in, so it must latch before the caller consumes the latch.Fbarge_inT)is_audio_output_activestart_thinking_soundcV^8dQhRR/#rr r r )r s"rr'_start_turn_voice..__annotate__s  t rcl<S!4'dR#^RIHpV!4'*# \dR#i;i)F)is_continuous_activeT)hermes_cli.voicerrO)rrs r_thinking_should_play0_start_turn_voice.._thinking_should_plays5%'' A/111  s $ 33) should_play) _tts_stream_begin_voice_mode_enabled_voice_cfg_dictr!_arm_full_duplex_listenertools.voice_moderrrO) tts_queuerrrs @r_start_turn_voicers}"#I  %Z..!#  Q  .;PQQQ  % s A&&A87A8c ,V^8dQhRRRRRRRRRR /#) rrrr7historyrhistory_versionrMr rur )r s"rrrs4%5%5 %5%5*.%5AD%5IS%5rc 4VR,;_uu_4\VPR^44pWC8Xd$VR,VR&V^,VR&RRR4R#\VR,4pVUu.uFp\V4'dKVNK ppVUu.uFp\V4'dKVNK ppW8Xd\;QJdRV4F 'gK RM RM !RV44'd^VR,p \ V 4\ V48dV \ V4RM \V 4p WZ,VR&V^,VR&RRR4R#\ R V R V R 2\PR 7RRR4R #uupiuupi +'giR#;i)aCWrite the agent's messages back to session history; returns a client warning or None. If history_version moved mid-turn, the only tolerated mutation is a gateway-inserted pivot marker (compare content, not indices: ``_append_model_switch_marker`` strips prior markers in place); any other desync is surfaced, never dropped.r|rmessagesrNc38"TFp\V4xK R#5iN)_is_pivot_marker)res& rr'_commit_turn_history..%s<>-< ##_sTFz@[tui_gateway] prompt.submit: history_version mismatch (expected=z current=u1) — agent output NOT written to session historyr.uhHistory changed during this turn — the response above is visible but was not saved to session history.) rMr!rrrrr0r3r4) rr7rrcurrent_versioncurrent_historyrhistory_no_markerscurrent_no_markersmsgs new_messagess &&&& r_commit_turn_historyrs  gkk*;Q?@  -!' !3GI )81)-<<><>-<<>9>9>*%D25d)c'l2J4G .PTUYPZL!0!?GI )81)rr<r)r7s&r_result_statusr7s6M22 = 7++W=1;=rc$V^8dQhRRRRRR/#)rr7rrrwr ztuple[Any, str, str | None]r )r s"rrr=s"''#'k'E`'rc\V\4'g\V4RR3#VPRR4p\ V4pV'gaVPR4'dJVPR4'gVPR4'd\ VPR4V4pVR8XdB\V\4'd,VP 4P\4'dRpVPR 4p\V\4'd'VP 4'dVP 4MRpW#V3#) zKReduce a run_conversation result to ``(raw_text, status, last_reasoning)``.r<Nfinal_responserrr=partialr>last_reasoning) rArrr!rturn_error_textr" startswith"INTERRUPT_WAITING_FOR_MODEL_PREFIX)r7rr9r8lrr s&& r _turn_outcomer=s fd # #6{J,, **%r *C F #F VZZ((fjj.B.BfjjQZF[F[fjj1=A :c3#7#7CIIK+_goal_followup_after_turn..bsosVVV_4]^rtuir_notification_config)platform user_configzgoal compression recoveryrI)count_active_delegationsgather_background_processes) owner_task_idrJT)user_initiatedbackground_processesactive_delegationsrrrrrWroshould_continuerjzgoal continuation hook)r rArr!rkgateway.warning_notificationsrr rOr5rBrRrLr!r"evaluate_after_turnr)rnrr7r8r9 goal_followuprUrecovery_promptr_goal_recovery_excrQ _active_delegr! _gather_bg _bg_procsdecision verdict_msg cont_prompt _goal_excrsf&&&& @r_goal_followup_after_turnr4Us M FD!9!a!afjjI`>ab G+J F,5(  I ^GGKK4HJ`bf,g i(//4 $' G99G>c ,V^8dQhRRRRRRRRR R /#) rrnrrrst_TurnRunr9rr r+r )r s"rrrs/#?#?c#?D#?h#?S#?T#?rc^RIHpVPR4;'gRpV'dV!VR7pVPpVepVP'd^TP \ V\4'dTMR4pVPR4;'gR;p 'd\RVRR R V /4TPR 4;p 'd]TPR4;'gTp \T4;_uu_4p T 'dT PY4'dRTR &RRR4TP fq\ T\4'dYTP#4'dA\%4'd/\&P)\*T3RR7P-4R#R#R#R#R# \dp \R T 4Rp ? ELRp ? ii;i +'giL;i \d&pRTR &\PR Y4Rp?LRp?i\dLi;i \.d\P1R4R#\d"p\P1RT4Rp?R#Rp?ii;i)zTHooks for a ``complete`` turn: /loop tick evaluation, pending title, voice fallback.) LoopManagerrIr)rJNrrrlooprozloop completion hook pending_titlez)Dropping pending title for session %s: %sT)targetargsdaemonz/voice TTS skipped: hermes_cli.voice unavailablezvoice TTS dispatch failed: %s)hermes_cli.loopsr9r!r`awaiting_response complete_tickrArrrOr5 _session_dbset_session_titlerdrrrr"_voice_tts_enabled threadingThread_speak_text_with_bargestart ImportErrorwarning)rnrr6r9r9 loop_sid_keyloop_mgr loop_state loop_decisionloop_msg _loop_exc_pending _session_key_pdbr)rs&&&& r_after_complete_turnrTs 90{{=177R "l;H!J%**F*F*F ( 6 6jc>R>RsXZ [ ,00;AArA8A/30RS;;//x/{{=188S  W%%D22<JJ/3GO,& || 3 4 4I[I]I] ?   $:#PT  U [ [ ]J^ 4# 9,i889 &% X'+GO $ KKC\ W W    N NNL M ? NN:A > > ?sF( F(*F(AF( F("F((G ;%G  G 3+H( G 3 GG  G G G H+H  HHH I-I- I- I((I-on_doneon_errorc ,V^8dQhRRRRRRRRRR /#) rrnrrrrrr(r r+r )r s"rrrs0''c'D'#'S'<@'rc\RV4\WW#4Ve V!4R#R# \dYpTeT!4\YG4TR,;_uu_4RTR&RRR4Rp?R# +'giRp?R#;iRp?ii;i)ziChain one follow-up turn (caller set ``running``); on failure run ``on_error``, log, release ``running``. message.startNr|Fr})r_run_prompt_submitrOr5)ridrnrrr(rUrVr)s&&&&&$$ r_dispatch_followup_turnr\st ' os#3W5   I  '   Jd ^ $ $!&GI % $ $ $ $ 's2#) B 'BA/!B/ B :BBB c ,V^8dQhRRRRRRRRR R /#) rrnrrrr7rr*rur r+r )r s"rrrs4+<+<+< +<*-+<>H+...s @gs Srr1async_delegation) _owns_eventr!)rkeyrarrns&rr*_run_post_turn_followups..s/)55 sSUVUZUZ[aUbfxUxzr_notification_emitted)ownedzcompletion queue drain)rArr!rr"_enqueue_prompt_drain_queued_prompt_session_turn_admissionr\tools.process_registryratools.process_registry_awaitingrb$tools.process_registry_notificationsrcrd_session_profile_runtime_scope_notif_handle_ready setdefaultsetcompletion_queueputrOr5)r[rnrr7r*steeradmittedrbrcrdownsminedeferredrhevent _drain_excrlras&ff&& @@r_run_post_turn_followupsrs ,6fd+C+CFJJ 'E%%++-- ^ $ $ GUGKK ,D E%Cg.. $W - -w{{955. -{{344 . - "&GI  . S'=B^_<; @qkk-,z,G 4 4kBRTX6Y6Y]aH WdWds6QRU6VssdW""#:CEBDT+T C" 1155e<" 7Z 4 45% $ $ . - -0X7Z6Y 4 4 4 <. ;;H- H( H(&AH- .I6I H  H% (H- - H= 8I I II I6 I11I6c>]tRtRt$RtR]R&R]R&R]R&R]R&]P!]R 7t R ]R &R t R]R &R t R]R&Rt R]R&]P!] R 7tR]R&^tR]R&R tR]R&R tR]R&RtR]R&RtR]R&RtR]R&RtR]R&RtR]R&RtR #) r7izShared state of one turn thread. ``agent`` is bound eagerly so except/finally always have one; ``error_retained`` makes the finally keep the failed inflight snapshot for resume replay; ``error_detail`` is the "tui turn finished" failure cause.rrone_turn_restoreterminal_callbackr receipt_committedrrscopesNr7rFthinking_startedrrrMrrscompression_count run_kwargserror_retainedrr error_detail prompt_textrreceipt_attemptedr )r2rrrrrrrrrr7rrrrrrrrrrrrrr rrr7r7sQ J%++KHFKHFCIs"d"%%d;GT;OS$(z(J ND L#KJ#t#rr7c V^8dQhRRRR/#)rrrr r+r )r s"rrrs1111d11t11rc Ra a aaVR,;_uu_4\VPR4;'gR4\VPR^44r!RRR4\V3RlX4RR7o\ VPR4;'g/4o RV 3R llo Sf\ WXS 4R#R V V3R llp\ V4;_uu_4pVeVP\V4SR 7M.pRRR4XUu.uF#qc!TPR44'gK!TNK% ppT'gR#\;QJdRT4F 'gK RM RM !RT44p\YR7;'g.pT'dS MTp \TU u.uFq!\ T 44'gKT NK up 4p T 'gR#TR,;_uu_4\TPR^44X8wd RRR4R#T'dT MY,TR&T^,TR&RRR4R# +'giEL;i \d$\PR RR7RRR4R#i;i +'giEL;iuupiuup i +'giR#;i)uGFold turns another surface appended to this session (Telegram reply, cron run) into the model-facing history before the turn snapshots it. The desktop already repaints them from the DB (#86588); without this the next prompt still ran on the in-memory history and the model never saw them (#42962). Foreign rows are the active rows between the highest ``_row_id`` the agent's own flushes stamped onto the in-memory messages (``sync_flushed_message_markers``; a local compaction re-stamps them too) and this turn's own user row, which ``_persist_submit_user_row`` already wrote (#111868). When a foreign row is a compaction summary the other surface rewrote the transcript under us, so the in-memory history is stale from the root and is re-hydrated from the DB the way ``session.resume`` does. Nothing stamped yet (seeded branch before its first turn) means nothing to adopt; a cold resume arrives stamped — but a record whose list was rebuilt from provider-format messages carries no stamp at all, so the row-id boundary cannot key on anything and the store-ahead fallback takes over (#81951).r|rrNc3z<"TF0p\V\4'gK\V4;ofK,SxK2 R#5ir)rAr_message_row_id)rmr[s& rr+_adopt_out_of_band_turns.. s+hW 1d(;XYHZAZWs ; ; ;)defaultr~cV^8dQhRR/#rr )r s"rr._adopt_out_of_band_turns..__annotate__sKKtKrcV<\V\4;'dSRJ;'gVS8#r)rArM)r[ceilings&r_below_ceiling0_adopt_out_of_band_turns.._below_ceilings(#s#JJD)I)IC'MJrcV^8dQhRR/#rr )r s"rrrs222rc.<S!V4;'dVS8#rr )r[rseens&r_foreign*_adopt_out_of_band_turns.._foreignsc"11sTz1r)after_idzDout-of-band history probe failed; turn runs on the in-memory historyTexc_infoidc3B"TFqPR4xK R#5i)_compressed_summaryNr)rrows& rrr%sDesGG122esFrepair_alternationr )rr!rMmaxr!_adopt_store_tail_without_row_idsrB get_messages_submit_row_target_keyrOrdebugr _load_durable_truncation_historycanonicalize_replay_history)rrversionrdbnewerr rewrittenrowskeeprtailrrr[rs& @@@@r_adopt_out_of_band_turnsrs#   I 6 < <"=s7;;O`bcCd?e ! hWh Dgkk*<=CCDGKK |)'G^T22 W   WYWeBOO$:7$CdOSkmE  " =ESXcggdm%HD &4'T4a4PQ@R;S4'T UD   w{{,a0 1W <  ! &/TGN %,q[!" ! C ! *  LL_jnL o        > (U ! se?H2I7"IJ %J J3J"JJJ2 I "I4(I73I44I77 J  J& c(V^8dQhRRRRRRRR/#) rrrrrrrMr r+r )r s"rrr2s).1.1t.1d.1S.1dh.1rca\VRR7;'g.Uu.uFpV!\V44'gKVNK ppV'gR#VUu0uFEp\V\4'gKVP R4'gK4VP R4kKG upo\ ;QJdV3RlV4F 'gK RM RM!V3RlV44'd`\ V4pVR,;_uu_4V'd1\VP R ^44V8XdW`R &V^,VR &RRR4R#\V4\V48:dR#\;QJd%R \W44F 'dK RM RM!R \W444'gR#\ V\V4R4pV'gR#VR,;_uu_4\VP R ^44V8wd RRR4R#W,VR &V^,VR &RRR4R#uupiuupi +'giR#;i +'giR#;i) uCatch a live record up with the store when its in-memory messages carry NO durable ``_row_id``. ``_adopt_out_of_band_turns`` keys off the highest ``_row_id`` in memory; a record whose list was rebuilt from provider-format messages (the unstamped shape ``_resolve_truncate_row_id`` heals for rewind — #82959) carries none. A writer in ANOTHER process (the messaging gateway appending to the same session while the desktop's serve record holds it) was then silently dropped and the next provider request truncated to the early snapshot while the UI showed the full transcript (#81951). With no row ids there is no boundary to key on, so adoption is gated on proof instead: the durable lineage (below this turn's own user row, which ``_persist_submit_user_row`` already wrote and the turn appends itself) must be STRICTLY longer and its head must equal the in-memory view entry for entry. A diverged view (prefix mismatch, e.g. a rewind that has not landed locally), a store that is not ahead (an unflushed local tail is the fresher record) and an empty in-memory history (no head to prove against) are left alone. A compaction by another surface is the one rewrite that is NOT an append: the store then holds a ``_compressed_summary`` row the in-memory view has never seen, so the view is stale from the root and is re-hydrated from the DB like the stamped path does — a positional check alone would keep it because the compacted store is shorter. TrNrcontentc3|<"TF1qPR4;'dVPR4S9xK3 R#5i)rrNr)rrknowns& rr4_adopt_store_tail_without_row_ids..Ls4 XSWa55& ' I IAEE),>?"4sA7*A7 ,A7) rrrArr!rrrMrallzip)rrr below_ceilingrrrrs&&&& @rrr2s*8TXY__]__ 2_!_Q/0 A_D 2 '. gw!*Q2E !%%PeJf QUU9 w gE s XSW Xsss XSW XXX*40 ^ $ $GKK(91=>'I%) "-4q[)*%  4yCL  36"%g"463336"%g"46 6 6  &tCLM': ;D   w{{,a0 1W <  ! %^ %,q[!" ! + 2 h% $  ! s:H$H$H),H)H)99H."II. H?  I c V^8dQhRRRR/#rr )r s"rrrcs   $ rc\V4;_uu_4pVRJ;'dVP^4uuRRR4# +'giR#;i \d\P RRR7R#i;i)aTTrue when this install already has session rows beyond the current one. Mirrors ``gateway.session.SessionStore.has_any_sessions`` (the messaging first-contact gate): ``_run_prompt_submit`` persists the session's own row before the turn runs (``_ensure_session_db_row``), so a fresh install on its first-ever message holds exactly one row. Nz2session count probe failed for first-contact checkTrF)rBsession_count_gerOrr)rrs& r_install_has_prior_sessionsrcs`  ! !RT><MZMZSMZ4MZXMZSMZR[MZrc 2^RIHpVPpV!VR,4Vn\ VR,VR7Vn\ VPR44pVe5VPVPVPuVnVn Vn \V4VP'g"\W4\W4\W4\!W4\#W4\%V4VR,;VnpVR,;_uu_4\)VR,4Vn\-VPR ^44VnRRR4\1WVP*'*4\3WVP*'*4\5V4p \7V4VPR ^P4p \9V 4p Tp \;V \<4'dR V 9d^R IH p ^R I!H"pT!\GVRR4;'g \I4\GVRR4;'gR\GVRR4;'gR\GVRR4;'gR\GVRR4R7pV !WWR7pVPJ'd5\MRTRRPOVPP4;'gR/4R#VPRp \;V \<4'dT MRVn*V'd \WWV4MT p^RI,H-pV!RV4'g\]4wVn/Vn0^RI1H2pH3pV!4'd \iVV4p\iV\kV44p\mVPoRR44Vn8V \iV\sV44W3# +'giELD;i)a3Bind scopes, sync the agent, snapshot history, build the run message; returns ``(prompt, run_message, cols, streamer)`` or None when @-expansion was refused. Scopes fill field by field so a failure midway still leaves every bound token for the finally; the profile's terminal policy is bound too (a failed install leaves a fail-closed refusal scope). The config-model sync is skipped under a /model --once override (not pinned as model_override, the sync would clobber it); a model picked mid-turn is applied first so the explicit pick wins over a config change.)set_current_session_keyrI) ui_session_id profile_homeNrr|rrcols@)preprocess_context_references)get_model_context_lengthmodelrbase_urlapi_keyprovider_config_context_length)rrrconfig_context_length)cwd allowed_rootcontext_lengthrr Context injection refused.)event_presentation_muted message.delta)SPEECH_INTERRUPTED_NOTEtake_speech_interrupted voice_turnF):tools.approval_contextrrr_set_session_contextr_profile_runtime_scope_tokensr!rrr_wire_callbacksr_apply_pending_model_switch_sync_agent_model_with_config#_sync_agent_compression_with_config _sync_agent_fallback_with_config_sync_bot_capabilitiesrrrrrMrr_stage_onboarding_turn_note _session_cwd_register_session_cwdmake_stream_rendererrAragent.context_referencesragent.model_metadatarr _resolve_modelblockedrjoinwarningsrrragent.notification_presentationrrrrtools.tts_streamingrr _prepend_note_pending_reaction_notesr r]_voice_turn_pending_hud_surface_note)rnrr6rorrrboundrrrstreamerrrrctx_lenctx run_messagerrrs&&&&& r_prepare_turn_inputrs? YYF-gm.DEFO01GWZ[F *'++n*E FE 6;jj%,,PUP^P^3 V]FOC    $C1%c3+C9$S23(W%w''BHu  '),-  ->!BC ! )RZZH N; w C'" ;;vr "D#D)H F&#3&=JA* E7B ' ; ;>+;UJ399rE9b177RUJ399r")%1I4"P R , #G ;;; y$))CLL*A*a*aEab d)&#66VBBNDJ)%@PVKH #OS 9 9,=,?) b)U  #K1HI  -DW-MNK $W[[u%E FE =.?.HI4 YYQ ! s 8N N cDV^8dQhRRRRRRRRR RR R R R RRRRRRRR/ #)rrnrrrr6r7rrrrrrtrurvrw turn_authorror r+r )r s"rrrswNN NN!)N36NEHN N%/NCNNN,/N;?Nrc aaaaaaSPo\\SRR4RR4Sn\S4'dRRRR/MRoVVVVVV3Rlp RR /R VV3R lllp \ 4'dT MRSnR \ SP4R T RV'd \W6V4MT/;Sn p \PSP4PpRV9d SR,V R&V'd RV9dW}R&V'd RV9dWR&V 'd RV9dWR&RV9d#^RIHpV!SSP4pVeVV R&\%SSV R,V 4SP'R4;'gSpV3V3RllSn\+SS4wpp^RIHpHpV!SV!RS4SR7;_uu_4SP!V3/SPBSnRRR4VP54VP74R# \\3d/pELHi;i +'giLL;i TP54TP74i;i)zWire the streaming callbacks and run the conversation into ``st.result``. ``text`` is the turn's raw submit, matched against the row staged by prompt.submit.context_compressorNrbufrheldct<\SRR4'dR#Set\V\4'd^^RIHpSR;;,V, uu&V!SR,4'dSR;;,V, uu&R#SR,V,RupSR&SR,;_uu_4\ SV4RRR4RV/pS 'dS P V4;peW2R &SPe2\V\4'dSPPV4\R SV4R# +'giL;i) _mute_notification_replyFN)is_partial_silence_markerrrrr|rorenderedr) r rArrr_append_inflight_deltafeedrr{r) deltarpayloadrrholdrrnr6rs & r_stream_invoke_agent.._streams 54e < <    5# 6 6 J K5 K(e55V % "&v,"6 E4< ^ $ $ "7E 2%5/ hmmE22?"#J  << # 5#(>(> LL  U # osG,% $s  D'' D7 already_streamedFc$V^8dQhRRRRRR/#)rrorr&r r r+r )r s"rr#_invoke_agent..__annotate__s&\\C\d\t\rcT<\SRR4'dR#\RSRVRV/4R#)rFNzmessage.interimror&)r r)ror&rrns&$r_interim_assistant_cb,_invoke_agent.._interim_assistant_cbs. 54e < <  vt5GIY&Z[rconversation_historystream_callbackpersist_user_messagetask_idrIpersist_user_display_kindpersist_user_display_metadatarprelude)onboarding_preludec&<\RSRVRV/4#)z session.titlerJtitler)t_src_krns&&&rr_invoke_agent..'sU|R!<>>r)notification_turnrrmutedrJ)rr rr& _load_interim_assistant_messagesinterim_assistant_callbackrr_build_persist_user_messagerinspect signaturerun_conversation parametersrcrdagent.onboarding_sessionr3_adopt_submit_user_rowr!_on_session_title_start_usage_tickerrr:rr7ryr)rnrr6rrrrrtrvrror$r*r run_paramsr3r2 _title_key _usage_stop _usage_threadr:rrr#sfff&&f&&&&& @@r _invoke_agentrLs7 HHE"752F#MObdhiB';7&C&CE2vr "D--*\U\\ "B!C!C $ RZZ 07HN ' DTZ "]]BMJ &&u'='=>II J ' 6 93zA2>./;zI6F23} 2$/=!J?$UBJJ7  $+Jy !7E:6L+MtT]+22sJ1;>E!4S%!@K_ u,D_VY,Zgj k k..{LbmmLBIl ; z " .l k s62)H "H:#H'#H: H$#H$' H7 2H::"Ic 0V^8dQhRRRRRRRRR R R R /#) rrnrrrr6r7rorrtrur r )r s"rrr5s<<< <<!)<14<DN<<rc TVPVPrvV'd\V\4'd\ VRR4p\ VRR4;'gVP R4p VeVP V RW4VR7\V\4'd\VP R 4\4'dZ\VR ,4FCp V P R 4R8XgKV P R 4V8XgK3WJR &V'dWZR&M RV9dVPRR4p \V \4'dV P R4p V P R4p V P R4pV fVPRR4MWR&V 'd.V'dV RV 2MT p\WVR\V 4RRR7MMV fVPRR4MWR&Rp\V\4'dU\VP R 4\4'd"\#WVP$VP&4p\)WRRR7V# \d\PRRR 7ELi;i \d!p\P!RT4Rp?LRp?ii;i)zZStamp, restore /moa, commit history, re-sync the session key; returns the history warning.rBNrJrIuser)rrrtrvz&failed to stamp synthetic display kindTrrrrrtrvmoa_one_shot_restoreoverriderrmodel_overridez --provider F)confirm_expensive_modelpin_session_overridepersist_override count_switchz%MoA one-shot model restore failed: %s)clear_pending_titlerestart_slash_worker)r7rrArr r!(set_latest_matching_message_display_kindrOrrrrreversedr]_apply_model_switchr rJrrr _sync_session_key_after_compress)rnrr6rortrvr7rrcurrent_session_idr_restore_prev_override _prev_model_prev_provider_raw_moa_restore_exc status_notes&&&&&& r_absorb_turn_resultre5sbIIrxxE 4-- UM4 0$UL$?]]7;;}C] > V;;&VT%5<7 fd # # 6::j3I4(P(P#F:$67;;v&&0W[[5Kt5S.:N+'6F 23 8 (;;5t< h % %%\\*5N",,w/K%\\*5N% ,d3,:()DR{m</?@Xc^'dE-1.-A).UD   KK($ /(0$ %K&$ fjj,d 3 3.w BL^L^_K ) e$ P ] V EPT U V<!^NN#JL\]]^s*.I.I<"I98I9< J'J""J'c(V^8dQhRRRRRRRR/#) rr6r7r9rr8rr rwr )r s"rrrts.kkkskCkKkrc|a^RIHoHpVPP R4p\ V\ 4'gR#T!T\VPRR4VPY\VP4\J;'d0VP\\VPRR4RR48HV3RlR7#) zCommitted row addresses of this turn (``agent.persisted_turn_receipt``); the pre-turn prefix is unchanged when every history row kept its committed row id.)committed_row_idpersisted_turn_receiptrN_persist_user_message_idxrrcJ<S!V4RJ;'dS!V4S!V48H#rr )beforeafterrhs&&rr)_persisted_turn_receipt..s- V $D 0 h h5Ef5MQabgQh5h hr)compression_unchangedprefix_row_matches) agent.persisted_turn_receiptrhrir7r!rArr rrr1rrM)r6r9r8rirrhs&&& @r_persisted_turn_receiptrrtsVyy}}Z(H h % % !'"(($?F  "2#7#78C?VVBDXDX\c BHH2D 9;NPT]VEVj  kkrc(V^8dQhRRRRRRRR/#) rrrr6r7rdrurrMr )r s"rrrs/N N DN hN ZN WZN rc FVPVPrTRp\V4R8XdO^RIHpT!T\ \ VRR4;'gR4\ \ VRR4;'gR4R7p\WF4wrp \V4'd\WR8HR 7pR VR \V4R V /p \WV 4;p 'dWR &V 'dWR&V'dW+R&\ VRR4p VPR4'g\V 4'dV !V4RJdRV R&V'dVPR4'dRV R&VPR4'dRV R&VPR4;p'dWR&VPR4V R&\W4;p'dWR&VPR4pVPR4p\!VPR4;'de\#V\ 4;'dMVP%4;'d5VP%4\ T;'gR4P%48g4pVR,;_uu_4V R8XdV'd<VPR4;'g/PR4'g \'W4\)VVVR7RVn\-VVPR4VP.4VnM \3V4RRR4V R8Xd7\ T;'gT4V R&RV R&V'dRV R&V'dWkR &VP4eyRVnTP5R R!R"RR#/PV R$4R \#V\ 4'dTM \ V4/V R8XdR\ T;'gT4/M/C4RVnVP8'd\;WP<4WV 3# \dRpELi;i +'giEL;i)%z``(payload, raw, status)`` for message.complete; retains/clears the inflight turn and settles the hosted-room terminal receipt.Nr)build_error_surface_from_resultrrr)rrr<)r rousager8persisted_turn reasoningrJ_interim_text_was_deliveredresponse_previewedTresponse_reusedresponse_transformed billing_blockbillingfailure_reasonrr r r|r assistantr recoverablerr> cancelledr=settled)r7rragent.error_surfacerurr rOrr&r _get_usagerrr!callablerender_messager rAr"r_fail_inflight_turnr_turn_failure_detailrr_clear_inflight_turnrrr_retire_turn_markerr)rr6rdrr7r_error_surfacerur9r8r r!receipt was_delivered_billing_blockr error_value final_texthas_partial_texts&&&& r_complete_turn_payloadrsIIrxxENf( " K<WUJ%C%I%Ir!J'%"5;;<>N #0"GCG$$%c 6JKsGZ%6&IG)"6::w:$+ !- ( E#@$GM zz&''H],C,C VYHZ^bHb(,$% vzz+,,%)!"zz())*.&'O44~4+ $*JJ/?$@ !!#,,x,& **W%K,-J 9 X X*Z"= X X     X X#-#3#3#5[=N=NB9O9U9U9W#WY  W  _)E)K)K(P(PQ\(](]&w4 N S $B 2VZZ(892>>KBO ! ) !{11c2!%  !%GI  '5O $ '#  }k7HEII&R[\ :c3//CSXQ6PP.AP; P  P  P c ,V^8dQhRRRRRRRRR R /#) rrnrrrr6r7rr*r r+r )r s"rrrs0111t11m1X\1rc ^RIp\P\4;_uu_4\P \P P\4RR7\\RRR7;_uu_4pVPR\PR4 R V R 24VPVP44RRR4RRR4\R \V4P R V 2\"P$RR 7\'WP(4VP*eBVP,'g0RVnVP+RRRRR\/V4/4RVn\7WW2P0R7RVn\;V\V4P VP<4VnR# +'giEL;i +'giEL;i \d\2P5R4Li;i \dYp\R\T4P R T 2\"P$RR 7\ARTR\/T4/4Rp?R#Rp?ii;i)zJExcept-path of the turn: crash log, history restore, terminal error frame.NT)exist_okazutf-8)encodingu" === turn-dispatcher exception · z%Y-%m-%d %H:%M:%Su · sid=z === z[gateway-turn] r-)r/flushr8r=rorrz*hosted room terminal receipt commit failed) retire_markerz+[gateway-turn] terminal error emit failed: r)! tracebackrarbrOosmakedirspathdirname _CRASH_LOGopenwritetimestrftime format_excr0r1r2r3r4'_restore_agent_history_after_turn_errorrrrrrr exceptionrrrrrr)rnrr6rrfemit_excs&&&& r_recover_turn_exceptionrs   Y ' ' BGGOOJ/$ ? *cG 4 4 GG5==!456hse6K L GGI((* + 5 ( ODG,,-Rs 3#**DQ+GXX> '0D0D0D# K  (Hfb'3q6!R S#'B  1!#AUAUV .q$q'2B2BBNNS'5 4 4 ( ' ' K   I J K 1 9$x.:Q:Q9RRTU]T^ _4 ) gsYA/00 1sQAG9A F= G'G%.A H = G  G G" % HH I.A I))I.c(V^8dQhRRRRRRRR/# rrnrrrr6r7r r+r )r s"rrrs( 2 2c 2D 2h 24 2rc>VPVPrCVP4\V\4'dVP4VP 'd8\ P\4;_uu_4^RI H pV!4RRR4VPeVPPR4VP'dC\VPVP4\!W4\#V4\%V4VP*p\ P\4;_uu_4VP,e^RIHpV!VP,4RRR4VP2e\5VP24VP6e^RIHpV!VP64\=VP>4R# +'giELJ;i \d\&P)RRR7Li;i +'giL;i)zpFinally-path, before settlement: drop snapshots, end turn audio, undo a one-turn model, reset scopes (not home).)stop_thinking_soundNz!TUI one-turn model restore failedTr)reset_current_session_key)reset_terminal_scope) rrclearrArrrarbrOrrrr{r_restore_agent_model_runtimer_restart_slash_worker_persist_live_session_runtime#_persist_live_session_system_promptrrrrrrrreset_secret_scopertools.terminal_scoper_clear_session_contextr) rnrr6rrrrrrs &&& r_release_turn_scopesrsm**bmmZ MMO*d##    + + <  !, ||   M (23F3F G !# / )' 2 / 8YYF   Y ' ' ?? & H %foo 6 (}} 6==) "=V__-6001/, + + M LL>2" D 3d CDs!A"BBg?cV^8dQhRR/#rDr )r s"rrr*s,,D,rc\V4# \d0\PRRR7\P R4u#i;i)zZThe session's own SessionDB for :func:`_reopen_routed_session_row`, or a ``None`` context.z7could not resolve the session db for routing provenanceTrN)rBrOrrra nullcontext)rs&r_routing_provenance_dbr*sD,7## , NY] ^%%d++,s 7AAc$V^8dQhRRRRRR/#)rrnrrrr r+r )r s"rrr3s&[[[d[t[rc\VPR4RR4pVe V'gR#VPVRV R2\R7R# \d\ P RTRR 7R#i;i) aARouting provenance for #106459, called under ``_sessions_lock`` while this backend still has the session registered and is about to start a turn for it: an explicit-close stamp on its row missed a live conversation, so it is cleared (the gateway's #54878 stale-route self-heal, which this backend lacked). ``_pop_session_by_id`` claims teardown under the same lock and sets ``_closing`` before ``_finalize_session`` stamps, so a close of THIS session is either not written yet or already stops the turn -- it is never cleared here. Best-effort: a failure never blocks the turn.rrJNz TUI session z) is still registered and accepting a turn) provenance patience_sz'routing-provenance reopen failed for %sTr)r r!reopen_if_explicitly_closed_ROUTING_REOPEN_PATIENCE_SrOrr)rrnrrJs&&& r_reopen_routed_session_rowr3swW-|TBJ z[ && \#6_#`1 ' 3 [ > UY Z[sA #A10A1rtrvrprrrrcDV^8dQhRRRRRRRRR R R R R RRRRR RRRR/ #)rrnrrrrorrtrurvrwrprqrrrsrz'Callable[[dict[str, Any]], None] | Nonerrlr r r )r s"rrrEsRRR R(+R>HR!R7GR)R? R  R @D R PT Rrc aaaaaaaa aaaaaa\S4RJd0\PRSPR4;'gS4\ SSSWgSSV R7p V fR#T woo^RIHp ^RIHp \S4;_uu_4V !4oV !SRS4oRRR4S'dRo\P4o\PR SSPR4;'gR \SR R 4;'gR S;'gR \S\4'd \!S4MR \!S44S'g \#RS4VVVVVVVVV 3 RloVVVVVVV3Rlp\%S4;_uu_4p\&;_uu_4\(PS4pSPR4'*;'dVRJ;'gVSJpV'd'VSJd\+VSS4\-VRS 2SR7RJpRRR4RRR4X'g"SR,;_uu_4RSR&RRR4V#V# +'giEL;i +'giLW;i +'giLb;i +'giT#;i)FuOprompt dispatch: session store unavailable for %s — this turn may not persistrI)rlN)diagnostic_turn_muted)notification_config_snapshotrhiddenz`tui prompt accepted: ui_session=%s session_key=%s agent_session_id=%s kind=%s chars=%s images=%drrJrO-rYc :< \SPR44p\PS4p\ SR,SP RR4SSRJR7p\ SSSRJS;'g/PR4R7VnRp\SSVSS4pVEfVPe8VP'g&RVn VPRR R R R R /4RVn \SSV4\PV4\V4RVPnSR,;_uu_4RSR&\"P#4SR&SP RR4VP$'g \'S4\)S4RRR4\+VP,\.4'd\1VP,4pMVP$'dR MRp\2P5RSSPR4;'gR \7VPRR 4;'gR WRP$\"P94S, VP:4VP'du\=SVP4SR,;_uu_4SPR4VP8XdSP RR4SP RR4RRR4SP RR4\?SSVP4\ASSV4R#Vwrgr\CSSW&WySSSSS4 \ESSVSSS4p \GSW*V4wrpVR8Xd&^RI$H%p V !SVP,VPS4\MRSV 4\OSSVP,W\4pVR8Xd\QSSW,4\SSSRR7\SSV4\PV4\V4RVPnSR,;_uu_4RSR&\"P#4SR&SP RR4VP$'g \'S4\)S4RRR4\+VP,\.4'd\1VP,4pMVP$'dR MRp\2P5RSSPR4;'gR \7VPRR 4;'gR WRP$\"P94S, VP:4VP'du\=SVP4SR,;_uu_4SPR4VP8XdSP RR4SP RR4RRR4SP RR4\?SSVP4\ASSV4TP,T3# +'giEL;i +'giELM;i \ASST4i;i \Tdp\WSSY.4Rp?ELRp?ii;i +'giEL;i +'giL;i \ASST4i;i \SST4\PT4\T4RTPnSR,;_uu_4RSR&\"P#4SR&SP RR4TP$'g \'S4\)S4RRR4M +'giM;i\+TP,\.4'd\1TP,4pMTP$'dR MRp\2P5RSSPR4;'gR \7TPRR 4;'gR YRP$\"P94S, TP:4TP'd\=STP4SR,;_uu_4SPR4TP8XdSP RR4SP RR4RRR4M +'giM;iSP RR4\?SSTP4\ASST4i \ASST4i;i;i)r`rone_turn_model_restoreN)rr)rrTr8r=rorrrr|Fr} last_active_turn_user_inputr<zptui turn finished: ui_session=%s session_key=%s agent_session_id=%s status=%s error_retained=%s duration=%.1fs%srIrJr_hosted_room_task_auto_continue_scheduled)note_task_donezmessage.complete)only_if_present),bind_transportr!_current_runtime_session_recordryr7r]rrrrrrrresetreset_transportrr>rrr_release_hosted_room_turn_slotrAr7rrrrr monotonicrr_emit_settled_session_inforrLrertui_gateway.free_tier_task_donerrr4rT!_publish_session_control_snapshotrOr)transport_tokenruntime_session_tokenr6r*preparedr8rrrrrdr!r9rr_turn_started_monotonicrtrvrrrnrrors rrun_body$_run_prompt_submit..run_bodyqsO)[)AB ? C CG L  G gkk*BDIK\/479,GTIZ^bIb#3#9#9r">">?V"WY  B :*3T6JH''3B1 6=*3B'Wb9s3; /F Wb+ +t 5.Wb$ 6FHK#9'2TX#Y G&#Jw 288\J $c7 35c7BIIv[M#$S'2; .c7D Q !gr 2# :/556KL06:3^,,).GI&-1YY[GM*KK 2D9,,,,W527; -bii..+BII6F(*(9(9(9WzF 9]399r7288\[];^;d;dbd--t~~/?BY/YOO %''''? 00";;'@AR]]R#KK(A4H $7>1 6=*3B'Wb9yy-''?-,,.100(Wb9O 9 #C" 8 8 9-,,.10(Wb9I !gr 2# :/556KL06:3^,,).GI&-1YY[GM*KK 2D9,,,,W527; -,,,bii..+BII6F(*(9(9(9WzF 9]399r7288\[];^;d;dbd--t~~/?BY/YOO %''''? 00";;'@AR]]R#KK(A4H $7>1000 6=*3B'Wb9'Wb9s< 3Y?%Y3AX65AX AX6,X6 X6)A0X6AX"1X6B+YAZAY.0AZ,Z-Z A0Z=AZ1Z X  X6" X3 - X66Y Y+ Y& Z'&Y++Z'. Y? 9 Z Z ZZ$'d6Ad8A]  d ]( #Ad3,d dA0d0Ab> 5 d> c 1d:dddc <^RIHp^RIHpV!SRS4;_uu_4V!SSS R7;_uu_4S!4pRRR4RRR4Xe\SS S.VO5!R#R# +'giL/;i +'giL:;i))r:)notification_policy_snapshotrr;N)rr:rr) r:rfollowuprr<notification_configr[rrrns rrun_run_prompt_submit..runs}E Q )%8K L LN_`emr@CODODzHOD L   $S#w B B ODOD L Ls!A6A# A6# A3 .A66 B rzz prompt-turn-)namerr|r})_ensure_session_db_rowrrJr!rr(rrrrvrrrr rArrrr_sessions_lock _sessionsr_start_session_work)r[rnrrortrvrprrrrrlr}rrr routing_db registered can_startrrrr<rrsffffdd$$dd$ @@@@@@rrZrZEsg&%/ ] KK & - -# /" WdKI I &I I")I5; I  I I"" I2 5 J cV^8dQhRR/#)rr r+r )r s"rrrs000rc2\\4VRR7R#)zFPublish this module's helpers onto ``server``, rebound to its globals.)skipN)_)rglobals)servers&rregisterrs 6/rrr\)-r __future__rr method_ctxrr _registryrr&r5rBrRrkrr dataclassrrrrrrr4rTr\rr7rrrrrrLrerrrrrrrrrrZrr rrrs#4    X XX T 6$9N;HL;|4<@0 T"#4B 2%5P= '0(V#?L'$('37'"+<\ T"$$#$011h.1b  LBMZ`Nb<~k"N b1@ 2F 3!,[$RKOR$(RJNR,0RBF R $ R GK Rj0r