+ iHjRt^RIHt^RIt^RIt^RIt^RIHt^RIH t H t H t H t H t ^RIHt^RIHt^RIHt^RIHtHt^R IHt^R IHt^R IHtHt^R IHt^R I H!t!R5t"0R6mt#R7t$R8t%RRlt&RRlt'RRlt(Rt)RRlt*RRlt+RRlt,RRlt-RRlt.RR lt/R!R"lt0R#R$lt1R%R&lt2R't3R(t4R)R*lt5R+R,lt6R-RR.R/R/R0llt7R1RR2R3/R4lt8R#)9a.Post-loop turn finalization for ``run_conversation``. Budget summary, trajectory save, persist, diagnostics, response transforms, result assembly, steer drain, memory/skill review. Synchronous, single return. ``logger`` is imported lazily from ``agent.conversation_loop`` (no cycle, same logger name).) annotationsN)suppress)AnyCallableListOptionalTuple)_summarize_user_message_for_log)"is_dispatcher_owned_worker_context)"interrupted_during_api_call_reason)exit_reason_failure stamp_failure)_DB_PERSISTED_MARKER)flatten_message_text)append_messagestamp_message_timestamp)_sanitize_surrogates)result_model_fieldsc V^8dQhRRRR/#)msgdictreturnbool)formats"9/home/ubuntu/.hermes/hermes-agent/agent/turn_finalizer.py __annotate__r(s@@T@d@c\V\4'dVPR4R8wdR#\VPR44P 4'*#)zJTrue when an assistant row has no visible text (blank final or tool-only).role assistantFcontent) isinstancergetrstrip)rs&r#_assistant_row_missing_visible_textr&(sA c4 CGGFO{$B#CGGI$67==? ??rc ,V^8dQhRRRRRRRRRR /#) r kanban_taskstrapi_call_countintmax_iterationsloggerlogging.LoggerrNoner)rs"rrr/s4% % % &)% ;>% HV%  % rc ^RIHp^RIHp^RIHpVP 4pVP VVRV RV R2RRRR VR V/R 7\ \4;_uu_4VP4R R R 4R # +'giR #;i \ \4;_uu_4TP4R R R 4i +'gii;i;i \dTPR TRR7R #i;i)uRecord a terminal ``timed_out`` outcome for a kanban worker out of budget. Routed via ``_record_task_failure`` (not ``kanban_block``) so it counts toward the consecutive-failure circuit breaker. Idempotent via the ``_end_run`` CAS (``WHERE ended_at IS NULL``), so safe from multiple exit paths. This is a bounded fallback (#87096): the CAS invariant in ``_end_run`` (``WHERE ended_at IS NULL``) guarantees idempotence — if another path already closed the run this is a no-op — so it is safe to call from multiple exit paths. ) kanban_db)kanban_db_connect)kanban_db_dispatchzIteration budget exhausted (/u;) — task could not complete within the allowed iterations timed_outT budget_used budget_max)erroroutcome release_claimend_runevent_payload_extraNz5Failed to record budget-exhausted failure for task %sexc_info) hermes_clir1r2r3connect_record_task_failurer Exceptionclosewarning)r(r*r,r-_kb_kbc_kbd_conns&&&& r_record_kanban_budget_exhaustedrI/s /89    % %2>2B!NCSTLL$"%2NLR`$a & )$$ %$$$)$$ %$$$   C[[_   s^"C#BCA:0C: B C CC&C 7 C C CCC98C9cV^8dQhRR/#rrr/r)rs"rrrWsTrcaVUau.uFeo\S\4'dK\;QJd#V3Rl\4F 'gK RM RM!V3Rl\44'dKcSNKg upVR&R#uupi)zRemove verification-continuation nudges in place; only the synthetic nudges carry these flags, so the real attempted final answer persisted to state.db survives.c3F<"TFpSPV4xK R#5iN)r$).0fms& r >_drop_verification_continuation_scaffolding..\s+_>^AEE!HH>^s!TFNNNN)r#rany _VERIFICATION_CONTINUATION_FLAGS)messagesrQs&`r+_drop_verification_continuation_scaffoldingrXWsXa1d##+_>^+_+_>^+_(_ 8HQKs%A:A:A:,A:cF^RIHpVUu.uF q!!V4NK up#uupi)z;Copy the review input without aliasing the live transcript.)_clone_message_for_send)agent.conversation_looprZ)rWrZmessages& r!_clone_background_review_messagesr]`s&@rc z^RIHpV!V3/VB# \dpTPRY4.uRp?#Rp?ii;i)zDFire a lifecycle plugin hook; a failing hook is logged, never fatal.) invoke_hookz%s hook failed: %sN)hermes_cli.lifecyclerbrBrD)r_r-kwargsrbexcs&&, r_invoke_hook_safelyrfhs>44*6** +T7 s :5::c(V^8dQhRRRRRRRR/#) rlabelr)fnzCallable[[], Any]errorsz list[str]rr/r)rs"rrrrs0QQCQ%6Q QVZQrcV!4R# \d6pTPT RT 24TPRYRR7Rp?R#Rp?ii;i)zPost-loop cleanup must never lose the response: each step is guarded independently and errors surface via ``cleanup_errors`` (#8049).z: zfinalize_turn: _%s failed: %sTr=N)rBappendr8)rhrirjr-errs&&&& r_guarded_cleanuprnrsLQ  Q r#'( 4e4 PPQs A *AA cV^8dQhRR/#)rrztuple[Any, Any, bool, Any]r)rs"rrr|sG[G[ G[rc hW P8;'gVPP^8*p Rp VfV 'dV'gV'g\V4R9dRV RVP R2pV'dTpV'dRVnWnRp MVP RV RVP R24VP'g%VPR V RVP R 2RR 7\P!4p VPWR4pV 'd0\4'd \ P"P%R4MRpV'd\'WVPV 4WW3# \d9^R I H p Rp\T4pT \P!4T , R R2pLi;i)z{Iteration-budget exhaustion. Returns ``(final_response, _turn_exit_reason, preserved_verification_fallback, interrupted)``.FNzmax_iterations_reached(r4)Tu#⚠️ Iteration budget exhausted (u) — asking model to summariseu% ⚠️ Iteration budget exhausted (u) — requesting summary...) diagnostic)"INTERRUPT_WAITING_FOR_MODEL_PREFIXz.1fz s elapsed).HERMES_KANBAN_TASK>unknownbudget_exhausted)r,iteration_budget remainingr)_response_was_previewed_reused_response_text_emit_diagnostic_status quiet_mode _safe_printtime_handle_max_iterationsInterruptedErrorr[rsr r osenvironr$rI)agentfinal_responser* interruptedfailedrW_turn_exit_reason_pending_verification_response(_pending_verification_response_previewedr-rvpreserved_verification_fallback_summary_startrs _kanban_tasks&$$$$$$$$$ r_resolve_budget_fallbackr|s ...WW%2H2H2R2RVW2W',##3KPV ! "&E E5n5EQuG[G[F\\]^ ) VPV4\V4R#)zStrip private retry scaffolding first, or a later "continue" replays assistant("(empty)") / recovery nudges into the same empty-response loop. Only the synthetic verification nudges go; the assistant candidate persists (#65919).N))_drop_trailing_empty_response_scaffoldingrX)rrWs&&r_drop_transcript_scaffoldingrs 33H=/9rcV^8dQhRR/#)rrztuple[Any, bool]r)rs"rrrs ! !N^ !rcV'g V'dVR3#\VRR4;'gRp\V\4'dVP4MRpV'd \ V4P4'g T'dTR3#VR3#)uAn empty terminal completion is not authoritative when the stream already delivered text; recover before persist so a blank tail isn't frozen (#95514). Returns ``(final_response, recovered_from_stream)``. Called by the finalizer BEFORE the fallible tail-shaping/persist steps so the recovered text is already bound when one of them raises — a persist failure must not lose text the user already saw.F _current_streamed_assistant_textT)rr#r)r%r)rrrr _streameds&&&& r_recover_final_from_streamrst fu$$A2FLL"I%/ 3%?%? !RI %d messageszMicro-compaction failed: %s) rrlenrrrr#r`agent.conversation_compressionrrinforB) rrWrr-task_id _compressor_before _compacted_splicedr_mc_errs &&&&& r_micro_compact_after_turnrsd&<e%94@  K %=uEM.>EFF@%HPTTE#6>>(mG$33'%9TVZ*[4J {$DeLL=B :.2+*d++ %5( X,WAQAQAWAWUWX#h-' A7CPXMZ(-?UGN : < 17;;.dsHa a  #$55=K#? DEEE,DW 8sAAA A _turn_originzuTurn ended: reason=%s model=%s api_calls=%d/%d budget=%d/%d tool_turns=%d last_msg_role=%s response_len=%d session=%sz origin=%srnonez>Turn ended with pending tool result (agent may appear stuck). z last_tool=%srr)rrrBdebugr$reversedr#rsummodelr,rwused max_totalrrrDr)rrWrr*rrr-_touch_last_msg_role_last_tool_name_m_tcs_turn_tool_countr _diag_msg _diag_argss&&&&&&& r_log_turn_exitrKsU-t 4F  J $ %2:Xb\%%f-tNO8$Bvvf~, 1E1E,'JtAw55&*2hll:r&B&F&Fv&NO %5.$7L D'EKK u<<>>88AG??HF!/!6!6!86!AF!J  K ?JJ Ks,B BB)B!B B) B$$B)c VP4'gV#T;'gRP4pVR 9pV'*;'dYV'*;'dJ\V4PR4'*;'d#\ V4^8*;'d VR R\ 9pV'gV'g\V4R8XdwTP T\VRR4\\VRR4RR4\\VRR4;'gR4R 7pV'dV'dTMVR ,V,pV# \dp TPR T 4Rp ? T#Rp ? ii;i)zTurn-completion explainer: on abnormal exits, surface one explanation from ``_turn_exit_reason``. Only acts when no usable reply exists (empty, "(empty)", or a short unpunctuated fragment); ``text_response(...)`` exits stay silent.r text_responseNpartial_stream_recovery_last_persistence_error_cause _session_dbdb_pathr)rrrz$turn-completion explainer failed: %s)rz(empty)r) "_turn_completion_explainer_enabledr%r) startswithr _SENTENCE_END#_format_turn_completion_explanationrrBr) rrrrr- _stripped_is_empty_terminal_is_partial_fragment _explanation_exp_errs &&&&& r_explain_abnormal_exitrsgG7799! !#))r002 &/9# " 4 433 4 4)*55oFF 4 4I"$ 4 4"#m3  !5=N9OSl9l DD!752QSW#X}d CYPTU'%"5;;<EL 1CU[I[^jIj  G ;XFF GsWD8D8D8#D8D8&D8=D8D8(D80A+D8D8$D88 E EE cV^8dQhRR/#)rrz Optional[Any]r)rs"rrrs  m rc\V4FVpVPR4R8XdR#VPR4R8XgK4VPR4'gKMVR,u# R#)zReasoning from the CURRENT turn only: stop at this turn's user message (#17055), but take the most recent non-empty reasoning since many providers emit it on the tool-call step and leave the final step with reasoning=None.r userNr! reasoning)rr$)rWrs& r_last_turn_reasoningrsT! 776?f $ 776?k )cggk.B.B{# # " rcV^8dQhRR/#rrztuple[Any, bool, Optional[Any]]r)rs"rrrs66%6rc \WWSVR7wrp \VRR4'g3\RVVPVVVV\ V4VP VR7 WV 3#)aResolve the turn's ``transform_llm_output`` outcome, then fire ``post_llm_call`` once per turn after the tool loop. Returns ``(final_response, transformed, pre_transform_response)``. The transform itself normally already ran before the assistant row was first persisted (``apply_llm_output_transform`` from ``finish_text_response`` / ``_persist_step``); this call returns that recorded outcome, and only fires the hook here when no earlier seam saw a response (e.g. text that only appeared through ``_explain_abnormal_exit``).)turn_idplatformr-rF post_llm_call)rrr user_messageassistant_responseconversation_historyrr)apply_llm_output_transformrrfrr`r) rrr-reffective_task_idroriginal_user_messagerW transformed pre_transforms &&&$$$$$ r_apply_output_hooksr sm2L w&2.N 5-u 5 5 V''%.-!%h++   55rrr-cV^8dQhRR/#rr)rs"rrrs'6'6$'6rc Vf^RIHp\VRR4p\V\4'd(\ V4^8XdV^,V8Xd VwrgpWV3#V'gVRR3#Vf\VRR4;'gRpRRr\ RTTVP;'gRVPVVR7F)p \V \4'gKV 'gK%YR rqpM W'V3Vn WV3#) u\Fire ``transform_llm_output`` once per turn and return ``(final_response, transformed, pre_transform_response)``. Called BEFORE the final assistant row is first persisted — from ``finish_text_response`` ahead of its durable flush, and from ``finalize_turn._persist_step`` ahead of the recovery-path tail close — so the text the user sees is the text stored in SQLite/JSON and replayed next turn (#44239). SQLite treats a non-blank assistant row as settled (a re-flush adopts the stored content rather than overwriting it), so transforming after that first write can never reach the durable store. Idempotent per ``turn_id``: later callers in the same turn get the recorded outcome instead of a second hook firing. Only the current turn's not-yet-written text is touched — earlier turns and the system prompt are never rewritten (prompt-cache invariant).Nr-_llm_output_transformFrrtransform_llm_output) response_textrrrrT) r[r-rr#tuplerrfrrr)r) rrrrr-recorded_r r  _hook_results &&$$$ rrrs~2u5tT(0% M99 ud**5*d399r!&+$##))rkk   lC ( (\\9GW[;M $+"GE  55rrrFcaaaaaaaaa a a!a"^RIHo!\SSVSSSV V VS!R7 woroS'gS'gS'd\SRM,\4'dSRM,P R4R8Xdo\ SRR4;'gRP4'gDRp RoRoSP4'dSPRR 4;'gRoS'gR oS'dR M \V 4pVeVP'dRoSR J;'dPS'*;'dAS'*;'d2VSP8;'g\V 4PR 4o \!SS4^R IHpV!SV SSSR 7.p^RIHo"\+RVV"3RlVS!4\+RVV VV 3RlVS!4\+RVV3RlVS!4VVVVVVV!VV3 Rlp\+RVVS!4\-\4;_uu_4SSnR R R 4\1SSSW,SS!4S'dS'g\3SSS!4oS'g\5SSWS!4o\ SRR 4;'gRpRpR pS'd S'g\7SSS!VSSV SR7wopp^RIHpV!SS\ SRR 4S!SSVSSV R7 \S\4'd \=S4oRSR\?S4R SR!TR"S R#T R$SR%RR&SR'TR(TR)\ SR*R4R+\AS4;'dS\ SR,R 48HR-SPB/\ES4CR.SPFR/SPH/C\JUu/uFpV\ SR0V 24bK upCR1\ SPLR1^4^8d,\ SPLR2SPLPN4M\ SPLR1^4;'g^/C\PUu/uFpV\ SR0V 24bK upCR3\ SR4/4;'g/P R54;'g/P R34R6SPR/CpSPTeSPTPW4VR7&S'dS\V 4R88XdC^R9I,H-pS;'g R:V!4 R;2VR<&\ SR=R 4pR>T;'gR?,VR@&MEVeBS'dS;'g \V 4VR<&\]VVP^VP`4V'dVVRA&\ SRBR 4;'g SPb!4pV'dVVRC&RSn2R Sn3S'd"SPh'dSPhVRD&SPk4R Sn6^REI7H8pV!S4SPr^8;'d1SPtSPr8;'dRFSPv9pV'd^Sn:SPyV SSSRG7S'diS'ga\ SRHR4'gNV 'g V'd>\-\4;_uu_4SP{\}S4V VRI7R R R 4\ SRJR4'g+\RKS!SPRSSS SSV SPBVRL7 R Sn@RSnAV# \dRoEL i;i +'giEL;i \dpS!P;RT4R p?EL{R p?ii;iuupiuupi +'giL;i)NzCRun the post-loop finalization and return the turn ``result`` dict.r) rr*rrrWrrrr-r rrrpending_tool_resultTNzmNo reply: the turn stopped while a tool result was still pending. Send `continue` to let the model summarize.ztext_response() finish_turn)rr)start_deferred_title_upgraderc<S!S4#rNr)rrsrfinalize_turn..\s =YZ_=`rsave_trajectoryc<<SPS\S4S4#rN)_save_trajectoryr )r completedrWrsrrr`s&&x1PQ]1^`ijrcleanup_task_resourcesc&<SPS4#rN)_cleanup_task_resources)rrsrrrds%*G*GHY*Zrc< \SS 4\SSSS4wopS'dS'g\SSS SR7wop\SS SSV4S'gS'g\ SS SSS4SP S S4R#))rr-N)rrrrr_persist_session) rrrrrrrrr-rWrs r _persist_step$finalize_turn.._persist_stepls~$UH51K >;2 .. +#=e^]dms#t NAquh Mcd6 %eX~vO` a x)=>rpersist_sessionrF)rrrrrW)$_notify_context_engine_turn_complete_last_turn_usage)usager-rrr*rrturn_exit_reasonz(on_turn_complete notification failed: %srlast_reasoningrW api_callsr r,rpartialrresponse_transformedpre_transform_responseresponse_previewedryresponse_reusedrzrproviderbase_urlsession_last_prompt_tokenslast_real_prompt_tokens service_tierrequest_overrides extra_bodyr guardrailsession_persistence_failed)profile_cli_selectoruRsession storage could not be written — check the state database health (`hermes z&doctor`), then send your message againr8rzsession_persistence_failed:rufailure_reasoncleanup_errors_drain_leftover_steer pending_steerinterrupt_message)end_voice_turn_route skill_manage)rrrrWskip_background_review)messages_snapshot review_memory review_skillsron_session_end) rrrr rrr,rrr)Br[r-rr#rr$rr%rrrBr fails_turnr,r)rr/hermes_cli.observability.shared_metrics_harnessragent.turn_contextrrnr_session_messagesrrrr r)rDrrrrrr4r5_SESSION_TOKEN_KEYSrr7_SESSION_COST_KEYSr_tool_guardrail_halt_decision to_metadatahermes_constantsr>r reason retryable_drain_pending_steerryrz_interrupt_messageclear_interrupt_stream_callbackagent.voice_turn_routerD_skill_nudge_interval_iters_since_skillvalid_tool_names_sync_external_memory_for_turn_spawn_background_reviewr`rfrr)#rrr*rrrWrrrrr_should_review_memoryrrrr _exit_failurer_cleanup_errorsr& _platform_response_transformed_pre_transform_responser)rekeyresultr>_cause_leftover_steerrD_should_review_skillsr r-rs#fd$ddddddd$$$$$ @@@r finalize_turnrk s/Vn n^+'E1Y WSN% &   x|T * * RL  V $ . BBGMM2TTVV1 7799==>SUYZ``^` > (D-@AR-SM ]%=%=%= d" k kJ k kO k ke22 2 i ic:K6L6W6WXh6i ,E;?K(.kZ`a!#O@35`bqsyzj  "Z??"& O )  "* 5(NNWbdjkk5e^VT / >#4W] z4066BI!"kI\ >6IQb3HS[J F-/FHP, 8752Dd#KTZ%6~#FEV .#&&-n= ..x8H^Y-&5{ 5 "9ge-FN 4/ssNgeUlnrFs4s!"$ e $%"& ENNENN)"*=P P&>"# !E< ##a' 5 5  $ $(C(C C 5 5 e44 4 #$  ((3N() 7?? "&; i  * *"&x.@U3 + ! 5-u 5 5 f''%#.++ .2E*-2E* Mi N R   @ HA3GGHF Q PR! sZ0[2[2[2 \#\,]:] ?]2 \\ \  ]%\==] ] )_verification_stop_synthetic_pre_verify_synthetic>!rq.?`。！？) input_tokens output_tokenscache_read_tokenscache_write_tokensreasoning_tokens prompt_tokenscompletion_tokens total_tokens)estimated_cost_usd cost_status cost_source)9__doc__ __future__rloggingrr~ contextlibrtypingrrrrragent.codex_responses_adapterr agent.delegation_contextr agent.interrupt_controlr agent.turn_failure_copyr r agent.context_compressorragent.message_contentragent.message_metadatarrrragent.served_modelrrVrrOrPr&rIrXr]rfrnrrrrrrrrrrr rrkrrrrsR # 77IGFF96J;2 $] > J@% PFQG[T.&: !,"^)