+ iHj„a0t$Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RI H t H t H t ^RI HtHtHtHt^RIHt^RIHt^RIHt^RIHtHt^R IHtHt^R IH t H!t!^R I"H#t#^R I$H%t%H&t&^R I'H(t(H)t)H*t*H+t+^RI,H-t-H.t.^RI/H0t0^RI1H2t2H3t3H4t4H5t5^RI6H7t7H8t8^RI9H:t:H;t;^RIH?t?H@t@^RIAHBtBHCtCHDtD^RIEHFtF^RIGHHtH^RIIHJtJHKtKHLtLHMtM^RINHOtO^RIPHQtQ^RIRHStSHTtTHUtUHVtV^RIWHXtX^RIYHZtZ^RI[H\t\^RI]H^t^^R I_H`t`^R!IaHbtb^R"IcHdtd^R#IeHftf^R$IgHhth]P!]j4tk]P!R%4tmR&tnR'toR(R)ltpR*R+ltqR,R-ltrR.R/ltsR0R1lttR2tuR3tvR4twR5R6ltx]y!0Rm4tz]y!R704t{^t|R8R9lt}R:R;lt~^ tR<R=ltR>R?ltR@RAltRBRCltRDREltRFRGltRHRIltRJRKltRLRMltRNtRORP/RQRRlltRSRTltRURVltRWRXltRYRZltR[RP/R\R]lltRR[RP/R^R_llltR`RaltRRbRclltRdRReR/RfRglltR[RP/RhRilltRjRkltRlRP/RmRnlltRoRpltRqRrltRstRtRultRvtRwtRxtRytRRzR{lltR|tR}tR~tRtRt/tR]R&RtRt^sRRltRtRRltRRltRRltRRltRRRlltRRltRRltRtRtRRRlltRRltRRRRRR/RRlltRRltRRltRR/RRlltRtRRlt] !RR44t]y!0Rm4t/tR]R&R]y!R04/tRRltRRltRRltRRRlltRRRlltRtRRltRRltRRltR.tR#)ueThe agent conversation loop — extracted from ``run_agent.AIAgent``. ``run_conversation(agent, ...)`` drives one user turn (model call, tool dispatch, retries, fallbacks, compression, post-turn hooks). Symbols that callers patch on ``run_agent`` (``handle_function_call``, ``_set_interrupt``, ``OpenAI``) resolve via ``_ra`` so those patches keep working.) annotationsN) dataclassfieldfields)AnyDictListOptional) hidden_interrupt_placeholder_row)_summarize_user_message_for_log) begin_turn)append_messagewithout_persistence_fields)_repair_tool_call_arguments_sanitize_surrogates)MINIMUM_CONTEXT_LENGTH_estimate_tools_tokens_rough)_install_safe_stdio)RUNTIME_ENVIRONMENT_ENDRUNTIME_ENVIRONMENT_HEADING)build_prompt_cache_planeffective_cache_ttlstrip_anthropic_cache_control"strip_anthropic_tool_cache_control)REPETITION_LOOP_INTERRUPTEDis_runaway_repetition)resolve_agent_cwd)identity_line_valuenote_inert_pinned_toolsruntime_host_valuestage_surface_switch_note)PreflightCompressionTimedOutbuild_turn_context)record_cache_breakrecord_prompt_rebuild)TurnRetryState)Prelude play_prelude)handle_api_interruptnous_rate_limit_guardperform_api_call)handle_api_error)build_api_request)FAILED_TURN_DISPLAY_KINDOPEN_TURN_TAIL_ROLESfailed_turn_notice site_copy)finish_text_response) finalize_turn)announce_api_callapply_retry_restartsbegin_iterationprepare_iteration)handle_outer_loop_error)run_preflight_gate)assemble_api_request)check_api_response)normalize_model_response)run_tool_round)set_session_context)set_current_write_origin)base_url_host_matchesz^\[[A-Za-z_][A-Za-z0-9_.-]*\]$z5[This response was interrupted by a user correction.]u[SYSTEM NOTICE — run time budget nearly exhausted] Run time budget nearly exhausted. Stop new discovery/verification work now. Produce the required final deliverable (answer/JSON/summary) from the state you already have, completing only mandatory writes.c ,V^8dQhRRRRRRRRR R/#) agentr api_messageslist[dict[str, Any]]effective_systemstr approx_tokensintreturn)formats"&>&A+ 50! 4D dC R RD$)?%? R RDNRrNc$V^8dQhRRRRRR/#)rArBrmessagesrDrIrYrJ)rKs"rLrMrM|s#  3 :N SW rNc\VRR4p\VRR4pV'dMV'dE\VRR4'g2\P!4V, R\V4,8dR#^RIHp\ V4Fp\ V\4'gKVPR4R 8XgK3VPV4'dR#VPR R 4p\ V\4'dVR \ 2,VR &M.T;'g.OR RR\/NVR &RVn \PR\V4\P!4V, 4R# R# \dR#i;i)zInject the one-time wall-clock wrap-up notice when past 80% of budget. Appends to the NEWEST ``role:"tool"`` message (cache-safe, like /steer); latches ``_run_budget_wrapup_injected`` only on a successful append.run_budget_secondsN_run_budget_started_at_run_budget_wrapup_injectedFg?)_DB_PERSISTED_MARKERroletoolcontentrQ typetextTz@Run budget wrap-up notice injected (budget=%.0fs, elapsed=%.0fs))rWtimefloatagent.context_compressorrmreversedrXdictgetrFRUN_BUDGET_WRAPUP_NOTICErZrlr[info)rBrhrdstartedrmmsgexistings&& rL_maybe_inject_run_budget_wrapupr|s@ U0$ 7Fe5tww+,,wwy"-H(C((!)d3K2L,M!MI!%lB%l&&&Rj9k%lC N15E - KKRf tyy{W4 '"( !! !s E/E// E?>E?c$V^8dQhRRRRRR/#rArhrD user_messagerrIrYrJ)rKs"rLrMrMs$"25 rNc\V\4'd\VP44pM#\V\4;'d \V4pV'gR#V'd VR,MRp\V\ 4'd/VP R4R8XdVP R4V8XdR#\VRRRV/4R#)z~Re-append this turn's real user ask when compaction left only a handoff (#80622). Returns True when a restore append happened.FNrnuserrpT)rXrFrYstriplistrxryr )rhr restorablelasts&& rL%_restore_user_after_reference_handoffrs ,$$,,,./  d3JJ\8J #8B<D$$((6"2f"<)ATXdAd8ffiFG rNc$V^8dQhRRRRRR/#rrJ)rKs"rLrMrMs$  " 25   rNcN^RIHpV!V4;'d\W4'*#)zKGuard post-compaction continues against sole-handoff active turns (#80622).)-reference_handoff_would_drive_next_model_call)rvrr)rhrrs&& rL-_should_skip_model_call_for_reference_handoffrs/W 9 B  -hEHrNuXContext was compacted. The previous response is complete — awaiting your next message.zContext compression timed out without reducing this conversation. No messages were dropped. Start a fresh session with /new, or check auxiliary.compression before retrying /compress.z3Operation interrupted: waiting for model response (c ,V^8dQhRRRRRRRRRR/#)rAcompression_attemptsrHcompleted_compaction_pendingrY prompt_tokensthreshold_tokensrIrJ)rKs"rLrMrMs4@DUXlo rNcp\T;'d%T;'d^Tu;8;'d V84#u4#)zTrue once a provider proves a completed compaction worked: rough estimates cannot rearm the anti-thrash budget, only the completed-compaction latch plus a positive normalized prompt count below the threshold.)rY)rrrrs&$$$rL _should_rearm_compression_budgetrs@ ff!=ff!mBfBfVfBf Bf rNchat_completion_helpersc V^8dQhRRRR/#)rAexcrZrIrYrJ)rKs"rLrMrMs   d rNcN\V\4'd^RIHpV!V4#R#)zTrue for a fatal interpreter-shutdown RuntimeError. The RuntimeError type gate stays here: a ValueError carrying similar text must not match (#93269).)interpreter_shutting_downF)rX RuntimeErrortools.interpreter_shutdownr)rrs& rL_is_interpreter_shutdown_errorrs%#|$$ I(-- rNc V^8dQhRRRR/#)rAclientrrIrYrJ)rKs"rLrMrMs;;#;$;rNc^\\VRR4RR4p\\VRR44#)zTrue when ``client`` is the in-process MoA facade (only ``MoAChatCompletions`` exposes ``prepare()``; other clients raise TypeError on ``_moa_prepared_request`` even while ``agent.provider`` stays ``"moa"``).chatN completionsprepare)rWcallable)rrs& rL%_moa_client_consumes_prepared_requestrs/'&&$7MK GKD9 ::rNc$V^8dQhRRRRRR/#)rApreviousrF continuationrIrHrJ)rKs"rLrMrM s&BB3BcBcBrNc\V4\8g\V4\8d^#^.\V4,p^p\^\V44FQpV'd%W,W,8wdW#^, ,pK,W,W,8XgKDV^, pW2V&KS ^p\V4^, p\V4FnwrFV'dWaV,8wdW#^, ,pK&WaV,8XgK:V^, pV\V48XgKUWE8XdVu#W#^, ,pKp V\8dV#^#)zHReturn the longest continuation prefix that repeats the previous suffix.)len_MIN_CONTINUATION_OVERLAPrange enumerate)rrprefix_lengthsmatchedindex last_indexchars&& rL_continuation_overlap_lengthr s 8}00C 4EHa4aS3|,,NGq#l+,,-1FF$q[1G  ,"7 7 qLG$+5 ! -GX"J * $w"77$q[1G ( ( qLG#l++&"N(15+!::7AArNc V^8dQhRRRR/#)rApartslist[tuple[str, bool]]rIrFrJ)rKs"rLrMrM&s  !7 C rNcFRpRpVFwr4V'd-V'd%V'dV\V\V4)RV4RpV'dLVR,P4'g/V'd'V^,P4'g VR, pW, pTpK V#)zDJoin continuation fragments, deduping only interrupted-stream seams.rQFN r)rrisspace)rjoinedprevious_was_partial_stubpartis_partial_stubs& rL_join_truncated_partsr&s F %!& $D4VSYJK5H$OPQD &*,,..4Q@Q@Q dNF$3!"' MrNc V^8dQhRRRR/#)rArBrrIrJ)rKs"rLrMrM5s  3 3 rNc\VRR4p\VRR4p\V4'gR#V!4# \dR#i;i)zPer-advisor metrics for post_api_request, or None off the MoA path (a plugin only sees the aggregator generation; this carries the per-slot advisor spend).rNlast_reference_metrics)rWrrZ)rBrgetters& rL_moa_reference_metrics_for_hookr5sMUHd +F V5t githubcopilotgithub-copilot)rY_is_copilot_providerrZrWrlower)rBs&rLrrls` E..011  z2.44";;=CCEJ    sA"AAc$V^8dQhRRRRRR/#)rA status_code Optional[int] error_messagerFrIrYrJ)rKs"rLrMrMys#  M RU Z^ rNcaT;'gRP4oVR8wd RS9dR#\;QJdV3RlR4F 'gK R# R#!V3RlR44#)zDetect a Copilot 400 that is really a STALE / DEGRADED credential (status 400 AND an integrator/model-not-supported marker, so a wrong model name never triggers the single-shot re-exchange). Caller enforces scoping/guard.rQizerror code: 400Fc3,<"TF qS9xK R#5iNrJ).0markerlowereds& rL 5_is_stale_copilot_credential_error..s0V 0sT)"model_not_available_for_integratorznot available for integratormodel_not_supportedz$the requested model is not supported)rany)rrrs&&@rL"_is_stale_copilot_credential_errorrysm""))+Gc/w> 3033330 rNc$V^8dQhRRRRRR/#)rA compressorr rough_tokensrHrIrJ)rKs"rLrMrMs!#SSrNc|\\VR^4;'g^4pW!8d\VRR4'gV#V#)aFloor the ROUGH pre-API pressure estimate at the last REAL prompt size. Applied only on the fallback path -- when ``anchored_context_tokens`` has no valid anchor (first request, transcript rewritten under the anchor, provider never reported usage). A valid anchor is provider-exact and is used as-is; in particular on MoA turns the anchor deliberately uses the pre-fold aggregator usage while ``last_real_prompt_tokens`` holds the folded figure, so flooring an anchored value would re-add fan-out tokens the anchor exists to exclude. On the rough path, non-ASCII text (Cyrillic, Greek, Polish, ...) under-counts by up to ~2x, so a session can sit at the provider's real context ceiling while the rough figure stays under the compaction threshold -- on silent-clip providers (ollama /v1) that is a truncation death spiral the reactive overflow handler never sees (observed live: real prompts 64,842->64,995 against a 55,705 threshold). The provider's last reported prompt_tokens is authoritative; never let the rough figure fall below it. Skipped for exactly one turn after a compaction, when last_real_prompt_tokens still holds the stale pre-compression value (#36718's awaiting_real_usage_after_compression window). last_real_prompt_tokens%awaiting_real_usage_after_compressionF)rHrW)rr last_reals&& rL_pressure_with_real_floorrsH,GJ(A1EJJKI;U)) rNc$V^8dQhRRRRRR/#)rArBrrequest_tokensrHrI Optional[str]rJ)rKs"rLrMrMs!sCMrNc\VRR4p\VRR4'd.\V\4'd^Tu;8d\8gR#R#\VRR4;'gRp\P RT\VRR4;'gR \VR R4;'gR T\T\ \VRR4;'g.4\VR R4;'gR 4 RV RVR R\R R2#)zIReturn a user-facing error when Ollama is loaded with too little context._ollama_num_ctxNrRmodelrQthe selected modelzOllama runtime context too small for Hermes tool use: model=%s provider=%s base_url=%s runtime_context=%d minimum_context=%d estimated_request_tokens=%d tool_count=%d session=%srunknownbase_urlzunknown base URL session_idnonezOllama loaded `z ` with only ,z6 tokens of runtime context, but Hermes needs at least a tokens for reliable tool use. Increase the Ollama context for this model and restart/reload the model before trying again. A known-good starting point is 65,536 tokens. In Hermes config, set `model.ollama_num_ctx: 65536` (and `model.context_length: 65536` if you also override the displayed model context). If you manage the model through an Ollama Modelfile, set `PARAMETER num_ctx 65536` there instead.)rWrXrHrr[warningr)rBr runtime_ctxrs&& rL_ollama_context_limit_errorrs%!2D9K E7D ) )+s++;7!778 E7B ' ? ?+?E NN e wuj"-::z2&<<* --provider .rzC reported that your Claude subscription usage may be exhausted for uf (included quota + extra-usage credits) — but this specific error is not proof of a billing problem.uIf https://claude.ai/settings/usage still shows quota remaining, this is probably NOT a billing problem: on a Claude subscription (OAuth) token Anthropic returns this same message when its content filter rejects part of the request — typically a phrase in the system prompt.zyIf usage really is exhausted: wait for the billing cycle to reset, or add extra usage at https://claude.ai/settings/usagezRetry with a fresh credential state: `hermes auth reset anthropic`. Until that cooldown clears, this error can be replayed from cache without contacting the API.z? reported that your Claude subscription usage is exhausted for z( (included quota + extra-usage credits).zdOptions: wait for the billing cycle to reset, or add extra usage at https://claude.ai/settings/usagebuild_billing_block)rrrNzI reported that billing, credits, or account entitlement is exhausted for .z=Add credits or update billing with that provider, then retry.z billing: zOYou can switch providers temporarily with /model --provider .) r7rrrragent.billing_linksr>provider_label billing_urlrZ) rrrrr8rA model_labelswitchr>_linkrBs $$$$$ rL_billing_or_entitlement_messagerFs 33(TBBnn"++-HH1HN;;B%%'??+?K B%%';6 4  99!""e- 22%6e yy]mC E r     ;#XPUV--??''  99  cdocppqrG;Fn Z } 5 62 Z    s"D48D44 EEc V^8dQhRRRR/#)rAr8rYrIzOptional[dict]rJ)rKs"rLrMrMMs  d _m rNc^RIHpV!V\V4W#R7P4pTeT'dRTR&T# \dR#i;i)zQBest-effort structured billing descriptor (None if billing_links is unavailable).r=)rrrr NTr8)r@r>rFto_dictrZ)rrrr r8r>blocks&&&&$ rL_billing_block_dictrKMsV;#H U ')   Z"l L s(= A  A c$V^8dQhRRRRRR/#)rAsummaryrFr8rYrIrJ)rKs"rLrMrM[s!66S6d6s6rNc&V'dRV 2#RV 2#)zsTerminal-failure prefix for a billing-classified error; ``unverified`` (#82154) must not assert exhaustion as fact.uzProvider reported usage/credit exhaustion (unverified — the same error can be a content-filter rejection, not billing): zBilling or credits exhausted: rJ)rMr8s&&rL_billing_terminal_labelrO[s, FFMY P ,G9 55rNcV^8dQhRR/#)rArI+tuple[str, Optional[float], Optional[dict]]rJ)rKs"rLrMrMfs..Cn.rNc\VRR4;'g/pVPR4'gR#^RIHpHp^RIHp\VRR4pV!V4pVe V!VRVR 7MRp VPR 4p \\VR R4;'gR4P4p \V \4'd(V P4'dV P4p M5V 'd!V PR 4P4p M V 'dT p MR#Ve V!WxR 7MRp Rp^RI H p^RIH pT!Y V'dT!T;'g.4MRR7pVeVP4MRpT \V \$4'dV ^8d V R, V3#RV3# \d\ P#RRR7RpLSi;i \d\ P#RRR7Ru#i;i)u'A usage-window 402 in the words of the credits limit line ("You've hit your daily limit · resets 15:56 · /topup to add credits") plus when that allowance frees up (epoch seconds), so the chat and the error card say exactly what the notice says and the card can offer a retry at the reset. The third item is the structured limit (:class:`agent.plan_limits.LimitHit` payload: what ran out, the recommended models that still work, the credits option) every surface renders as buttons or a sentence. ``("", None, None)`` for every other billing failure. error_contextN usage_windowrQ)_window_hard_stopwindow_stop_resets_at_ms)current_model_is_top_tier_credits_stateF) model_is_freemodel_is_top_tierdisplay_messager u✕ )rZ)estimate_messages_tokens_rough) limit_hit)r  needed_tokensz&Usage-window limit payload unavailableTrTiz!Usage-window refusal parse failedrQNN)rWryagent.credits_trackerrUrVagent.plan_limitsrWrFrrX removeprefixagent.model_metadatar\r] to_payloadrZr[r\rH)rB classifiedrCcontextrUrVrWstatetop_tierstopdisplayserver_messager  resets_mslimitr\r]hits&&& rL_usage_window_refusalrofsj/48>>BG ;;~ & &$U?/6,U3\a\m exXsw++/0WZB?EE2FLLN gs # # mmoG ''/557G  %G! !SXSd,UOjn   K 3E`l*HI[I[Y[*\rvxC(+CNN$TEZ 3-G-GIXYMT)ejkk_cejkk  LLADL QE   84 HsaAGAGG*'GGG)!F $F/(GG$GGGG$G-,G-guidancerTc4V^8dQhRRRRRRRRRRR R R R /#) rArMrFapi_call_countrHrrrprrTrQrIrxrJ)rKs"rLrMrMsH###;>#JM#`c##># #rNc \\VRR44p Vf9\V4R,^,'g\RV\ V4VV R7p\V4R,R,wrp T ;'g \ W4V'dRV 2MR,p /pV 'dWR&V eWR &V 'dWR &/VCR V R VR VRRRRRVRVP PR\VP4RV R\WEWgV R7/ C#)uStructured terminal result for a billing-classified failure — the single construction point for the non-retryable abort and max-retries paths (#82154). A usage-window refusal reads as its one stop-line sentence instead of the generic "billing exhausted" text.billing_unverifiedFrQz model accessrrrrr8NNrqusage_window_messagefailure_resets_at usage_limitfinal_responserh api_calls completedfailedTerrorfailure_reasonfailure_retryable billing_block)r8rQ)NNN) rYrWtuplerFrFrOreasonvalue retryablerK)rerMrhrrrrrrprTr8rxusage_window_resets_atrzfinalextras$$$$$$$$$ rL_billing_failure_resultrs.gj*>FGJ|!4u! >u2D99GE#8"=CCDJJL***u/?/?/? E--??@P@PQWWUWX^^`&jj40TUb0i+jj      s D.D D.D. D.%D.D.D.'0DD- D.8D. DD.DD. D+(D.*D++D.. D=<D= persist_toolsc$V^8dQhRRRRRR/#)rAfailure_messagerFrrYrIrrJ)rKs"rLrMrMs" ? ?3 ?$ ?[_ ?rNc2VP'gR#VPPVPVP4V'd^RIHpV!V4R#R# \ d,p\PYPT4Rp?R#Rp?ii;i)zPersist ``agent._cached_system_prompt`` to the session row; failures log at WARNING (with ``failure_message``) because the gateway path (fresh AIAgent per turn) reads this row every turn, so a silent failure breaks prefix-cache reuse.N)persist_agent_tool_names) rupdate_system_promptr_cached_system_prompttools.mcp_tool_agentrrZr[r)rBrrrrs&&$ rL_persist_system_promptrsv    ? ..u/?/?A\A\]  E $U +  ?(8(8#>>?s7A A B+ BBcV^8dQhRR/#)rArIrrJ)rKs"rLrMrMs"""rNc~^RIHpHpHpV!V4pV'dVP R4MRpV'd\ P !V4MRpV'd V!W4V#Ve\VRR4'g V!V4V# \dRpLCi;i \d\PRRR7T#i;i) zPin ``agent.tools`` to the session's persisted array (tools freeze); returns the names this surface built BEFORE the pin merged a previous surface's tools back in.)agent_tool_namesrrestore_agent_tool_prefix tool_namesN_persist_disabledFztool prefix restore skippedTrT) rrrrryjsonloads ValueErrorrWrZr[r\)rB session_rowrrrbuilt_for_this_surface saved_toolspins&& rL_restore_pinned_toolsrskj-e43>+//,/DK)4djj%$C  %e 1 "!  $WU>L LL M#L>>M"M+*M+c V^8dQhRRRR/#)rApromptrFrIrYrJ)rKs"rLrMrMs#$rNcRFPwr#\W4p\\WR4;'gR4P4pV'gKGWE8wgKOR# \VR4pV'd&\VRR4'dW`P8wdR#\ VR4pV'dV\\ 448wdR#R#)zAReturn False when the persisted runtime-identity lines are stale.rQFz Session IDpass_session_idzCurrent working directoryT))Modelr)Providerr)rrFrWrrrr)rBrlabelattrstoredcurrent stored_sid stored_cwds&& rLrrsF $V3ge2.44"5;;= 6f' F%V\:Jge%6>>:QaQaCa$F,GHJjC(9(;$<< rNuL[System: The previous response was cut off by a network error mid-stream — a transport interruption, NOT a change in your capabilities. Your tools are still fully available; call them as normal and ignore any earlier claim that you lack tool access. Continue the task from where you left off. Do not restart or repeat prior text.]z[System: Your previous response was truncated by the output length limit. Continue exactly where you left off. Do not restart or repeat prior text. Finish the answer directly.]z[System: The previous response was cut off by a network error mid-stream. Continue exactly where you left off. Do not restart or repeat prior text. Finish the answer directly.]z![System: Your previous tool call c$V^8dQhRRRRRR/#)rArrY dropped_toolszOptional[list[str]]rIrFrJ)rKs"rLrMrMs( g gd gCV gbe grNcV'd-V'd%RPVR,4p\ RV R2#V'd\#\#), rv(u) was too large and the stream timed out before it could be delivered. Do NOT retry the same tool call with the same large content. Instead, break the content into multiple smaller tool calls (e.g. use multiple patch calls or write smaller files). Each tool call's arguments must be under ~8K tokens to avoid stream timeouts. The cut was a transport interruption, not a capability change — your tools remain fully available.])r)_LENGTH_CONTINUATION_DROPPED_TOOLS_PREFIX!_LENGTH_CONTINUATION_NETWORK_STUB!_LENGTH_CONTINUATION_OUTPUT_LIMIT)rr tool_lists&& rL_get_continuation_promptrsJ=IImB/0 899+F\ \ 1@ ,fEffrNz[System: Your previous response contained only internal reasoning and never produced a visible answer or tool call. Do not keep thinking. Produce your final answer as plain text now (or make the tool call you were planning).]zr[System: Continue now. Execute the required tool calls and only send your final answer after completing the task.]z[System: Your previous message ended the turn with a fragment that is not a usable answer. If the task is unfinished, continue it and then give the complete answer. If that fragment WAS your complete answer, send it again exactly as before.]uYour previous turn indicated a tool call but none was included. Do not narrate a plan or restate intent — issue the actual tool call now to continue the task.z~You just executed tool calls but returned an empty response. Please process the tool results above and continue with the task.zdict[str, str]_CANON_ARGS_CACHEic V^8dQhRRRR/#)rAarg_strrFrIrJ)rKs"rLrMrM1sssrNcL\PV4pVeV#\P!\P!V4RRR7pV\V&\ \ V4\ V4,, s\ \4\8g$\ \8di\ \4^8dU\\\44p\ \ V4\ \PV44,,sKV# \\\3dT#i;i)zCanonical wire form of a tool-call arguments JSON string; raises on malformed input (the caller falls back to ``_repair_tool_call_arguments``).T) separators sort_keys)r:)rryrdumpsr_canon_args_cache_bytesr_CANON_ARGS_CACHE_MAX_CANON_ARGS_CACHE_MAX_BYTESnextiterpop StopIterationKeyErrorr)rcached canonical evicted_keys& rL!_canonicalize_tool_call_argumentsr1s " "7 +F   4::g.:QUVI!*gs7|c)n<<  #8 8"==#FWBX[\B\ t$567K #s;'7#>O>S>ST_>`:a'a a # x6    s4AD D#"D#c ~\V\4'dMVP4UUu/uF/wrT\V\\34'd \ V4MTbK1 upp#\V\4'd:VUu.uF,p\V\\34'd \ V4MTNK. up#V#uuppiuupi)zStructural clone (dicts/lists recursively, immutable leaves shared) of a history message for the per-call API copy, so send-path rewrites never reach the persisted transcript (#80498). Cheaper than deepcopy: messages are JSON-shaped and acyclic.)rXrxitemsr_clone_message_for_send)r}kvs& rLrrFs#t`c`i`i`kl`kX\XYAd|1L1L*1-RSS`kll#tZ]^Z]UVjT4L.I.I'*qPZ]^^ Jm^s 5B4=2B:cV^8dQhRR/#rrJ)rKs"rLrMrMQs##$#rNc VFpVPR4pV'gK.pVF[p\V\4'd2RV9d+VR,p\VR,4p/VCR/VCRV/C/CpVP V4K] W1R&K R# \d'\ TR,TPRR44pL]i;i)zCanonicalize tool-call argument JSON on the send-path copy (copy-on-write for the dicts it touches; persisted history untouched). tool_callsfunction argumentsname?N)ryrXrxrrZrr)rCamtcsnew_tcstcfnargss& rL_canonicalize_api_tool_callsr!Qsff\" B"d## b(8 ^]B?c V^8dQhRRRR/#)rArrFrIrJ)rKs"rLrMrMhs I I3 IS IrNcT;'gRP4'gR#RP\V44pRV RV 2#)uError content for an unknown tool name. A blank name is a model echoing tool-call syntax seen in data (#47967) — dumping the catalog feeds that loop, so it gets a terse error; a nonempty wrong name still gets the catalog to self-correct.rQuTool call rejected: the tool name was empty. If tool-call XML or JSON appeared in file contents or tool output, that is data — do not re-emit it as a tool call. To call a tool, use a valid name from your tool list; otherwise reply in plain text.rzTool 'z#' does not exist. Available tools: )rrsorted)rvalid_tool_names availables&& rL _invalid_tool_name_error_contentr'hsN JJB     Y  &!123I D6\VRR4p\PR T\ V\ 4'dTMR 4R pVP 4\WaVR R VPR7# \dL'i;i)uSoft turn result for a transiently-deferred compression. Both reasons must end as ``compression_deferred``, never ``compression_exhausted`` — the gateway wipes the session on exhaustion (#9893/#35809). ``failed`` stays False; the turn persists.rtransient_block_compression_blocked_transientNukturn deferred: compression transiently blocked (%s) (session=%s) — not counting as compression exhaustionz unknown guarduContext compression is temporarily paused after a recent failed attempt. Please retry in a moment — compression will resume automatically (or run /compress to force a retry now). _compression_skipped_due_to_lockuvturn deferred: compression lock held by another path (session=%s holder=%s) — not counting as compression exhaustion unconfirmeduContext compression is already running for this session. Please retry in a moment — your next message will be processed once the concurrent compression finishes.FT)r~compression_deferredr) rrWr[r{rXrF_flush_status_bufferrZr3)rBrhrrrsessionrJ_finalholders&&&& rL_compression_deferred_resultr?s((&G ""?F  %/9%/E/Ee?\c  m   BDI  129ZPVX[E\E\6bo  \   ""$ .4E.s3?JQ$ 4==488F#3v#=='s;;FTrsrQN)ryrXrallr startswith)rrLrpheads&& rL_rewrite_system_content_blocksrSs  +G gt $ $G33?JQ?333?JQ?<< 7|q& 6 7|qqz~~f%++ I((..9SYZ3H!*3t9:!6GAJv  rNcj\VRR4p\V\4'd V'gV#V'd~V^,PR4R8XdaVP'd)VR,VP,P 4MTp\ V^,V4'g WA^,R&V#)zRefresh the in-flight system message after a provider failover: ``api_messages`` were built pre-failover and are reused each retry. Returns the new ``active_system_prompt``.rNrnr0rqrp)rWrXrFryephemeral_system_promptrrS)rBrCactive_system_promptsprLs&&& rL_sync_failover_system_messagerXs / 6B b#  b## Q++F3x?MRMjMjMjR&[5#@#@@GGIpr -l1oyII)2OI & IrNc:\WV4pRVnRVnV#)zAfter a successful fallback activation: sync the system message and arm ``restart_with_rebuilt_messages``. Callers also zero ``retry_count`` / ``compression_attempts`` and ``break`` the retry loop.FT)rXprimary_recovery_attemptedrestart_with_rebuilt_messages)rBrCrV_retrys&&&&rL_arm_fallback_restartr]s+9 13(-F%+/F( rNcV^8dQhRR/#rrJ)rKs"rLrMrMsggtgrNc&^RIHpV!WRR7R#)zRebuild ``_cached_system_prompt_static`` when caching becomes active (#72626): sessions restored under a cache-off primary would otherwise fall back to the legacy layout after failover to a cache-on provider.)rzfailover redecoration)r log_labelN)rr)rBrrs&& rL#_ensure_cached_system_prompt_staticras>eNefrNc$V^8dQhRRRRRR/#)rArhrDrprrIrJ)rKs"rLrMrMs#77!577I]7rNc^RIHpV!W4#)zIRemove MoA reference guidance attached by ``_attach_reference_guidance``.)peel_reference_guidance)agent.moa_looprd)rhrprds&& rL_peel_moa_guidancerfs6 "8 66rNr moa_prepared tools_for_apic(V^8dQhRRRRRRRR/#) rArCrDrgOptional[dict[str, Any]]rhzOptional[list[dict[str, Any]]]rIzKtuple[list[dict[str, Any]], Optional[dict[str, Any]], list[dict[str, Any]]]rJ)rKs"rLrMrMs/1-1--1-*1-B`1-Q1-rNcT;'g.Uu.uF&p\V\4'd \V4MTNK( ppTp\V\4'dVPR4MRpV'd \Wh4p\ V4\ VeTM \ VR.44p Vee\ VRR4R8XdS\ \ VPRR4RR4p \ V RR4p \V 4'dV !Wv4pVR ,pMVP'd\WR 7\ VR R4p ^R I H p \TT \VPVP VP"R 7VP$\V \&4'dT MR\ VRR4!4V !\ VRR4\ VRR44R7pVP(VP*rWgV 3#uupi)uStrip and re-apply cache_control for the *current* provider policy — failover ``continue`` paths reuse ``api_messages`` (#72626). MoA guidance is peeled and rebased.rpNrRrmoarrrebase_prepared_requestrhr_cached_system_prompt_static)*envelope_tool_part_cache_markers_supportedrr._direct_native_anthropic_tool_cache_capabilitycR#)FrJrJrNrL7_redecorate_prompt_cache_for_provider..-sQVrNrQr) cache_ttlnative_anthropicstatic_system_prefixdirect_native_tool_cachetool_part_markers)rXrxryrfrrrWrr_use_prompt_cachingraagent.prompt_cachingrorr _cache_ttlrr_use_native_cache_layoutrFrhrR)rBrCrrgrhmrhpreparedrp planned_toolsrrebasestaticroplans&&$$$ rL%_redecorate_prompt_cache_for_providerrs WcVhVhfhVh%jVhPQAt1D1Dd1g!&KVhH%jH+5h+E+Ex||J'4H%h9!(+6&2 wPR8SMz4 @E IgellFDA=RVW &?F F  h1H +H  " " "+EQ >ES&  *%*:*:U^^[`[f[fg";;+5fc+B+B%,G&& Iz2.z20N "#'--- } ,,W&ks,G"c$V^8dQhRRRRRR/#)rAenginerrrFrIrYrJ)rKs"rLrMrM:s!  3 c d rNc\WR4pVe\V4'gR#^RIHp\VRR4\W14J# \dR#i;i)zTrue when ``engine`` implements ContextEngine hook ``name`` itself. Non-implementing engines must pay nothing per turn; ``hasattr`` is not enough because the ABC defines a no-op default. Lazy import avoids a cycle with agent.context_engine.NF) ContextEngine__func__T)rWragent.context_enginerrZ)rrhook_CEs&& rL_engine_overrides_hookr:sS 6 &D ~Xd^^=tZ.gc6HHH sA AAc 0V^8dQhRRRRRRRRRRR R/#) rArBrrCrDconversation_messagesincoming_messagerjr[rIrJ)rKs"rLrMrMIs>// /2/K_/./;>//rNc b\VRR4p\VR4'gV#\VRR4;'gRpTPTVeVUu.uFp\V4NK upMR\ V\ 4'd \V4MT\VR^4;'g^R7pTfT#\ T\4'dT'd\;QJdR T4F 'dK R M R M !R T44'dkTUu.uFp\T4NK p p\;QJd%R \Y44F 'dK R M R M!R \Y444'dT#T #TPRT4T#uupi \ dTPRTR R 7Tu#i;iuupi)zRun the optional per-turn ``ContextEngine.select_context()`` hook, fail-open: any exception or invalid return yields ``api_messages`` unchanged; history is never mutated.context_compressorNselect_contextr-r)rr budget_tokenszYContext engine select_context hook failed; using unmodified request messages (session=%s)TrTc3B"TFp\V\4xK R#5ir)rXrx)rr~s& rLr2_apply_context_engine_selection..ns6]T\qz!T7J7JT\sFc3,"TF wrWJxK R#5irrJ)rabs& rLrrssJ2I$!qv2IsznContext engine select_context returned an invalid value (not a non-empty list of dicts); ignoring (session=%s)) rWrrrrXrxrZrrrPrzip) rBrCrrr[r session_labelr~selectedstrippeds &&&&$ rL_apply_context_engine_selectionrIs U0$ 7F !&*: ; ;E<6==#M(( )46KK5J(+5JK:>.55((89;K!&*:A>CC!)  &(D!!h336]T\6]3336]T\6]3]3]rNc \PRV4^RIHpV!V4\ \ V4\ T;'g.4^RRRRRR7#)zTyped recovery result when turn-start preflight compression timed out (#98424): no provider call was sent, and surfaces would otherwise hide the actionable guidance.uYTurn-start preflight compression timed out — ending turn with typed recovery result: %s)note_turn_persistedTcontext_compression_timeoutrDFrF)r[ragent.agent_runtime_helpersrr3rFr)rBrrrs&&& rL_preflight_timeout_resultrsY NNceh @  C$+11r2A4B_)U rNc]tRtRt$RtR]R&R]R&R]R&R]R&R]R&R]R &R]R &R]R &R]R &R]R &R]R&R]R&R]R&R]R&R]R&^tR]R&RtR]R&RtR]R&Rt R]R&^t R]R&^t R]R&^t R]R&^t R]R&^tR]R&]!]R 7tR!]R"&^tR]R#&RtR$]R%&RtR]R&&RtR]R'&R(tR)]R*&RtR]R+&RtR]R,&RtR]R-&RtR]R.&RtR]R/&RtR]R0&RtR]R1&RtR]R2&RtR]R3&Rt R]R4&Rt!R]R5&Rt"R]R6&^t#R]R7&Rt$R]R8&Rt%R]R9&R:t&R)]R;&Rt'R]R<&Rt(R]R=&Rt)R]R>&Rt*R]R?&Rt+R]R@&Rt,R]RA&Rt-R]RB&RCt.R#)D _LoopStateiaEvery local the turn loop threads through the phase helpers in ``agent/turn_*.py``. Helpers take the loop locals they need as keyword arguments named like these fields and return a verdict whose non-``action``/``result`` fields carry the same names; :func:`_run_phase` passes and copies them back by name, so a new helper input/output needs a field here and nothing else. Per-iteration slots are rebound by the phases before any later phase reads them, exactly as the former inline locals were.rrr moa_configoriginal_user_messagereffective_task_idturn_id_should_review_memory_plugin_user_context_ext_prefetch_cacherhrVcurrent_turn_user_idx_preflight_compression_blockedrBrHrrNr{FrY interruptedr~codex_ack_continuationslength_continue_retries restart_count_outer_error_counttruncated_tool_call_retries)default_factoryrtruncated_response_partsrr_last_preflight_pressure#_provider_overflow_recovery_pending_compression_timeout_exhaustedrrF_turn_exit_reason_pending_verification_response(_pending_verification_response_previewedpending_moa_prepared_requestrequest_loggerrCrh_moa_prepared_requestrGrA total_charsthinking_spinnerapi_start_time retry_count max_retriesr\ri finish_reasonresponser-api_request_id_original_api_kwargs_llm_middleware_trace api_durationassistant_messagerJ)/__name__ __module__ __qualname____firstlineno____doc____annotations__rrr{rr~rrrrrrrrrrrrrrrrrrCrhrrGrArrrrrr\rrr-rrrrr__static_attributes__rJrNrLrrsTO LM$''"!NCNCKFD#$S$#$S$ M3'((7.s*g6V_fZf116Vs rrQTrJ)actionresult) rryrinspect signature parametersrW_LATCHED_VERDICT_FIELDSrrsetattr) rrBrgrparamsnverdictlatchedfrs &&&, rL _run_phasers   r "F ~%*U*gg6G6G6K6V6V*gUU*gg6G6G6K6V6V*g%ggr"]U[\U[PQ!*eh'%:KKU[\]G%))'"j"*ErJG G_ 66) ) ( 66 E665 ) U E664 ( N]s"E! c V^8dQhRRRR/#)rAsrrIrjrJ)rKs"rLrMrM%s*1IrNcVPVP8d\\W4pVPR8Xd VP #VPR8XdR#\\ W4\\W4PR8XdR#\\W4pVPR8Xd VP #VPR8XdR#KR# \d(\\Y4PR8XdR#EK\dXp\\YTR7pTPR8XdTP uRp?#TPR8XdRp?R#Rp?EK^Rp?ii;i)uOne API call with its retry/recovery loop (guard → build → call → check, error handlers). Returns a turn result dict when a phase ends the turn, else None once the loop is left (success, a restart armed on ``s._retry``, interrupt, or retries exhausted).rIbreakN) api_error) rrrr)rrr,r*r:InterruptedErrorr(rZr+)rBr_ng_rcr_aes&& rL_run_api_retry_loopr%s --!-- '.9 :: !::  ::   (% 3*E5<<G/:CzzX%zz!zzW$%   .9@@GKL -u9MCzzX%zz!zzW$%  s</C,C;C*E$E$ E$ .E;E$EE$c$V^8dQhRRRRRR/#)rArBrrrIrjrJ)rKs"rLrMrMEs"##2JrNcLVPVPVPVPVPVP R7p^RIHpV!W4'gV#\VPR4;'g^4Vn \VRVP4Vn R#)zThe codex app-server's result for this turn, or None when its failure activated a fallback and the generic loop retries the same user turn.)rrrhrshould_review_memory)"activate_codex_app_server_fallbackr|N) _run_codex_app_server_turnrrrhrragent.turn_recoveryrrHryrrrXrV)rBr codex_resultrs&& rL_codex_app_server_turnrEs33^^1;R;Rq/B/B444L G -e B B<++K8==A>A:5$H^H^_A rNcTV^8dQhRRRRRRRRRR R R R R RRRRRRRRRRRRRRRR/#)rArrrrrlist[dict[str, Any]] | Nonetask_idstream_callbackOptional[callable]r Optional[Any]persist_user_timestampOptional[float]persist_user_display_kindrpersist_user_display_metadatarjpersist_user_platform_id turn_authorrtitle_user_messagepreludeOptional[Prelude]rIr+rJ)rKs"rLrMrMWs____6 _  _ ( _(_,_ -_$<_,_*_)_&__ !_rNc V f\W4wrpR;VnVnRVn\ W4VP 4\WW#VWVV3RVRV RV R V R \R \R \R \R\R\R\ R\#V 4RV / p^RIHpT!YP,TP.4Tn\14TnRTnRTnRTnRTn/TnRTn\AR!RTRT R\CTR^4/\E\@4Uu/uFJpTPF\H9gKTPF\CTTPFPKR44bKL upBpTPLR8Xd\OTT4;peT#\QTTT4wppTR8XdT#TR8wEdyTPRTPT8dTPVPX^8gTPZ'Ed0\]\^TT4P`R8XdEM \]\bTT4\]\dTT4\]\fTT4pTP`R8Xd TPh#TP`R8XdEMTP`R8XdK\]\jTT4\lPl!4^TPnuTn8Tn9Tn:\w4RRR3wTn<Tn=Tn>Tn?TP RTPR 2;TnATnB\TT4pTeT#\]\TT4pTP`R8XdMTP`R8XdEK\]\TT4pTP`R8Xd TPh#TP`R8XdEK\]TPP'd\M\TT4pTP`R8Xd TPh#TP`R8XdMTP`R8XdEK}EK\T3/\P!\4PUu/uFpTR8wgK T\CTT4bK upBpTP'dTP\RRR 7T# \ d\PRRR7ELi;i \$dp\'TTT4uRp?#Rp?ii;iuupi \ d6p\]\TTTR7P`R8XdRp?EKRp?EKRp?ii;iuupi)"aRun a complete conversation with tool calling until completion; returns the result dict. ``stream_callback``: per-text-delta callback (TTS). ``persist_user_message``: clean text to store when ``user_message`` carries API-only synthetic prefixes; timestamp / platform id are stored as metadata (platform id lets restart drain recovery dedup). ``title_user_message``: optional pre-injection text for titles only (None uses the model-facing message; an empty string suppresses titling for this turn). ``persist_user_display_*``: display-only event rendering; the model still receives the message unchanged. ``prelude``: scripted tool calls played before the first model call (``agent/turn_scripted_prelude.py``).NFz&per-turn env credential refresh failedTrTrrrrrestore_or_build_system_promptinstall_safe_stdiosanitize_surrogatessummarize_user_message_for_logr=r>ra moa_activer)begin_voice_turn_routerrrB_codex_app_serverrIrcontinueriz:api:)erB)rr2rGrJ)Rr_last_compaction_in_place"_last_compression_attempt_recorded"_last_compression_attempt_in_placebegin_fast_mode_turn#_try_refresh_env_client_credentialsrZr[r\r"rrrr r=r>rrYr!ragent.voice_turn_routerrhrVset_delivered_interim_texts_incremental_persistence_failed_last_persistence_error_cause_compression_adoption_failed_ephemeral_reasoning_off_auth_pool_refresh_counts_last_turn_usagerrWrr _CTX_FIELDSlstripapi_moderr'rrmax_iterationsiteration_budget remaining_budget_grace_callrr5rr6r9r8rr3rt_api_max_retriesrrrr%r\rrr-rr_current_api_request_idrr4r;rrr<r1r7r2rrrrupdate#_COMPRESSION_TIMEOUT_FINAL_RESPONSE)rBrrrr r rr rrrrrrr_ctx_preflight_timeout_excrrrr_prelude_action_prelude_result_pg early_result_rs_ri_vr!rrs&&&&&&&&&&&&&&& rL_run_conversation_turnrDWs-69P : 6 "6 RWVE#e&N/3E,5N 113 ^! w 3I '@ +H  &>  $  ,K  3 !5 ,K !4 &>  J'! " 2# .> 6ummTMfMf gD&)UE",1E)*.E').E&%*E"&(E#!E % 2< !(0JA!N ?EZ>P j>PTUTZTZ^iTi 416674s!34 4>P j A ~~++AWX]_`Aa1a0n'3E1g'F$O_(" W $  E00 0U5K5K5U5UXY5Y^c^v^v^v oua 0 7 77 B $eQ/'2+UA6 :: !::  ::  :: # $eQ/9=aI_I_6!->L>NPVX\^b>b;!/1:q|>?ii[aN^N^M_;``58*5!4  # -ua8 ::  :: #  5ua@CzzX%zz!zzZ'"#"5"5"@"@"@FZ\acdByyH$yy yyG#yyJ&'5%%m4??%?D47? ga?%F '''  ?ei j Mk N = MN0 (^(0FH\]]^2 kn 15!qAHHGST  %syR+A SS9 84S9 2-S> S>4AS>S>S> U )U +"SS S6 S1+S61S6> T> "T99T>cTV^8dQhRRRRRRRRRR R R R R RRRRRRRRRRRRRRRR/#)rArrrrrrr r r rr r rrrrrjrrrrrrrIr+rJ)rKs"rLrMrMs99996 9  9 ( 9(9,9 -9$<9,9)9*9&99 !9rNc|^RIHp^RIHp^RIHpRVnV!V4;_uu_4\VVVVVVVVVV V V V V VR7pV!V4RRR4V!VXV4p\V\4'd\\VRR44VR&\VV4V# T!T4i;i +'giLd;i) uRun one turn (see ``_run_conversation_turn``) and export the current-turn boundary. Every envelope that leaves the loop — success, partial/error, interrupt, retry-exhausted, tool-limit, preflight timeout, codex runtime — passes through here, so the ``{turn_id, current_turn_user_idx}`` pair is stamped beside the exact ``messages`` it addresses, after every history rewrite including post-turn micro-compaction. )export_current_turn_boundary)end_voice_turn_route)native_turn_imagesF) rrr r rr rrrrrrrN_turn_user_interveneduser_intervened) agent.turn_contextrGr'rH!tools.vision_tools_history_budgetrIrJrDrXrxrYrW_close_durable_failed_turn)rBrrrr r rr rrrrrrrrGrHrIrs&&&&&&&&&&&&&&& rLrun_conversationrOs0@;D#(E L ) ) (+-%9 /%9'=*C.K)A%'#5F$ ! ') ***% FF&$$(8OQV)W$X !uf- M ! ') * )s"B+BB+ B((B++ B; ic V^8dQhRRRR/#)rArrxrIrJ)rKs"rLrMrM8s...$.rNc^RIHpT!YP;'gRVP;'gRR7p\VPR4;'gR4P4R\pRV3R V33UUu/uFwrVV'gKWVbK ppp\V4# \d\ P RRR7RpLi;iuuppi) aMThe error text and ``error_surface`` a client needs to redraw the failed turn's error card from the transcript, after the live ``message.complete`` frame is gone. Every string is redacted with ``force=True``: the error came from a provider/tool, so a secret echoed in it must not reach the durable store (the redaction e2e boundary).)build_error_surface_from_resultrQrpz%failed-turn error surface unavailableTrTNr error_surface) agent.error_surfacerRrrrZr[r\rFryr_FAILED_TURN_ERROR_MAX_CHARS_redact_display_metadata)rBrrRsurfacerrrmetadatas&& rL_failed_turn_display_metadatarY8s D1 ^^11r9J9J   7#))r * 0 0 23P4P QE#*E"2_g4N!OU!OST!OHU #H --   C C #$C  C c V^8dQhRRRR/#)rArXrxrIrJ)rKs"rLrMrMKs88t88rNcaa^RIHoVV3RloVP4UUu/uFwrVS!V4bK upp#uuppi)aForce-redact every string in a display_metadata payload (dicts and lists included). display_metadata is persisted via ``SessionDB.append_message`` and re-delivered to clients, so it sits downstream of the turn's own content redaction: an error string that escaped a provider or tool would otherwise reach the 'store' and 'export' sinks verbatim. ``force=True`` keeps the boundary closed even when ``security.redact_secrets`` is off, matching the compressor's persistence boundary.)redact_sensitive_textc<<\V\4'd S!VRR7#\V\4'd,VP4UUu/uFwrVS!V4bK upp#\V\4'dVUu.uF pS!V4NK up#V#uuppiuupi)T)r")rXrFrxrr)rrr_redactr\s& rLr^)_redact_display_metadata.._redactUs eS ! !(d; ; eT " ".3kkmT3U3Uzz*+/AA ::j)  t`J(D))RZz  5-u 5 59T9TU_9`h|9|  23,6uc,B,BqEGaTWX`TaGa(go K,>},M~_w 4EB B7 B+2' (x* ++H5 H 7$ GHs<+F F F F 5AF = F -F :BF "F21F2rO>message_contentmessage_sanitizationagent_runtime_helpersrrrr_i)lock> rrhrrrrrVrrrrr) NNNNNNNNNNNNN)__conditional_annotations__r __future__rrrloggingrert dataclassesrrrtypingrrrr (agent.agent_runtime_helpers_placeholdersr rVr agent.fast_moder r%agent.message_metadatar ragent.message_sanitizationrrrcrragent.process_bootstraprrrrr{rrrragent.repetition_guardrragent.runtime_cwdragent.surface_switchrrrr rLr!r"2hermes_cli.observability.shared_metrics_efficiencyr#r$agent.turn_retry_stater%agent.turn_scripted_preluder&r'agent.turn_api_callr(r)r*agent.turn_api_errorr+agent.turn_api_requestr,agent.turn_failure_copyr-r.r/r0agent.turn_final_responser1agent.turn_finalizerr2agent.turn_iteration_prepr3r4r5r6agent.turn_loop_errorsr7agent.turn_preflight_gater8agent.turn_request_assemblyr9agent.turn_response_checkr:agent.turn_response_intaker;agent.turn_tool_roundr<hermes_loggingr=tools.skill_provenancer>utilsr? getLoggerrr[compile_STALE_MARKER_RErrzr^rfrrr_HANDOFF_SKIP_FINAL_RESPONSEr:"INTERRUPT_WAITING_FOR_MODEL_PREFIXr frozenset_LOCAL_PROCESSING_MODULES_API_CALL_MODULES_MAX_OUTER_LOOP_ERRORSrrrrrrrrrrrr rrr(r+r3r7rFrKrOrorrrrrrrrrr(_LEGACY_LENGTH_CONTINUATION_NETWORK_STUBrr_CODEX_INCOMPLETE_NUDGE_CODEX_ACK_CONTINUATION_NUDGE_DEGENERATE_FINAL_NUDGE_DROPPED_TOOLCALL_NUDGE_CONTENT_EMPTY_TOOL_RESPONSE_NUDGErrrrrrrr!r'r.r3r?rJrSrXr]rarfrrrrrrrr0rrrrrrDrOrUrYrVrN__all__)rps@rLrs*#  00,,UI>MXU7U V/Ph1=^]14qq:. ;8<8?0.;'   8 $::?@U _]: S F$ &_j$&["&' 89: ;B8  '%T   <<0 %&I  5UZ5p UZ  6.b#"#AQ#L\a$N ?QV ?",.>K\BE"\" \) -P) g"6"BN 0%'>&.*#. I  F8(  g7 1-AE1--11-cg1-h /d UY & 4& O"O" O"f #% $.y:_9`/ab*@$_D9x $.&8,,H^  rN