+ iHjnRt^RIHt^RIt^RIt^RIt^RIHt^RIH t ^RI H t H t H t Ht^RIHt^RIHtHt^RIHt^R IHt]P0!R 4tR R ltR tRRlt] !RR44tRRltRRRR/RRlltRRlt RRlt!] !RR44t"RRlt#] !R R!44t$R"R#lt%] !R$R%44t&R&R'lt'R#)(aOuter-iteration bookkeeping for the conversation turn loop, in call order: ``begin_iteration`` (pending redirect, interrupt / review-budget / iteration-budget exits), ``prepare_iteration`` (``agent:step`` callback, skill-nudge counter, pre-API ``/steer`` drain as a standalone user row after the newest tool result, run-budget wrap-up notice, tool_call argument sanitization, interrupt-placeholder ghost-row neutralisation, role-alternation repair), ``announce_api_call`` (verbose summary / quiet spinner) and, after the retry loop, ``apply_retry_restarts`` (consumes the ``TurnRetryState`` restart flags). Nothing here imports ``agent.conversation_loop`` at module level (cycle).) annotationsN)suppress) dataclass)AnyDictListTuple) KawaiiSpinner)interrupt_issuer"interrupted_during_api_call_reason) _reanchor)boosted_output_capzagent.conversation_loopc(V^8dQhRRRRRRRR/#)messagesridx user_messagereturnbool)formats">/home/ubuntu/.hermes/hermes-agent/agent/turn_iteration_prep.py __annotate__rs. D DC Dc D D Dcb\V\4'd^Tu;8:d\V48gR#R#W,p\V\4'dVP R4R8XgR#VP R4V8XdR#^RIHpV!V4pVRJ;'dVP R4V8H#)z\True when ``messages[idx]`` is this turn's user row (verbatim, or its user-originated view).FroleusercontentT)user_originated_turn_viewN) isinstanceintlendictgetagent.context_compressorr)rrrmsgrviews&&& r_anchors_current_turnr's c3  qC'?#h-'?(@ -C sD ! !cggfo&? wwy\)B $S )D t  C C 3| CCru[SYSTEM NOTICE — iteration budget checkpoint] You have used {used} of {maximum} iterations. Checkpoint durable progress now, then continue the task; do not stop solely because of this warning.c$V^8dQhRRRRRR/#)ragentrrrrr)rs"rrr0s!33#333rcB^RIp^RIHp\VRR4'dR#\VRR4p\ VP P R44;'d V!4;'dR\VRR49pVf V'dR p\VR R4pVeVeVP^8:goVP\P8gP\VR R4'g=VP\WFP,VP^, 48dR#\PVPVPR 7pV'd VR , p^RIHpV'd<VR,P R4R8wgVR,P V4'dR#VR,p V P RR4p \!V \"4'dV RV 2,V R&M4\!V \$4'gV f.T ;'g.ORRRV/NV R&MR#RVnR#)z=Append the opt-in one-shot warning to the newest tool result.N)"is_dispatcher_owned_worker_context_interrupt_requestedFbudget_warning_ratioHERMES_KANBAN_TASKkanban_completevalid_tool_namesg?iteration_budget"_iteration_budget_warning_injected)usedmaximuma While tools are still available, call kanban_complete only if all task requirements are verified, or kanban_request_review if it is ready for review; otherwise persist a kanban_comment handoff and continue. A diff or commit alone is not completion evidence.)_DB_PERSISTED_MARKERrtoolrz typetextTr)osagent.delegation_contextr+getattrrenvironr# max_totalsysmaxsizer3min!ITERATION_BUDGET_WARNING_TEMPLATErr$r5rstrlistr2) r)rr;r+ratio kanban_workerbudgetnoticer5messagers && r&_maybe_inject_iteration_budget_warningrK0s Ku,e44 E14 8E RZZ^^0 12 H H . 0 H H 0BB!G G  } U. 5F >   q   s{{ * 5> F F ;;U%5%55v7G7G!7KL L . 5 5 [[&"2"26F K >  ((0F:| 455rlGkk)R(G'3$fX6  GT " "goQ 2Q0PQ /3E, rcD]tRt^ft$RtR]R&R]R&R]R&R]R&RtR #) IterationPrepzAlways ``action == "fallthrough"``. ``messages`` is the (possibly filtered) transcript and ``request_logger`` the per-request logger the caller keeps using.rDactionrrrequest_loggercurrent_turn_user_idxrN__name__ __module__ __qualname____firstlineno____doc____annotations____static_attributes__rrrrMrMfs M KMrrMc V^8dQhRRRR/#)rseqzlist[dict[str, Any]]rz tuple[list[dict[str, Any]], int]r)rs"rrrws66(<6Aa6rcaa^RIHpHp^RIHpW20o^p.pVFoSP R4R8XdlSP R4R8XdV\ ;QJd VV3RlR 4F 'gK R M R M!VV3RlR 44'd/SCRR R V/CoV^, pVPS4K V'dWT3#TV3#)z@(new list, neutralised); never mutates ``seq`` or its row dicts.)_INTERRUPTED_PLACEHOLDER_LEGACY_INTERRUPTED_PLACEHOLDER)_INTERRUPT_SCAFFOLD_MARKER display_kindhiddenr assistantc3<"TFFp\SPV4\4;'dSV,P4S9xKH R#5i)N)rr#rDstrip).0khazardsms& r 1_neutralise_replay_echo_ghosts..s<nSmaJquuQx-II!A$**,'2IISms *A#Ar api_contentTFr7)rrj)(agent.agent_runtime_helpers_placeholdersr\r]agent.conversation_loopr^r#anyappend)rZr\r]r^ neutralisedoutrfrgs& @@r_neutralise_replay_echo_ghostsrqwsC *KGK "C  EE. !X -!%%-;2NnSmnnSmnnnM1Mi]4LMA 1 K 1 C 55C+ 55rrrPc 0V^8dQhRRRRRRRRRRRR/#) rr)rrapi_call_countrrPrrMr)rs"rrrsDrr r r25rEHrhkrrrc^RIHp\VRR4'd^RIHpV!V4VP eVP V\ V44VP^8d+RVP9dV;P^, un VP4VP4pV'd \WV4\VRR4'd V!W4\!W4\VRR4;'g\p \VR R4p V f)/p \#\4;_uu_4WnRRR4VP'WVP(V R 7p V ^8d/RVnT P-R T VP(;'gR 4\/V4wrV 'd'T P-R YP(;'gR 4^RIHp V !W4pV^8dgT P-RTVP(;'gR 4Ve<\5WV4pW8wd*T P-RYOVP(;'gR 4TpVeH\7WV4'g6\5WV4pT P-RYOVP(;'gR 4Tp\9RWVR7# \d"p\PRY'4Rp?ELrRp?ii;i +'giEL;i)a#Prepare ``messages`` for this iteration in the original order. Every mutation here is cache-safe by construction: steer text is appended as a new (not yet persisted) user row, the ghost-row filter neutralises copies of hidden interrupt placeholders, and repair runs BEFORE the request build.)_maybe_inject_run_budget_wrapup_nous_wire_pendingN)apply_pending_wire_switchz&step_callback error (iteration %s): %s skill_managerun_budget_secondslogger_sanitize_args_cursor)rz session_idcursorzFSanitized %s corrupted tool_call arguments before request (session=%s)-zGNeutralised %d interrupt-placeholder row(s) before request (session=%s))#repair_message_sequence_with_cursorzFRepaired %s message-alternation violations before request (session=%s)zPRe-anchored current_turn_user_idx %s -> %s after alternation repair (session=%s)z=Re-anchored stale current_turn_user_idx %s -> %s (session=%s) fallthrough)rNrrOrP)rlrur=agent.nous_wirerw step_callback_previous_tool_round Exceptionrzdebug_skill_nudge_intervalr0_iters_since_skill_adopt_nous_key_before_expiry_drain_pending_steer&_inject_steer_after_newest_tool_resultrKrr{_sanitize_tool_call_argumentsr|_db_flush_scan_prefixinforqagent.agent_runtime_helpersrr r'rM)r)rrsrrPrurw _step_err_pre_api_steerrO_sanitize_cursorrepaired_tool_calls_echo_neutralisedr repaired_seq_reanchored_idxs&$$$$ rprepare_iterationrs Hu*D11=!%( & ^   0DX0N O  ""Q&>U=S=S+S   A%  '') //1N.uOu*D11'8+5;UHd3==vNu&=tD i *: '!==E4D4DM]>Q'+# T     # # #A"JH U //663 P6uGLa T     # #   #'FO7##f)E ] ] ^F! s#J,K  K (KK  K c V^8dQhRRRR/#)rrrrrEr)rs"rrrs34rc j\\V44EFwrVPR4R8XgKVPR4'gK7/pV\V4V, RFJpVPR4R8wdM3VPR4pV'gK6VPRR4W5&KL VR,Uu.uFep\ V\ 4'gKR VR ,R ,R VPVPR 44R VR ,PR 4/NKg upu# .#uupi)zRThe newest assistant tool_calls batch with each call's result, for ``agent:step``.rra tool_callsNr6 tool_call_idrr7namefunctionresultid arguments) enumeratereversedr#r!rr")r_idx_m_results_by_id_tm_tcidtcs& rrrshx01 66&>[ (RVVL-A-ANH  4 56776?f,/5,/GGIr,BN) 7\*  +Bb$' BzN62n00>J!3!3K!@ +  2$ Is <D0AD0c(V^8dQhRRRRRRRR/#)rr)rr steer_textrDrNoner)rs"rrrs* . .# . .RU .Z^ .rcR\\V4^, RR4FwpW,p\V\4'gK#VP R4R8XgK;^RIHpVPV^,V!V44\PRV4R# ^RI H pV!W4R#)zAppend the steer marker as a standalone user row after the newest tool message; with no tool message, put the text back so the post-tool-execution drain delivers it later.rr6)steer_user_rowzFPre-API-call steer drain: appended user row after tool msg at index %dN)_requeue_pending_steerr:) ranger!rr"r#agent.prompt_builderrinsertrzrrr)r)rr_si_smrrs&&& rrrs~S]Q&B/m c4 SWWV_%> ; OOC!G^J%? @ LLacf g  0C5-rc0]tRtRt$RtR]R&R]R&RtR#) ApiCallAnnouncementi*zAlways ``action == "fallthrough"``; ``thinking_spinner`` is the started raw spinner or None (TUI widget / streaming consumers / verbose mode).rDrNrthinking_spinnerrNrQrrrrr*s? Krrc4V^8dQhRRRRRRRRRRRRRR /#) rr)rr api_messagesrs approx_tokens total_charsrrr)rs"rrr3sOXX X X03XEHXY\XXXrc RpVP'gVPRVP RV RVP R24VPVP R\ V4 RVR R VR R 24TPVP R VP 'd\ VP 4M^ 24M\ P!\P!44p\ P!\P!44pVP'dVPV R V R24MqVP4'g\VP4'dF\ P!.RO4p \V R V R2WPR 7pVP4VP 'd\"P$!RVP& R\ V4 RVP 'd\ VP 4M^ 24\"P$!RV'dVR,R,MR 24\"P$!RVR R24\)RVR7#)zOPrint the request summary (verbose) or start the quiet-mode thinking indicator.N u🔄 Making API call #/z...u 📊 Request size: z messages, ~,z tokens (~z chars)u 🔧 Available tools:  ) spinner_typeprint_fnzAPI Request - Model: z , Messages: z , Tools: zLast message role: rnonezTotal message size: ~z tokensr)rNr)brainsparklepulsemoonstarr:) quiet_mode_vprint log_prefixmax_iterationsr!toolsrandomchoicer get_thinking_facesget_thinking_verbsthinking_callback_has_stream_consumers_should_start_quiet_spinner _print_fnstartverbose_loggingloggingrmodelr) r)rrrsrrrfaceverbrs &$$$$$ rannounce_api_callr3s7      5++,,B>BRRSTYThThSiilmn ))**@\AR@SS_`mno_ppz|GHI{JJQR S ))**CX]XcXcXcC DTijCklm}}]==?@}}]==?@  " " "  # #tfAdV3$7 8,,..53T3T3V3V"==)VWL,vQtfC-@|fufuv   " " $  -ekk],s8}oU^sxs~s~s~_bchcncn_oEF_GH I +HHRL,@RX+YZ[ -mA->gFG mFV WWrcN]tRtRt$RtR]R&R]R&R]R&R]R&R]R &R tR #) IterationStartiTu``action``: ``"fallthrough"`` (run the iteration) or ``"break"`` (turn ends: interrupt, review input budget or iteration budget exhausted — ``_turn_exit_reason`` set).rDrNroriginal_user_messagers interrupted_turn_exit_reasonrNrQrrrrrTs'Y Krrc8V^8dQhRRRRRRRRRRRRRRR R /#) rr)rrconversation_historyrrsrrrrr)rs"rrr`sXA#A# A# A#8;A#TWA#A#&)A#>AA#A#rcaaaa^RIHpHpRVVVV3Rllp VP4p V 'd8V!WV 4\ S\ 4'dS RV 2oVP W4VPP4VP'dIRo\V4p V 'dRV R2MRoVP'gVPR 4V !R 4#V!V4'dHR oVP'g,VPR \VP4R R2RR7V !R 4#S^, oSVnVP!RS 24VP"'d RVnM~VP$P'4'g_RoVP'gCVPRVP$P( RVP$P* R2RR7V !R 4#V !R4#)zIteration entry in the original order: apply a pending redirect, reset the checkpoint dedup, then the interrupt / review-budget / iteration-budget exits. ``api_call_count`` is incremented here (the grace call consumes its flag instead of the budget).)_apply_active_turn_redirect_review_input_budget_exhaustedc V^8dQhRRRR/#)rrNrDrrr)rs"rr%begin_iteration..__annotate__ks    rc$<\VSSSSR7#))rNrrsrr)r)rNrrsrrs&r_verdict!begin_iteration.._verdictks1F){/  rz# User correction during the turn: Tzinterrupted_by_system()interrupted_by_useru2 ⚡ Breaking out of tool loop due to interrupt...breakreview_input_budget_exhaustedu( ⏹️ Review input budget exhausted (ruI tokens) — stopping the review tool loop before the next provider call.) diagnosticzstarting API call #Fbudget_exhaustedu% ⚠️ Iteration budget exhausted (rz iterations used)r)rlrr_drain_pending_redirectrrD_persist_session_checkpoint_mgrnew_turnr,r r _safe_printr session_input_tokens_api_call_count_touch_activity_budget_grace_callr1consumer3r?) r)rrrrsrrrrr_redirect_text_issuers &$$dddd rbegin_iterationr`s   224N#E^D +S 1 1())RSaRbc " x> ""$ !!! "5)CJ4WIQ?Pe   S T  &e,,;   223A67FGSW     aN*E //?@A $)  # # + + - -.    FuG]G]GbGbFccdeje{e{fFfFeGGXYfj  k  M ""rcl]tRtRt$RtR]R&R]R&R]R&R]R&R]R &R]R &R]R &R]R &R tR#)RetryRestartVerdictiu8``action``: ``"fallthrough"`` (a response is ready — process it), ``"continue"`` (a restart flag re-issues the iteration: redirect / compressed / rebuilt-for-fallback / length continuation) or ``"break"`` (turn ends: interrupted, non-actionable compaction handoff, or every retry exhausted without a response).rDrNrrPfinal_response retry_count restart_countrs_preflight_compression_blockedrrNrQrrrrrs8> K$''rrc$`V^8dQhRRRRRRRRRRRRRRR RR RR RR RR RRRRRRRRRRRRR/#)rr)r_retryresponserrrr api_kwargsrPrr max_retriesrsrlength_continue_retriesrrrrr)rs"rrrsA#A# A#A#*-A#AA#Z]A#A#'*A#9<A#NQA# A#25 A# %( A# =@ A#  A#rcaa a a a aa^RIHpHpRVVV VV V V 3RllpVP'dS ^, o S V 8dJRo\P RV 4VP 4pV'dVPV4V!R4#S ^,o VPP4RVnV!R4#V'd\V4oV!R4#VP'dS ^,o VPP4S ^, o RVn V!WF4'd*\PR 4S 'gVo R oV!R4#\WV4oV!R4#VP'deS ^, o S V 8d!R o\P R V 4V!R4#S ^,o VPP4RVnRoV!R4#VP'd)\!WP#V4V4VnV!R4#Vf-R oVP'R4VP)WE4V!R4#^o V!R4#)azConsume the ``TurnRetryState`` restart flags after the retry loop, in the original priority order. Refunds the iteration budget/count for restarts that produced no valid assistant item; ``restart_with_rebuilt_messages`` is the single consumer that clears ``_preflight_compression_blocked`` so the fallback gets a fresh preflight (#84733). The two refunding restart paths (redirect and rebuilt-for-fallback) are bounded by ``max_retries`` via ``restart_count`` (restarts since the last response) so a runaway interrupt/redirect that keeps re-arming a restart flag cannot refund the budget forever and hold the turn lease indefinitely.)_HANDOFF_SKIP_FINAL_RESPONSE-_should_skip_model_call_for_reference_handoffc V^8dQhRRRR/#)rrNrDrrr)rs"rr*apply_retry_restarts..__annotate__s   !4 rc *<\VSSSSSSSR7#))rNrPrrrrsrr)r)rNrrrsrPrrrs&rr&apply_retry_restarts.._verdicts'"1F){R_)+I/   rredirect_restart_limit_exceededzsRedirected-message restart limit (%s) exceeded; ending turn instead of refunding the iteration budget indefinitely.rFcontinuezjSkipping compressed-restart model call: reference-only handoff would be the sole active user turn (#80622)!compaction_handoff_not_actionablerebuilt_restart_limit_exceededzpRebuilt-message restart limit (%s) exceeded; ending turn instead of refunding the iteration budget indefinitely.!all_retries_exhausted_no_responseub❌ The model provider didn't answer after all retries. Send /retry, or switch models with /model.r)rlr r  restart_with_redirected_messagesrzwarningrsteerr1refundr restart_with_compressed_messagesrr restart_with_rebuilt_messages restart_with_length_continuationr %_requested_output_cap_from_api_kwargs_ephemeral_max_output_tokens_emit_diagnostic_statusr)r)rrrrrrrrPrrrrsrrrrr r r _unapplieds&$$$$$$$ddd$dd$dd rapply_retry_restartsr s`"  ... ; &!B  NN? 668J J'G$ $ ! %%'27/ ##>uE   ...! %%' q 27/ 8     KKF "!= C G$ $!*%< H ## +++ ; &!A  NN?  G$ $ ! %%'/4,*/& ## ...-? >>zJLc. * ##? %%'K L x>  M M ""r)(rV __future__rrrr@ contextlibr dataclassesrtypingrrrr agent.displayr agent.interrupt_controlr r agent.turn_context_compactionr agent.turn_truncationr getLoggerrzr'rCrKrMrqrrrrrrrrr rrrr*s@# !))'X34   4 5 D&"3l   62rKOrnrrj. .  XB  A#H      A#r