+ iHj3jRt^RIt^RIt^RIHt^RIHt]P!R4t!RR4t R#)a<User-facing status / warning / notice plumbing for ``AIAgent``. Safe printing, quiet-mode gating, deduped context-overflow warnings, and the buffered retry chatter that is shown only when every retry/fallback is exhausted. Extracted from ``run_agent.py``; every method resolves through ``AIAgent``'s MRO unchanged. N)t)ActivityProvenance run_agentc a]tRt^toRtRR/V3RlRlltRRRR/V3RlRlltV3R lR ltV3R lR ltV3R lRlt V3RlRlt V3RlRlt V3RlRlt V3RlRlt V3RlRltV3RlRltV3RlRltV3RlRltV3RlR ltV3R!lR"ltV3R#lR$ltV3R%lR&ltV3R'lR(ltV3R)lR*ltV3R+lR,ltV3R-lR.ltV3R/lR0ltV3R1lR2ltV3R3lR4ltV3R5lR6ltV3R7lR8ltR9tVt R:#);StatusOutputMixinzRStatus/warning/notice emission and retry-chatter buffering (see module docstring). diagnosticFc <V^8dQhRS[/#)rbool)format __classdict__s"8/home/ubuntu/.hermes/hermes-agent/agent/status_output.py __annotate__StatusOutputMixin.__annotate__s  T c \VRR4'dR#V'dVP4'gR#VP;'g\!V/VBR# \\ 3dR#i;i)zPrint that swallows broken pipes / closed stdout (headless stdout can vanish mid-session); routes through ``self._print_fn`` so the CLI can inject an ANSI-aware renderer._mute_notification_replyFN)getattr_warning_presentation_enabled _print_fnprintOSError ValueError)selfrargskwargss&$*,r _safe_printStatusOutputMixin._safe_printsc 43U ; ;  d@@BB   ^^ $ $u $t 6v 6$   sA AA.-A.forcec&<V^8dQhRS[RS[/#)r rrr )r r s"rrr s..D.d.rc "\VRR4'dR#V'dVP4'gR#V'g<\VRR4'g?VP4'dVP'dVP!V/VBR#R#R#)uVerbose print — suppressed while tokens are streaming (allowed during tool execution) and after the main response; ``force=True`` bypasses both. ``suppress_status_output`` (``hermes chat -q``) wins.suppress_status_outputFN_mute_post_response)rr_has_stream_consumers_executing_toolsr)rrrrrs&$$*,r_vprintStatusOutputMixin._vprint s 415 9 9  d@@BB  '> %  ))+, , G4  s&9AAc <V^8dQhRS[/#r)r )r r s"rrr4s n n$ nrc \VRR4'dR#VP;'d*VP'*;'d\VRR4R8H#)aTrue when quiet-mode tool summaries should print directly (CLI, no callback owns rendering); ``suppress_status_output`` always wins so ``[tool]``/``[done]`` never land in captured stdout. ``suppress_status_output`` (the strict machine-readable mode used by ``hermes chat -Q``) always wins: those flows neutralize the rendering callbacks, and without this gate the "no callback owns rendering" fallback would print ``[tool]``/``[done]`` spinner lines into the captured stdout it exists to keep clean (#93220). r"Fplatformcli)r quiet_modetool_progress_callbackr0s&r _should_emit_quiet_tool_messages2StatusOutputMixin._should_emit_quiet_tool_messages4sK 415 9 9mmt'B'B#BmmwtU_acGdhmGmmrc*<V^8dQhRS[RS[RR/#)r nameoriginr*Nstr)r r s"rrrAs'LL3LsLtLrc \WR4pV'd V!V!R#R# \d\PRYRR7R#i;i)uhInvoke ``self.(*args)`` if set, swallowing errors — a driver callback must never break the loop.Nz%s error in %sT)exc_info)r Exceptionloggerdebug)rr=r>rcbs&&$* r_call_callback StatusOutputMixin._call_callbackAsI T &  LD   L -td K Ls #AAc0<V^8dQhRS[RS[RS[RR/#)r kindmessager>r*Nr?)r r s"rrrJs/MMcMCMCMDMrc ^RIHpV!W4'dVP4'd"VPVP V 2RR7TP RYTR7R# \ dL#i;i)zkPrint to the CLI (``_vprint(force=True)``) and forward to ``status_callback(kind, message)``. Never raises.)is_warning_statusTrstatus_callbackr>N)gateway.warning_notificationsrMrr& log_prefixrCrG)rrJrKr>rMs&&&$ r_emit_status_kind#StatusOutputMixin._emit_status_kindJsmC $T33t7Y7Y7[7[ 0 :$ G -tVL   s#A#!A## A10A1c <V^8dQhRS[/#r)r )r r s"rrrTs  t rc ^RIHpV!\VR\VRR44\VRR44# \dR#i;i))warning_notifications_enabled_notification_platformr5r7_notification_configNT)rQrXrrC)rrXs& rr/StatusOutputMixin._warning_presentation_enabledTsOO 06jRW8XY4d;   s)2 AAc$<V^8dQhRS[RR/#r rKr*Nr?)r r s"rrr_s33s3t3rc @^RIHpVPV!V44R#)zGA diagnostic on the lifecycle rail, without changing legacy formatting.DiagnosticTextN)rQr` _emit_statusrrKr`s&& r_emit_diagnostic_status)StatusOutputMixin._emit_diagnostic_status_s@ .12rc$<V^8dQhRS[RR/#r]r?)r r s"rrrdsLLCLDLrc .VPRVRR7R#)zDEmit a lifecycle status message (CLI + gateway ``status_callback``). lifecyclerarPNrSrrKs&&rraStatusOutputMixin._emit_statusds {GNKrc$<V^8dQhRS[RR/#r]r?)r r s"rrrhsHHSHTHrc .VPRVRR7R#)zdEmit a user-visible warning for degraded side paths where the turn continues but the user must know.warn _emit_warningrPNrhris&&rrnStatusOutputMixin._emit_warninghs vwGrc$<V^8dQhRS[RR/#r]r?)r r s"rrrlseeSeTerc VP4p\VRR4;'gRR8XdVPV4R#^RIp^RIHpRVP VP44R 2pVPR4'dRMR pV!WR WDR 7p\VR R4'dVPV4R#.\VR R4OVNVn R#)aA warning raised during ``__init__`` that the user must see (e.g. a memory provider that could not be recovered). The CLI prints it. Other drivers get a sticky warn ``AgentNotice``: Desktop renders notices but no warn-kind ``status.update``, and the messaging gateway wires its callbacks per turn, after init, so a notice raised before then waits for :meth:`_replay_startup_warnings` on the first turn.r5Nr7) AgentNoticezstartup-warning.08xu✓successrmsticky)textlevelrJkeyidnotice_callback_pending_startup_notices) striprrnzlibagent.credits_trackerrrcrc32encode startswith _emit_noticer{)rrKr~rrrxrwnotices&& r_emit_startup_warning'StatusOutputMixin._emit_startup_warningls --/ D*d + 4 4u >   w ' 5 GNN,7rc0<V^8dQhRS[RS[RS[RR/#)r reasonpreflight_tokensthreshold_tokensr*N)r@int)r r s"rrrs+  S C cf ko rc 0T;'gRPR^4^,pRV3p\VRR4V8XdR#YPn^RIHpVR 9d&VP RV R2\ PR 7VPVPW#VR 74R#) uWarn (deduped on the block *kind* — ``cooldown`` / ``ineffective`` — not the countdown string; cleared by ``_clear_context_overflow_warn``) when context is over the threshold but compression is blocked.unknown:ctx_overflow_blocked_last_ctx_overflow_warnN))CONTEXT_OVERFLOW_BLOCKED_WARNING_TEMPLATEzcompression blocked ()) provenance)tokens thresholdr)cooldown ineffective) splitrragent.conversation_compressionr_touch_activityrAGENT_COMPRESSION_COOLDOWNrnr )rrrr _warn_kind _warn_keyrs&&&& r_warn_context_overflow_blocked0StatusOutputMixin._warn_context_overflow_blockeds)) 00a8; +Z8 42D 9Y F '0$\ 4 4  #8!BOaO|O| } DKK#L  rc*<V^8dQhRS[RS[RR/#)r rcontext_lengthr*N)r)r r s"rrrs) h hC hY\ hae hrc RV3p\VRR4V8wd*W0nVP\RVR VR R74R#R#)a`Deduped warning when uncompressed context exceeds the model limit; points the user at /compact. When compression is explicitly disabled (compression.enabled: false), long sessions can grow past the model context window with no compression to shrink them (#89297). Surface an actionable warning so the user knows to run /compact or enable compression. uncompressed_ctx_overflowrNz,display.notice.uncompressed_context_overflow,)rr)rrrnr)rrrrs&&& r#_warn_uncompressed_context_overflow5StatusOutputMixin._warn_uncompressed_context_overflowsW1.A 42D 9Y F+4 (   q!O+;A*>SabcRd g h Grc<V^8dQhRR/#rr|)r r s"rrrs,,d,rc RVnR#)zTReset the blocked-overflow warning dedup so it can re-fire on the next blocked turn.N)rr0s&r_clear_context_overflow_warn.StatusOutputMixin._clear_context_overflow_warns '+$rc<V^8dQhRR/#rr|)r r s"rrrsNNdNrc .VPRVRR7R#)zCFire a structured ``AgentNotice`` to the active driver (TUI / CLI).rzrrPNrG)rrs&&rrStatusOutputMixin._emit_notices -vnMrc$<V^8dQhRS[RR/#)r rxr*Nr?)r r s"rrrsWWcWdWrc .VPRVRR7R#)zEClear a previously-fired sticky notice by ``key`` (e.g. on recovery).notice_clear_callback_emit_notice_clearrPNr)rrxs&&rr$StatusOutputMixin._emit_notice_clears 3SAUVrc$<V^8dQhRS[RR/#r rvr*Nr?)r r s"rrrsSScSdSrc PVPV4VPRVRR7R#)zRewrite the live status line (CLI spinner, TUI ``thinking.delta``, gateway activity) so long provider waits are not an anonymous spinner.thinking_callback_emit_wait_noticerPN)rrG)rrvs&&rr#StatusOutputMixin._emit_wait_notices) T" />QRrc$<V^8dQhRS[RR/#rr?)r r s"rrrs55#5$5rc@^RIHpVPV!V44R#rWr_N)rQr`r)rrvr`s&& r_emit_diagnostic_wait'StatusOutputMixin._emit_diagnostic_waits@ ~d34rc*<V^8dQhRS[RS[RR/#)r rJrKr*Nr?)r r s"rrrs" $ $# $ $ $rc \\VRR4pVf .;q0nVPW34R#)zBuffer a retry/fallback line as ``(kind, text)`` until we know whether the turn recovered. ``kind`` is ``"status"`` (replays via ``_emit_status``), ``"vprint"`` (``_vprint(force=True)``) or ``"warn"`` (``_emit_warning``). _retry_status_bufferN)rrappend)rrJrKbufs&&& r_buffer_retry_message'StatusOutputMixin._buffer_retry_messages1 d2D9 ;.0 0C+ D?#rc$<V^8dQhRS[RR/#r]r?)r r s"rrr66c6d6rc*VPRV4R#)statusNrris&&r_buffer_status StatusOutputMixin._buffer_status ""8W5rc$<V^8dQhRS[RR/#r]r?)r r s"rrrs5555rc@^RIHpVPV!V44R#r)rQr`rrbs&& r_buffer_diagnostic_status+StatusOutputMixin._buffer_diagnostic_statuss@ N734rc$<V^8dQhRS[RR/#r]r?)r r s"rrrrrc*VPRV4R#)vprintNrris&&r_buffer_vprint StatusOutputMixin._buffer_vprintrrc<V^8dQhRR/#rr|)r r s"rrrsdrc T\VRR4pV'dVP4R#R#)u=Drop buffered retry messages — call on successful recovery.rN)rclear)rrs& r_clear_status_buffer&StatusOutputMixin._clear_status_buffers"d2D9  IIK rc<V^8dQhRR/#rr|)r r s"rrrstrc \VRR4pV'gR#RVn\V\4'dTMV.FpVP V4K R# \ dK)i;i)a+Surface the one-shot fallback-switch notice on successful recovery: a provider switch is durable state operators must see, unlike the retry chatter ``_clear_status_buffer`` drops. Emitted once, then cleared; on terminal failure the buffered switch line is flushed instead (``_flush_status_buffer``)._pending_fallback_noticeN)rr isinstancelistrcrC)rritems& r_emit_pending_fallback_notice/StatusOutputMixin._emit_pending_fallback_noticesf94@ (,%(66FVHDD ,,T2E  sA A$#A$c<V^8dQhRR/#rr|)r r s"rrrsdrc RVn\VRR4pV'gR#\V4pVP4RVPRVP /pVFUwrEWC9dW4,!V4KVP 4'd$VPVP V 2RR7KUKW R# \dKii;i)uZEmit buffered retry messages — call on terminal failure so the user sees what was tried.NrrrmTrN) rrrrrarnrr&rRrC)rrmessagesreplayrJmsgs& r_flush_status_buffer&StatusOutputMixin._flush_status_buffers)-%d2D9 9 D--vt7I7IJ!ID >L%99;; '8%>d K< "  sB12B1!B11 C?C)rrr{rN)!__name__ __module__ __qualname____firstlineno____doc__rr&r1r:rGrSrrcrarnrrrrrrrrrrrrrrrr__static_attributes____classdictcell__)r s@rrrs5\ E  .5.U.. n nLLMM  33 LLHHee,**  " h h,,NNWWSS 55 $ $665566  rr) rloggingr, agent.i18nragent.session_activityr getLoggerrDrr|rrrs6  5   ; 'mmr