+ iHj2 a0t$Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RI H t ^RI H t ^RI HtHtHtHtHtHt^RIHt^RIHt^RIHt^R IHt^R IHt^R IHt ^R I!H"t"^R I#H$t$^RI%H&t&H't'H(t(^RI)H*t*H+t+H,t,^RI-H.t.^RI/H0t0H1t1^RI2H3t3]Ph!]54t6RRlt7RRlt8RRlt9RRlt:RRlt;RRltR#R$lt?R%R&lt@R'R(ltAR)R*ltBR+R,ltC]D!R-04tER{R.R/lltFR0R1ltGR2R3ltHR4R5ltIR6R7ltJ!R8R9]K4tLR:R;ltMR<R=ltNR>R?ltOR@RAltPRBRCltQRD^/RERFlltR] !RGRH44tSRIRJltTRKRLltURMRNltVRORPltWR|tXRR]YRS&RTRUltZRVRWlt[RXRYlt\RZR[lt]R{R\R]llt^R^R_lt_R`Ralt`RbRcltaRdReltbRfRgltcR{RhRilltdRjRklteRlRmltfRnRoltgR}RpRRqRRrRRsRQRtR/RuRvlllthRwRxltiRyRzltjR#)~aPer-turn setup for ``run_conversation`` (the turn prologue). ``build_turn_context`` runs the once-per-turn setup (stdio guard, sanitization, prompt restore-or-build, session row, idle/preflight compaction via ``turn_context_compaction``, pre_llm_call hook, prefetch, persistence), mutating ``agent`` as the loop expects, and returns a ``TurnContext`` with only the locals the loop reads back. ``build_api_messages`` builds the wire copy for one API call.) annotationsN)suppress) dataclass)AnyDictListMappingOptionalTuple)#recover_rotated_compression_session)IterationBudget)build_memory_context_block)is_trivial_promptflatten_message_text)forward_to_agent)pop_plugin_notices)stage_skills_index_note)PERSISTENCE_ONLY_MESSAGE_FIELDSappend_messagestamp_message_timestamp)estimate_messages_tokens_rough.estimate_native_anthropic_request_tokens_roughestimate_request_tokens_rough)bind_image_token_cost)anchored_context_tokensrestore_usage_anchor)parse_turn_authorc$V^8dQhRRRRRR/#)agentrnamestrreturn)formats"7/home/ubuntu/.hermes/hermes-agent/agent/turn_context.py __annotate__r')s!**S***c.\WR4;'gR#)uS``getattr(agent, name, "") or ""`` — route facts read off partial agents/doubles.getattr)r r!s&&r& _str_attrr-)s 5 # ) )r)r(c(V^8dQhRRRRRRRR/#) rr rmessageslist[dict[str, Any]] system_promptr"r#intr$)r%s"r&r'r'.s,00 0.0?B00r(c\V\VRR44pVRJVnVeV#\VRR4;'gRp^RIHpT!YT;'gRVR7p\ V\ 4'd \ V\4'g V^8dV#\T4pTpT'd\TR R4R 8Xd^R I H p T !\TR R4\TRR44'dX^RIHp TU u.uF&p \ T \ 4'd \!T 4MT NK( pp T !Y4\#Y;'gRTR7#\%Y;'gRTTR7# \d\PRRR 7Li;iuup i)zToken estimate for automatic preflight compression: a valid provider usage anchor, else the checkpoint-pruned native wire payload, else the generic estimator. _usage_anchorNtools)*estimate_native_responses_preflight_tokensr*)r1r5zRnative Responses preflight estimate unavailable; using generic transcript estimateTexc_infoapi_modeanthropic_messages))native_anthropic_preserves_prior_thinkingbase_urlmodel#apply_rejected_thinking_suppression)r1r5charge_stale_thinking)rr,_request_pressure_anchoredagent.codex_responses_adapterr6 isinstancer2bool Exceptionloggerdebug_agent_stale_thinking_on_wireagent.anthropic_thinking_policyr;agent.anthropic_thinking_replayr?dictrr) r r/r1anchoredr5r6nativer@estimate_messagesr;r?messages &&& r&_preflight_request_tokensrP.s 'xQU1VWH'/t';E$ E7D ) 1 1TE  \; =+>+>Be  fc " ":fd+C+CRS M:%@  B!?CW!W] 4 E:r *GE7B,G   \ (!'G",GT!:!:W G' ! 0 IA!1D1D"E  ))<)<"E3 7    0   &!sE=E+,E8"E54E5c V^8dQhRRRR/#rr rr#rDr$)r%s"r&r'r'as    r(cVa^RIHpV!V3RlR4!# \dR#i;i)z{Whether the active route replays stale thinking text; ``True`` (conservative full charge) when route facts are unavailable.)stale_thinking_reaches_wirec3<<"TFp\SV4xK R#5iN)r-).0kr s& r& 0_agent_stale_thinking_on_wire..hs Y+Xaiq!!+XsT)r9providerr=r<)agent.message_sanitizationrTrE)r rTsf r&rHrHas5J* Y+X Y   s  ((c$V^8dQhRRRRRR/#)rext_prefetch_cacher"plugin_user_contextr# Optional[str]r$)r%s"r&r'r'ns$;;;25;;r(cV'd \V4MRpW!3Uu.uFq3'gK VNK ppV'dRPV4#R#uupi)zThe ephemeral context of one turn (memory prefetch + ``pre_llm_call``) as one text block; ``None`` when nothing is injected. The string sidecar appends it to ``content``; a multimodal (list) turn carries it as a durable text part (#71998).r* N)r join)r^r_fencedpart injectionss&& r&compose_multimodal_context_partrgnsP @R '(: ;WYF$*#@I#@4D$$#@JI&06;;z ":d:Js A A c(V^8dQhRRRRRRRR/#)rcontentrr^r"r_r#r`r$)r%s"r&r'r'ys2 G G  G&) G@C G Gr(ct\V\4'gR#\W4pVfR#VR,V,#)a6Compose the API-bound content of the current turn's string user message. Single source for the ``api_content`` sidecar and the wire bytes so they never drift (what turn N sends is what turn N+1 replays). ``None`` when nothing is injected or the content is not a string (list content takes the text-part path).Nrb)rCr"rg)rir^r_ injections&&& r&compose_user_api_contentrlys9 gs # #/0BXI$4F'F*:Y*FFr(c V^8dQhRRRR/#)rapi_msgdict[str, Any]r#r`r$)r%s"r&r'r'sN}r(cVPRR4p\V\4'd#V'dVPR4R9dWR&V#)zPop the ``api_content`` sidecar and substitute it into ``content`` (keeps the prompt-cache prefix byte-stable). Returns the popped sidecar, or ``None``. api_contentNroleriuser assistant)poprCr"get)rnsidecars& r&substitute_api_contentrysAkk-.G'3G F0CG\0\$  Nr(c V^8dQhRRRR/#)rmsgror#Noner$)r%s"r&r'r's!!!4!r(c*VPRR4R#)zDrop the ``api_content`` sidecar from a message whose content was rewritten (replaying it would resend what the rewrite removed; cost is one cache miss).rqN)rv)r{s&r&drop_stale_api_contentr~sGGM4 r(c V^8dQhRRRR/#)rr{zMapping[str, Any]r#r`r$)r%s"r&r'r's--%6-=-r(cXVPR4p\V\4'dV#R#)zEExtract the ``api_content`` sidecar; ``None`` when absent/non-string.rqN)rwrCr")r{vs& r&extract_api_content_sidecarrs'  A1c""1,,r(c$V^8dQhRRRRRR/#)rr rattrr"r#r$)r%s"r&r'r's!11#1S1S1r(c\WR4;'gRp\W4'd-\\4;_uu_4\ WR4RRR4\ V\ 4'dV#R# +'giL*;i)z}One-shot per-turn note: read and clear, so the system prompt stays byte-stable and a cached agent never replays a stale note.r*N)r,hasattrrrEsetattrrCr")r rnotes&& r&_pop_turn_noters] 5 # ) )rDu i E $!dC((40b0! s A.. A> c V^8dQhRRRR/#rr rr#r"r$)r%s"r&r'r's@@c@c@r(c\VR4#)z.Pop the gateway's per-turn must-deliver notes._gateway_turn_context_notesrr s&r&"consume_gateway_turn_context_notesrs %!> ??r(c V^8dQhRRRR/#rr$)r%s"r&r'r's99s9s9r(c\VR4#)zPop the surface-switch note staged by the system-prompt restore (#104414); rides the same user-message channel as the gateway notes, behind the cached prefix._surface_switch_noterrs&r&consume_surface_switch_noters %!7 88r(c V^8dQhRRRR/#rr$)r%s"r&r'r's77S7S7r(c\VR4#)zVPop the skills-index delta staged by the system-prompt restore; same channel as above._skills_index_noterrs&r&consume_skills_index_noters %!5 66r(c$V^8dQhRRRRRR/#)rrirnotesr`r#rDr$)r%s"r&r'r's!Mdr(cV'd\V\4'gR#\\4;_uu_4VP RRRV/4RRR4R# +'giR#;i)zAppend must-deliver notes as a durable text part on a multimodal (list) user message (the sidecar path returns ``None`` for non-string content).FtypetextNT)rClistrrEappend)rirs&&r&"append_notes_to_multimodal_contentrsM  7D11 )  67     s A A* cronc(V^8dQhRRRRRRRR/#) rr rr/ list[Any]title_user_messager`r#r|r$)r%s"r&r'r's8GMGM GM#GM9FGM GMr(c aa\SRR4p\SRR4pV'd V'gR#\\SRR4;'gR4P4pV\9dR#^RIHp^RIHpHpRp Rp \T;'g.4Fp \V \4'gKV PR4R 8XgK3V!V PR 44P4p V PR 4p \V \4'd/\V PR 4\4'd V R ,p M VeVP4p V 'gR#\SR R4'g;\SRR4p \V 4'dV !4\SR R4'gR#VR8Xd V!W4V 4R#RUu/uFpV\SVR4bK upoT!TTT T\SRR4;'g\SRR4S\SRR4VV3RlV R7 pVeVPf VSnR#R#R#uupi \"d\$P'RRR7R#i;i)zHKick off auto-titling for the session's first user message; never fatal. _session_dbN session_idplatformr*r)apply_subagent_titlemaybe_auto_titlerrrtridisplay_metadata title_preview_session_db_createdF_ensure_db_sessionsubagent_title_failure_callback_emit_auxiliary_failure_on_session_titlecp<\SRR4SR,8H;'d\SRR4SR,8H#)r=Nr[r+)r main_runtimesr&4_maybe_title_session_at_turn_start..sAw-g1FFQQE:t4 Z8PPQr()conversation_historyfailure_callbackrtitle_callbackruntime_validatorrz%Turn-start auto-title dispatch failedTr7)r=r[r<api_keyr9r)r,r"lower_UNTITLED_PLATFORMSagent.message_contentragent.title_generatorrrreversedrCrKrwstripcallableident_deferred_title_upgraderErFrG)r r/r session_dbrrrrr user_textrr{metadataensurerXupgradersf&& @r&"_maybe_title_session_at_turn_startrsB t4J d3J Z75*b177R8>>@H&&<M>P  HNN+C#t$$F)B01CDJJL 77#56h--*X\\/=Z\_2`2`$,_$=M ,  )*002I u3U;;U$8$?F5"7?? z !  C \ [ wua& &[ #   !)8$?CC5";TB%"5*=tD( &  7==#8,3E )$9 1 4 M I8AI>I"I)(I)c V^8dQhRRRR/#rr rr#r|r$)r%s"r&r'r's!!!!r(cV\VRR4pVfR#RVn^RIHpV!V4R#)zYFire the title upgrade ``_maybe_title_session_at_turn_start`` held back; no-op when none.rN)start_title_upgrade)r,rrr)r rrs& r&start_deferred_title_upgraders,e6=G$(E!9 r(c$V^8dQhRRRRRR/#)rr/r user_messagerr#r2r$)r%s"r&r'r's!$$Y$c$c$r(cd^RIHpRp\\V4^, RR4FpW,p\ V\ 4'dVP R4R8XgK9VP R4V8XdVu#V!V4pVfKaVP R4V8XdVu#V^8gKTpK V#)uLocate this turn's user message after compaction rebuilt ``messages``. Prefers the LAST user message whose content exactly matches this turn's text, else the last user-originated turn; compaction handoffs are never the fallback. Returns -1 when there is no user-originated message. Compression replaces list entries with fresh copies (and may append a todo-snapshot user message or a restored user turn AFTER the surviving copy of the current turn's message), so a pre-compression index is meaningless. Prefer the LAST user message whose content exactly matches this turn's text — the surviving copy in the common case — so the injection stamp and the #48677 persist override can't land on a todo-snapshot or historical row. Fall back to the last *user-originated* turn when no exact match survives (merge-summary-into-tail rewrites the content but the trackers still need a live anchor). Compaction handoffs must never become the fallback anchor (#80622) — they are reference-only scaffolding, not the active ask. user_originated_turn_viewrrrtri)agent.context_compressorrrangelenrCrKrw)r/rrfallbackir{ live_views&& r&reanchor_current_turn_user_idxrs CH 3x=1$b" -k3%%#''&/V*C  779  -H-c2    == #| 3H a<H!." Or(c(V^8dQhRRRRRRRR/#)rr rresultrr#r$)r%s"r&r'r'As)###S##PS#r(ct\V\4'dVPR4R8XdV#VPR4p\\ VRR4;'gR4p\V\ 4'd V'dVfV#\ W24pV^8gV\V48dV#W5,p\V\4'dVPR4R8XgV#^RIH pV!V4pVPR 4V8wd/\V\4'dVPR 4V8XgV#WAR &WQR &V#) a>Stamp ``{turn_id, current_turn_user_idx}`` on a result envelope, proven against the exact ``result["messages"]`` projection it travels with. Hosts that settle their own transcript by index (hermes-webui) must never guess which row is the current user turn after this loop rewrote history (alternation repair, compaction, post-turn micro-compaction): a guessed index or a text match can relabel an identical historical prompt and claim its old answer as this turn's. So the producer exports the coordinate, computed on the final list, only when the addressed row is this turn's user message verbatim. Otherwise the keys are omitted and hosts fail closed. A preflight-timeout envelope carries the prior history without this turn's row (#7100), so a repeated prompt would resolve to its historical copy: nothing is exported there. turn_exit_reasoncontext_compression_timeoutr/_current_turn_idr*rrrtrriturn_idcurrent_turn_user_idx) rCrKrwr"r,rrrrr) r rrr/ridxrowrrs &&& r&export_current_turn_boundaryrAs  fd # #vzz2D'EIf'f zz*%H'%!3R8>>B?G h % %W 8L ( @C Qw#X& -C sD ! !cggfo&? B)#.I wwy\)9d## i(@L(P 9&) "# Mr(c ,V^8dQhRRRRRRRRRR/#)rorig_lenr2new_len orig_tokens new_tokensr#rDr$)r%s"r&r'r'gs;WWWW.1W?BW Wr(cJW8;'gV^8;'d W2R,8#)uu``True`` if a compression pass materially reduced the request: fewer rows, or a >5% token cut with the same rows (same floor as the overflow-handler retry). Compression can succeed by summarising message contents — reducing the estimated request token count — without reducing the message row count. Treating row count as the sole progress signal false-positives on size-only wins and surfaces a misleading "Cannot compress further" failure even when post-compression tokens are well below the model context window. See issue #39548 for an observed case: 220 → 220 messages, ~288k → ~183k tokens on a 1M-context model still triggered auto-reset. The token reduction must be *material* (>5%) to count as progress — the same floor the overflow-handler retry path uses (conversation_loop.py, 39550) — so a sub-5% wobble doesn't keep the multi-pass loop spinning. See #39550. ffffff?r$)rrrrs&&&&r&compression_made_progressrgs*   V V+/"U"UjQUCU6UVr(c]tRtRtRtRtR#)PreflightCompressionTimedOutiyz=Raised when an oversized turn cannot safely finish preflight.r$N)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r$r(r&rrysGr(rc V^8dQhRRRR/#rrequest_tokensr2r#r|r$)r%s"r&r'r'}sr(c^RIHpHpV!V4'gR#V!W4RJd2\P RVR VP P R 4R#\RVR R24h)uStop an oversized turn instead of sending its unchanged provider payload. Only a request the model cannot accept (above its context window, or of unknown fit) is stopped: a request that merely sits above the compression threshold is sent unchanged, exactly as the cooldown-blocked path sends it every turn — otherwise a slow summariser turns a session that still fits its window into a turn that can never run (#113646, #114594).)context_compression_timed_outrequest_exceeds_model_windowNFzzPreflight compression timed out but the request (~%s tokens) fits the model window (%s); sending it uncompressed this turn,z_Context compression timed out before it could commit while the request was still approximately z] tokens. The provider call was not sent. Run /compress and wait for it to finish, then retry.)agent.conversation_compressionrrrFwarningcontext_compressorcontext_lengthr)r rrrs&& r&$_fail_closed_after_preflight_timeoutr}sz k ( / /#E:eC 0a e&>&>&M&Ma%P  & ##1!"45M M r(c V^8dQhRRRR/#rr$)r%s"r&r'r'sr(c^RIHpHpV!W4RJdR#V!V4'dR#VPPp\ RVR RVR R24h)uDStop an over-window turn the moment preflight proves it cannot shrink the session, with "start a new session" guidance, instead of sending a request the model cannot accept. ``_fail_closed_after_preflight_timeout`` only stops a turn whose compression wait timed out. A pass that ran and reclaimed nothing (or under 5%) on a request still above the model window used to fall through to the provider call: the provider rejected it, the overflow handler forced another compression pass, and each pass re-waited its budget while the UI sat blocked (#116472: ~356k tokens on a 131k window). Only a ``True`` verdict fails closed — an unknown window or a fitting request keeps the send-as-is behaviour — and a pass skipped by the summary-failure cooldown is a defer, not proof of incompressibility, so it keeps its typed cooldown result. )compression_blocked_transientlyrTNzTContext compression could not bring this session under the model's context window (~rz tokens vs zp). The provider call was not sent. Start a new session with /new; this session is too large to compress further.)rrrrrr)r rrrwindows&& r&%_fail_closed_on_insufficient_progressrsem#E:$F&u--  % % 4 4F & A k&4^ ^ r(c V^8dQhRRRR/#rRr$)r%s"r&r'r'scdr(cb\\VRR4;'d\VRR4'*4#)zWhether a detached review fork has yet to send its first provider request: it replays the parent's FULL snapshot as a warm cache read, so compaction must wait for that first response. Dormant without the attribute.._review_defer_compaction_before_first_responseF _turn_received_provider_response)rDr,rs&r&"_review_fork_first_request_pendingr s: GO J JA5I I r(c(V^8dQhRRRRRRRR/#)rrr2rthreshold_tokensr#rDr$)r%s"r&r'r's2bbb"%b9<b br(cJW8;'dV^8;'d WR,8#)z_Another immediate summary only if still over threshold AND the previous pass cut tokens by >5%.rr$)rrrs&&&r&,_compression_warrants_another_preflight_passrs*  ) a akAo a a*]aOaBaar(c ,V^8dQhRRRRRRRRRR/#) rr/r0protect_first_nr2protect_last_nrr#rDr$)r%s"r&r'r's4  " 58 JM ad   r(cd\V4W,^,8;'g\V4V8#)a!Cheap gate for the (expensive) full preflight estimate: message count exceeds the protected ranges OR a rough char-based estimate crosses the threshold (few-but-huge case). The estimator undercounts by design (omits system/tools) so one large base64 image is not mistaken for ~250K tokens.)rr)r/rrrs&&&&r&_should_run_preflight_estimaters7 H 81<< H H )( 37G Gr(last_compaction_tokensc8V^8dQhRRRRRRRRRRR RR RR R/#) renabledrDidle_after_secondsr2idle_gap_secondsfloattokens floor_tokenscooldown_activerr#r$)r%s"r&r'r'sN$$$*-$AF$PS$$(,$FI$ $r(c~V'dV^8:gW!8g V'dR#TpV^8d\WvV,4pW78#)ugPure predicate: idle compaction fires after a wall-clock gap of ``idle_after_seconds`` (opt-in, <= 0 disables), independent of ``threshold_tokens``; never at/below ``floor_tokens`` or during a compression-failure cooldown. ``floor_tokens`` (``threshold_tokens × summary_target_ratio``) is a theoretical target a real pass routinely misses (system prompt, tool schemas and protected head/tail are incompressible), so a session compacted to above it would re-summarise on every idle resume without growing. ``last_compaction_tokens`` — what the previous pass actually produced (``ContextCompressor.last_compression_rough_tokens``, same rough shape as ``tokens``) — raises the floor to ``last + floor_tokens`` so the transcript must gain a floor's worth of NEW content first. ``0`` (nothing compacted yet / counter reset) keeps the original semantics exactly. A session that compacted to well above that target therefore stays above it forever, so every later idle resume re-runs a full summarisation over a transcript that has not grown — minutes of silently blocked prompt on a slow route, reclaiming nothing (#97239). F)max)rrrrrrreffective_floors$$$$$$$ r&_should_idle_compactr#s@* (A-1A1VZi"O!o /TU  ##r(c]tRtRt$RtR]R&R]R&R]R&R ]R &R ]R &R]R &R]R&R]R&RtR]R&RtR]R&RtR]R&Rt R]R&Rt R#) TurnContextizCValues produced by the turn prologue and consumed by the turn loop.r"rroriginal_user_messager0r/Optional[list[dict[str, Any]]]rr`active_system_prompteffective_task_idrr2rFrDshould_review_memoryr*r_r^preflight_compression_blockedr$N) rrrrr__annotations__r*r_r^r+rr$r(r&r%r%s`M""88'' L!&$&!!  */!4/r(r%c(V^8dQhRRRRRRRR/#)rr r failure_msgr"pending_cli_messager#r|r$)r%s"r&r'r's)33s3S3s3W[3r(c\VRR4pVf V!4MV;_uu_4V!4RRR4\ V\ 4'dVPR4'd RVnR#R# +'giLH;i \d/\PY P;'gRRR7Li;i \ T\ 4'dTPR4'd RTnii;i)uGRun ``fn`` under the session persist lock (when the agent has one), log-and-swallow failures, then drop staged CLI input — unless it is an unmarked handoff kept for a close retry (once ``_db_persisted`` the close path must not treat it as pre-worker UI input). Eager clearing keeps a preflight crash from leaking stale input._session_persist_lockNnoneTr7 _db_persisted) r,rErFrrrCrKrw_pending_cli_user_message)r fnr.r/locks&&&& r&_persist_under_lockr7s 3u5t< < D -t448K8O8OP_8`8`.2E +9a  O{$4$4$>$>NO-t448K8O8OP_8`8`.2E +9as[BB< BA-B- A= 8B<B<=B,B9- B96B<8B99B<<-C3* C3c V^8dQhRRRR/#rr$)r%s"r&r'r's    r(c*\\4;_uu_4^RIHp^RIHpV!V4;'gRpT!\ VR4\ VR43/RUu/uFqD\ W4bK upBRV/BRRR4R#uupi +'giR#;i) zTell auxiliary_client the live main provider/model for this turn (after primary restoration settled the runtime). Never raises: failure loses only the scope.)set_runtime_main)resolve_prompt_cache_scope_safer*r[r= cache_scopeN)requested_providerr<rr9 auth_moder)rrEagent.auxiliary_clientr:agent.prompt_cache_scoper;r-)r r:r; _cache_scoperXs& r&_publish_runtime_mainrBs )  ;L7u=CC  eZ ()E7*C 00!)E%%0 %       s=BA<) B<B B c V^8dQhRRRR/#rr$)r%s"r&r'r'(sNNCNDNr(cDR\P9d^RIHpV!V4\ VRR4'g@R\P9d)^RIHp^RIHpV!4'dV!VRRR 7R #R #R #R # \d\PR RR 7R #i;i) zLate-connecting MCP servers land in THIS turn's snapshot, before the first API call assembles ``tools=``. ``preserve_prefix`` keeps the tool array append-only so a flapping ``check_fn`` can't fork the cache.ztools.connectors.mcp)adopt_late_connections_skip_mcp_refreshFztools.mcp_tool)has_registered_mcp_tools)refresh_agent_mcp_toolsT) quiet_modepreserve_prefixz&between-turns MCP tool refresh skippedr7N) sysmodulestools.connectors.mcprEr,tools.mcp_tool_discoveryrGtools.mcp_tool_agentrHrErFrG)r rErGrHs& r& _refresh_mcp_tools_between_turnsrP(sN "S[[ 0 C "5 )u1599>NRUR]R]>] I D'))'$PTU*?^9 N = MNsA#A9& A99"BBc 0V^8dQhRRRRRRRRRRR R /#) rr rtask_idr`persist_user_messagepersist_user_timestampOptional[float]persist_user_platform_idr#ztuple[str, str]r$)r%s"r&r'r'=s>&& &&&OR&+>&&r(cW nRVnW0nW@nWPnT;'g\ \ P!44pW`n0\VRR 4mVkVn \ \VRR4;'gR4;'gCVP;'gR RV R\ P!4PR, 2pRVn WpnRVn^RIHpV!W4Wg3#) zStage callback/persist overrides on the agent and bind this turn's task and turn ids. Returns ``(effective_task_id, turn_id)``.N_process_owner_task_ids_relay_pending_turn_idr*session::NN)note_turn_startr$)_stream_callback_persist_user_message_idx_persist_user_message_override_persist_user_message_timestamp!_persist_user_message_platform_idr"uuiduuid4_current_task_idr,rXrhexrYr_current_api_request_idagent.agent_runtime_helpersr]) r rRstream_callbackrSrTrVr)rr]s &&&&&& r&_bind_turn_identityrj=s -&*E#+?(,B).F+443tzz|#4.$gge5NPR&S$gUf$gE!'%!92>DD"E    ( (y )+<*=Qtzz|?O?OPR?S>TU $(E $$&E!<E#  %%r(Fztuple[tuple[str, Any], ...]_PER_TURN_RESET_STATEc V^8dQhRRRR/#rr$)r%s"r&r'r'ms--s-t-r(c\Fwr\WV4K /Vn\4VnVP P 4\VPRR4p\V4'dV!4\P!4Vn VPR8wdH\\4;_uu_4VP4'dVP!R4RRR4\\4;_uu_4^RIHpV!V4RRR4VP&'dVP)4RVn\VRR4'dVP+4\-VP.4Vn\VRR4'd\P!4MRVnRF%p\WR4pVfKVP54K' R# +'giEL;i +'giL;i) zJReset retry counters, guardrails, iteration and run budgets at turn start.reset_consolidation_failuresNr:u~🔌 Detected stale connections from a previous provider issue — cleaned up automatically. Proceeding with fresh connection.)retry_recovered_local_server_pending_startup_noticesrun_budget_seconds)_stream_context_scrubber_stream_think_scrubber)rkr_turn_failed_file_mutationsset_turn_file_mutation_paths_tool_guardrailsreset_for_turnr, _memory_storertime_current_turn_timestampr9rrE_cleanup_dead_connections_emit_diagnostic_statusagent.chat_completion_localro_compression_warning_replay_compression_warning_replay_startup_warningsr max_iterationsiteration_budget_run_budget_started_atreset)r r!value _reset_consolroscrubbers& r&_reset_per_turn_agent_staterms, U#-(*E%&)eE# ))+E//1OQUVM  %)IIKE! ~~-- i ..00--"! )  L$U+  !!! ))+%)"u0$77 &&(,U-A-ABEu&:DAA t  G5-   NN G1!   s=(GG1 G. 1 H c8V^8dQhRRRRRRRRRRR RR R R R /#)rr rrrSrTrUrVr`persist_user_display_kindpersist_user_display_metadataOptional[dict[str, Any]]r#ztuple[dict[str, Any], Any]r$)r%s"r&r'r'sR')') ')!')9<')+')GT') -')$< ')  ')r(c6\VRR4pVeTMTp\V\4'dVPR4V8XdTp WR&M#RRRV/p \V\4'dRVn\ WR7V'dWYR&V'dWiR&VeWIR &W3#) zBuild this turn's user dict, reusing CLI-staged input only when its clean text matches this turn (a stale handoff must not replace later input; voice turns compare the clean override). Returns ``(user_msg, pending_cli_message)``.r4Nrirrrt) timestamp display_kindrplatform_message_id)r,rCrKrwr4r) r rrSrTrVrrr/expected_persist_contentuser_msgs &&&&&&& r&_stage_turn_user_messagers"%)DdK 4 @l &--  # #I .2J J&+FI|< )4 0 0.2E +HG!#< $'D#$ +*B&'  ((r(c$V^8dQhRRRRRR/#)rr rrOptional[list[Any]]r#r|r$)r%s"r&r'r's(,\,\,\.s"Z*>Q%%-SYBYqq*>s( () _todo_store has_items_hydrate_todo_store_user_turn_countrr,rrBragent.usage_anchorrrErFrGsum_memory_nudge_interval_turns_since_memory)r rnote_checkpointrrprior_user_turnss&& r&_hydrate_from_historyrs-     & & ( ( !!"67  " U9! E/ 6 /   O $ $ ?$%D$UD1 Z*>ZZ a %5 "++a/E4M4MQR4R,V;P^, unVPVP8d ^VnR#R#)zRAdvance the turn-based memory nudge counter; ``True`` when the review should fire.memoryTF)rvalid_tool_namesryrrs&r&_tick_memory_nudgers] $$q(E222### !!Q&!  $ $(D(D D()E % r(c(V^8dQhRRRRRRRR/#)rr rr&rr`r#r|r$)r%s"r&r'r's)$$#$c$$bf$r(c\VRR4pVeVR8XdR#\\4;_uu_4^RIHp^RIHpV!V4e RRR4R#V!V4pV'd V!V4RRR4R# +'giR#;i)zCosmetic side-signal: detect an affection reaction so the host can play hearts. Token-free, never touches the conversation, never fatal. Only words the user typed count: a hidden prompt or an expanded skill body is app/skill text, not affection.reaction_callbackNhidden)detect_reaction)describe_skill_invocation)r,rrEagent.reactionsragent.skill_commandsr)r r&rrrrkinds&&& r&_emit_reactionrss ':DA LH$< )  3B $%: ; G   45  d #    sA6A6$A66 B c$V^8dQhRRRRRR/#)rr rr/r#r|r$)r%s"r&r'r's!sr(c4\WPRV4R#)zCreate the DB row now (system prompt populated => non-NULL) and BEFORE preflight compression: compaction/rotation INSERTs reference this row under PRAGMA foreign_keys=ON. Idempotent; the user-turn crash persist runs later.z5Turn-start session row creation failed for session=%sN)r7r)r r/s&&r&_ensure_session_rowrs ''?ATr(c4V^8dQhRRRRRRRRRRR R R R/#) rr rr)r"rr&r/rrrr#r$)r%s"r&r'r'sF66 6&)6476PS66/B6 6r(c\VRR4'dR#^RIHpT!RVPTTT\ V4\ V4'*VP \VRR4;'gR\VRR4;'gR\VR R4;'gRR 7 p^R IHpH p V!4p .p VFp \V \4'd+V PR 4'd\V R ,4p M1\V \4'dV P4'dT p MKtV eV !WPR V R7p V P%V 4K RP'V 4# \dRp Rp Li;i \d!p\ P#RT4Rp?LaRp?ii;i \d"p\ P#RT4Rp?R#Rp?ii;i)zRun ``pre_llm_call`` plugins; their context is injected into the user message (never the system prompt). Oversized per-hook context is spilled to disk so a runaway plugin can't inflate every subsequent turn's prompt._persist_disabledFr*) invoke_hook pre_llm_callrN_parent_session_id_user_id) rrRrrr is_first_turnr=rparent_session_id sender_id)get_spill_configspill_if_oversizedcontextz plugin hook)rsourceconfigzhook context spill failed: %srbzpre_llm_call hook failed: %s)r,hermes_cli.lifecyclerrrrDr=tools.hook_output_spillrrrErCrKrwr"rrFrrrc)r r)rr&r/r _invoke_hook _pre_results _spill_cfg_spill_if_oversized_spill_config_cached _ctx_partsr_piece _spill_excexcs&$$$$$ r&_collect_pre_llm_call_contextrsu)511,<D# ''%.!%h#$899++UJ5;;%e-A4HNNBeZ6<<"   ( $.< !# A!T""quuY'7'7Qy\*As## ".P0+;+;M3F   f % {{:&&) ("& #'  ("!PNN#BJOOP <5s;; F% F%'E7<%F%"E41F%3E44F%7 F"FF%F""F%% G0G  Gc ,V^8dQhRRRRRRRRR R/#) rr rr/rrr2r_r"r#r$)r%s"r&r'r'Xs4 #.`s <?C F#&F#4F6 F # F3 6 G c4V^8dQhRRRRRRRRR RR R R R /#)rr rr/rrr2r^r"r_preflight_compressedrDr#r|r$)r%s"r&r'r'sO,t,t ,t#,t$0=! u   $$Y/2ootGEKfhmaaaRVVV3Rllp\SVRV4R#)zCrash-resilience: persist the inbound user turn once, with final api_content, before the first LLM call. Same critical section as CLI close persistence; retries the row create if the pre-compression attempt failed transiently.cV^8dQhRR/#)rr#r|r$)r%s"r&r')_persist_turn_start..__annotate__s???r(cL<SP4SPSS4R#rV)r_persist_session)r rr/sr&_ensure_and_persist0_persist_turn_start.._ensure_and_persists    " x)=>r(z:Early turn-start session persistence failed for session=%sN)r7)r r/rr/rsfff& r&_persist_turn_startr s#?? "DFYr(rrr moa_activercLV^8dQhRRRRRRRRRR R R R RR RRRRRRRRRRR/ #)rrrsystem_messager`rr'rRrSz Optional[Any]rTrUrVrrrrr!rDrr#r%r$)r%s"r&r'r' syyy.;y8yCPy(yBQy, yQ^ y $< y Ph y/3y&yyr(c  a*^RIHpV !4\V 4p Wn\ V4pVeTpT!VP 4V!\ VRR44^RIHpV!\ VRR44VP4\V4\V4\V\4'd V!V4p\V\4'd V!V4p\WWVWx4wpp\V4V!V4pVR,\!V4^P8dR MR ,pR pVP ;'gR VP"VP$;'gR VP&;'gR \!T;'g.4VP)RR4.p\ VRR4;p'dVR, pVP+V4\,P.!V.VO5!V'd \1V4M.p\3WWgWV 4wp p!\5W4\7V4\9VV 4\!V4^, p"V"VnV;P<^, unRVnVeTMTp#\AV4p$\CVV#V 4VPD'g1TPGRVR, \!V4^<8dR MR R24VPHf V !WV4TPHp%^RI%H&p&V&!V4\SVV!4^RI*H+o*V'dR\X;QJdV*3RlV4F 'gK RM RM!V*3RlV44'dVP[W34V!VVVV%VV"VVR7p'V'P\pV'P^p%V'P`pV'Pbp"\eVVVV#VVR7p(\gVV%V4\iVVV"V(4p(\kVV4\mVV#V 4p)\oVVV4^T"u;8:d\!V48dMMVV",PqR4R8Xd\VV",PqR4\04'd#\sVVV",V)V(V'PtR 7M5V'g.\ VR!R4R"8wd\wVVV"V)V(V'PtR 7\yVVVV!4\{VV#VVV%VVV"V$V(V)V'P|R#7 # \Nd\,PQRRR7EL i;i)$aDRun the once-per-turn setup and return the loop's input context. Helpers are passed in to avoid an import cycle with ``agent.conversation_loop``. Order matters: the DB session row is created only AFTER the system prompt is built (else it persists system_prompt=NULL and costs a cache miss) and BEFORE preflight compression.)run_turn_start_compactionN_memory_write_originassistant_tool)set_review_attended_review_attendedF:NPNz...r*zPconversation turn: session=%s model=%s provider=%s platform=%s history=%d msg=%rr2unknown  _turn_originz origin=%sTu💬 Starting conversation: ':N<N')ensure_message_agent_toolzmessage_agent injection skippedr7)"_PERSIST_AFTER_ADMISSION_INTERRUPTc3v<"TF.p\V\4;'dVPS4xK0 R#5irV)rCrKrw)rWr{r2s& r&rY%build_turn_context..s4$'C 3MM#''*L"MM's99)r/r#r(rrrr))r)rr&r/rrrrtri)rr9codex_app_server) rr&r/rr(r)rrr*r_r^r+)?agent.turn_context_compactionr%r _turn_authorr rr,tools.skill_provenancer(_restore_primary_runtimerBrPrCr"rjrrr=r[rreplacerrFinforrrrrr_r_is_user_initiated_turnrrrI _safe_print_cached_system_prompttools.bot_mode_dmr1rErGrrr2any_flush_messages_to_session_dbr/r(rrrrrrrrrwr compressedrr r%blocked)+r rr#rrRrirSrTrVrrrrestore_or_build_system_promptinstall_safe_stdiosanitize_surrogatessummarize_user_message_for_logset_session_contextset_current_write_originrr!rr%recovered_historyr(r)r _preview_text _msg_preview _turn_fmt _turn_argsr.r/rr/rr&r*r(r1 compactionr_r^r2s+&&&&&&&&&$$$$$$$$$$$$ @r&build_turn_contextrP s"H$K0K$+?M*R/uR8 ;  ""*&u>RS 66G?!%(23 M$'$$'$!! ++,@W* 1H\3,+ J ""H%::%::&<<7 !2G3h1E#7B. x.0C%$8@UWbc 'uh8JK !1CM1h?T6U6Y6YZ`6aek6k h4599)Dd K K &x 568JL_%/%:%: z4 @DV V &x!68J#*:O:O  x)=?RS !9NYa1H\+W3J^/DV&0&8&8  } G 6 FGsS "S21S2c$V^8dQhRRRRRR/#)rr r moa_configr#r$)r%s"r&r'r's!sr(cfVPpVPR8XdV'd<VPR4;'g/pVPR4'd VR,pW P8XdA\\VRR4RR4pV'd!VPR4'd VR,pV#)zModel name for strict-API tool-call sanitization. In MoA mode ``agent.model`` is the virtual preset name; use the resolved aggregator so Gemini keeps thought_signature (extra_content).moa aggregatorr=clientNlast_aggregator_slot)r=r[rwr,)r rR_sanitize_model_agg _agg_slots&& r&_sanitize_model_forr[skkO ~~ >>,/552Dxx  "&w- kk ) x >@VX\]IY]]733"+G"4 r(c8V^8dQhRRRRRRRRRRRRR RR R /#) rr rr/r0rr^r_rRr(r#z tuple[list[dict[str, Any]], str]r$)r%s"r&r'r'sXq*q* q*.q*JMq*q*25q*CFq*^aq*&q*r(cj^RIHp^RIHp^RIHp \ V\4;'d ^Tu;8*;'d\V48Mup V 'd W,MRp VPp V 'dTM^p V !VRV V R7WR,p.p\V4EFwppV!V4pVPRR4p\FpVPVR4K VV JdaVPR4R8XdK\ V\4'dV'dVVR &M_\VPR R 4W44pVeVVR &M9\ V\4'd$V'dVPR4R9dVVR &VP!VV4VPR R4V!VV\V4^, 8HR 7VPR R4VPRR4VP#4'd3VP%V\'W4VP(VP*R7VP-V4EK ^RIHpV!W4^RIHpV!W4T;'gR pVP6'd)VR,VP6,P94pV'dRRR V/.V,pVV3#)uwBuild the wire copy of ``messages`` for one API call plus the effective system message. Returns ``(api_messages, effective_system)``. Prompt-cache invariant: historical user/assistant rows replay their ``api_content`` sidecar (the exact bytes sent live) so the prefix stays byte-stable; the current user turn reuses the prologue's stamp (or composes live when a caller bypassed the prologue). Ephemeral context (prefetch, ``pre_llm_call`` hooks, ``ephemeral_system_prompt``) is added at API time only — ``messages`` stays untouched beyond the sidecar stamp, and the system prompt is built ONCE per session and replayed verbatim.)!fill_empty_non_final_wire_payload)_clone_message_for_send)canonicalize_replay_historyN)nowrqrrrtrir* finish_reason)is_final_length_continuation_fragment_length_continuation_nudge)r=r<r[)replay_for_agentr>rbsystemrs)rhr^agent.conversation_loopr_agent.replay_cleanupr`rCr2rr{ enumeratervrrwr"rl_copy_reasoning_content_for_api_should_sanitize_tool_calls#_sanitize_tool_calls_for_strict_apir[r<r[ragent.image_replayrfrJr?ephemeral_system_promptr)r r/rr^r_rRr(r^r_r` has_currentcurrent_turn_messageturn_nowsplitcanonical_messages api_messagesrr{rnr key _composedrfr?effective_systems&&$$$$$ r&build_api_messagesrysN?@2C8ggQBW=g=gZ]^fZg=gK>I8:t,,H%0 !aE4Xfu5E8TW_`fWggL01S*#. {{=$7 2C KKT "3 & &3776?f+D,,,&2 "5KK 2.0B ()2GI& |S ) )l#88 ".GI  --c7; OT* *'SCHZD[^_D_=_a  3T: 0$7  , , . .  5 525E%.. 6  G$u2|4U)T'< ,11r $$$,v58U8UU\\^96FGH<W ) ))r(rV))_invalid_tool_retries)_invalid_json_retriesr{)_empty_content_retriesr{)_incomplete_scratchpad_retriesr{)_codex_incomplete_retriesr{)_codex_reasoning_only_streakr{)_thinking_prefill_retriesr{)_post_tool_empty_retriedF)_last_content_with_toolsN)$_last_content_tools_all_housekeepingF)_reused_response_textN)_mute_post_responseF)_unicode_sanitization_passesr{)_tool_guardrail_halt_decisionN)_harness_metrics_turnN)"_iteration_budget_warning_injectedF)_run_budget_wrapup_injectedF)_verification_stop_nudgesr{)_pre_verify_nudgesr{)_lsp_turn_end_notesr{)NN)k__conditional_annotations__r __future__rloggingrKrrzrc contextlibr dataclassesrtypingrrrrr r rr agent.iteration_budgetr agent.memory_contextr agent.memory_providerrrragent.lsp.deferredrragent.plugin_live_notesragent.skills_index_deltaragent.message_metadatarrragent.model_metadatarrragent.image_token_costrrrragent.turn_authorr getLoggerrrFr-rPrHrgrlryr~rrrrrr frozensetrrrrrr RuntimeErrorrrrr rrr#r%r7rBrPrjrkr,rrrrrrrrrrrrrr rPr[ry)rs@r&rsA#  !<<N2;36G6<kk 9L/   8 $* 0f ; G! - 1@ 9 7  )GMT!$N#LW$H<H04b $LM$: 00 0"3& 0N*&<62$-`')T,\^ $&6r: 3>,t^{@"y_c y =A y im y49y'+yyx&q*r(