*jH UdZddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl Z ddl Z ddl Z ddl Z ddlZddlZddlmZddlmZejeZddlmZmZmZmZmZmZmZmZm Z m!Z!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1ddl2m3Z3m4Z4ddl5m6Z6m7Z7ddl8m9Z9dd l:m;Z;dd lm?Z?dd l@mAZAmBZBe jCZDd ZEdeFdzdeFdzdeFdzdeGeFdzeFdzeFdzffdZHdeFdeFdeIfdZJdZK ddlLmMaMn #eN$rdaMYnwxYwdZOdeFdeIfdZPddeQdeQfdZRdZSdTZUd eeVdeFfd!ZW dd"eeFd eeVdeFfd#ZXejYd$ZZd%eFdeFfd&Z[de\eVfd'Z]d(eFdefd)Z^d*Z_deVfd+Z`d,d-d.d/eFd0eFd1eFdeVfd2Zad3eVdebfd4Zcde\eFfd5Zdd%eFde\eVfd6Zed3eVdeVfd7Zf dd3eeVdeVfd8Zgd9eVdeVfd:Zhd;e\dZjdeFfd?Zkdd@eFdzdeFfdAZlddBdCdDeFdEeIdeVfdFZmddeFdHeFdIeFdeVfdJZndeIfdKZoddeFd@eFdzdeFfdMZpdLdNdeFddfdOZqddPZrdBdLdQdReIdeFddfdSZsdeFfdTZtddUl@muZumvZvddVlwmxZxhdWZydXZzhdYZ{dZZ|hd[Z}d\Z~d]Zdd^Zdd_Zd`eVdzdaeFdbeFdceFdeVf ddZdeeVdeFfdfZdgeFddfdhZdbeFde\eFfdiZdeFfdjZedkhedlhedmhedmhednhedohedphdqZeVedzeeFfedr<dsedteFdeIfduZdveVdeFfdwZddxdyeFdzeFdaeFdveVfd{Zd%eFdeFfd|Zd%eFdeFfd}Zd%eFdeFfd~Zd%eFdeIfdZdeFfdZejYdZejYdZejYdZejYdZdseFdeFfdZdseFdeFfdZdBdd%eFdeIdeFfdZdeIfdZdZdZdZdeQfdZdeFdeIfdZdeFdeFdeGeFe\eFffdZddeFdeFdeFdeIfdZdeVfdZdeIfdZddebdebfdZddeFdeFdeFdeQfdZddeFdeFdeFdeQfdZd1eFdeIfdZd1eFdeIfdZdeFfdZdeFfdZdBddeIdeGeFeFffdZ ddeFdeFdeFdeFdeFdeGeeFeFff dZdeFdeFdeGeeFeFffdZdeFdeFdeGeeFeFeFffdZddBddeFdeFdeIdeGeeFeFeFffdZddbeFd1eFdeFdeFdeFddf dZdeFdeFdeeFfdZdeFdeIfdZddbeFdeFdeFdeFfdZddbeFdeFdeFdeFfdZdeFddfdZdZdZdeIfdZdeIfdZddxdveVfdZdZdZdZdZdZdZd„ZdÄZdĄZdńZdƄZdDŽZdȄZdɄZȐd deFdzdeQdeFdzfd̈́Zd΄ZdτZdЄZdфZd҄ZdӄZdԄZdՄZdքZdׄZd؄ZdلZdڄZdeIfdۄZdZdZdZedߜdeQdeQfdZddededdeQdeQdeQdeQdeQdeVf dZefdeQdeFfdZݐd deQdeVfdZdeQdeQfdZߐddZdeVdeGfdZdddeVdeQdzdeIfdZdZdeIfdZdZdZdeFfdZdeVdeIfdZddZ ddBddBddZdeVdeIfdZdeFdeIfdZdS( zt Hermes Web UI -- SSE streaming engine and agent thread runner. Includes Sprint 10 cancel support via CANCEL_FLAGS. N)Path)Optional) get_configSTREAMS STREAMS_LOCK CANCEL_FLAGSAGENT_INSTANCESSTREAM_PARTIAL_TEXTSTREAM_REASONING_TEXTSTREAM_LIVE_TOOL_CALLSSTREAM_GOAL_RELATEDPENDING_GOAL_CONTINUATIONSTREAM_LAST_EVENT_IDLOCKSESSIONS SESSION_DIR_get_session_agent_lock_set_thread_env_clear_thread_envregister_active_runupdate_active_rununregister_active_runSESSION_AGENT_LOCKSSESSION_AGENT_LOCKS_LOCKresolve_model_provider"resolve_custom_provider_connectionmodel_with_provider_context load_settings)redact_session_data _redact_text)is_context_compression_markervisible_messages_for_anchor)meter)RunJournalWriter)$append_turn_journal_event_for_stream)prompt_cache_hit_percent)get_state_db_session_messages(reconciled_state_db_messages_for_sessionz dummy-keyresolved_providerresolved_api_keyresolved_base_urlreturnct|tr|ds|||fSt|\}}|s|r|}|s|r|}|r d}|st}|||fS)aReturn provider/key/base_url overrides for ``custom:*`` endpoints. Hermes Agent treats named custom providers as routing hints around an OpenAI-compatible base URL. Local OpenAI-compatible servers often run without authentication, so a missing key should not fail before the first request; pass a harmless placeholder to the SDK and let the endpoint accept it or return its own auth error. zcustom:custom) isinstancestr startswithr_KEYLESS_CUSTOM_API_KEY)r)r*r+_cp_key_cp_bases 0/Users/bertmahoney/hermes-webui/api/streaming.py*_resolve_custom_provider_runtime_overridesr6=s (# . .F3D3O3OPY3Z3ZF "24EEE:;LMMGX ##" %%$7 % 76  .0A AAkindmessagec t|pd}t|pd}|dkod|vpd|vp d|vpd|vpd|vS)zNReturn True if an agent lifecycle status should surface as a fallback warning. lifecyclez rate limitedzswitching to fallbackz falling backzfallback activatedztrying fallbackr0striplower)r8r9kms r5_is_fallback_lifecycle_messagerB]s DJB%%''A GMr  ""((**A [ a  &&!+ &" &$q( &!A% r7cPdD]"} t|#t$rYwxYwdS)aImport tools.skills_tool and tools.skill_manager_tool outside any lock. First-time module imports can trigger heavy initialisation (disk I/O, transitive imports, plugin discovery). Performing those imports while holding ``_ENV_LOCK`` serialises every concurrent session behind the slowest import. Prewarming ensures the modules are already in ``sys.modules`` before the lock is acquired, so the lock body only does lightweight attribute patching. We cannot place these at module top-level because ``tools.*`` lives in the hermes-agent package which may not be on ``sys.path`` at import time (Docker volume-mount ordering). A dedicated helper keeps the lazy-import try/except in one place and makes the intent explicit. )ztools.skills_toolztools.skill_manager_toolN) __import__ ImportError) _mod_names r5_prewarm_skill_tool_modulesrGmsT G   y ! ! ! !    D s  ##AIAgentcRt ddlm}|an#t$rYnwxYwtS)a^Return AIAgent class, retrying the import if the initial attempt failed. auto_install_agent_deps() in server.py may install missing packages after this module is first imported (common in Docker with a volume-mounted agent). Re-attempting the import here picks up the newly installed packages without requiring a server restart. NrrH)rI run_agentrE)_clss r5 _get_ai_agentrMsL  1 1 1 1 1 1GG    D  Ns  err_textct|pd}d|vp?d|vp;d|vp7d|vp3d|vp/d|vp+d|vp'd |vp#d |vpd |vpd |vpd |vpd|vpd|vp d|vod|vod|vS)zAReturn True when provider text looks like quota/usage exhaustion.r;zinsufficient creditzcredit balancezcredits exhaustedz more creditszcan only affordzfewer max_tokensquota_exceededzquota exceededzexceeded your current quotazplan limit reachedusage_limit_exceededzusage limit exceededzreached the limit of messageszused up your usageplanlimitreached)r0r?)rN _err_lowers r5_is_quota_error_textrVsX^$$**,,J+ X z ) X * , X Z ' X  *  X  +  X z )  X z ) X )J 6 X : - X "Z / X "Z / X +j 8 X : - X j VW %: VyJ?V!r7xdefaultc t}|did|}t|}|dkr|S|S#t$r|cYSwxYw)z;Resolve clarify timeout from config, with bounded fallback.clarifytimeoutr)rgetint Exception)rXcfgrawtimeout_secondss r5_clarify_timeout_secondsrbsxllggi$$((G<<c(( a  N sAAA A"!A")task cancelled task canceledresponse interrupteda WebUI progress guidance: - Match the normal Hermes messaging style; do not add extra status updates solely because this is a browser session. - For long multi-step work that uses tools, you may provide brief user-visible progress updates before continuing with tool calls. - Each update should say what you are about to check, what you just confirmed, or why the next tool call is needed. - Keep updates concise, factual, and in the user's language. One or two short sentences are enough. - Do not reveal hidden reasoning, chain-of-thought, private scratchpads, secrets, raw logs, or long tool output. - For direct answers or very short tasks, skip progress updates and answer normally. surface_contextc$t|tsdSgd}d}|D]\\}}||}|!t|nd}|r|d|d|]d|S)adReturn safe WebUI session metadata for the agent's ephemeral context. Messaging gateways inject platform/channel context before each run. Browser sessions do not have a chat platform wrapper, so provide an explicit, small surface description here instead of relying on the model to infer where it is running from the transcript alone. r;)zWebUI session context:zp- This browser session is not the same live transcript as Telegram, Discord, Slack, or other messaging surfaces.z- Use durable memory, saved sessions, and available tools for cross-surface recall instead of assuming those transcripts are in this browser chat.))sourceSource) session_idz Session ID)profileProfile) workspace WorkspaceNz- :  )r/dictr\r0r>appendjoin)rflinesfieldskeylabelr`values r5_webui_surface_context_promptrys ot , ,r   E F 00 U!!#&&$'OC     0 LL.e..u.. / / / 99U  r7personality_promptc0g}|r4|t|t|}|r|||tdd|DS)zHBuild WebUI-only runtime instructions that are not persisted to history. c3K|]}||V dSN.0parts r5 z1_webui_ephemeral_system_prompt..s'666t666666r7)rrr0r>ry_WEBUI_PROGRESS_PROMPTrs)rzrfpartssurface_prompts r5_webui_ephemeral_system_promptrs E6 S+,,22445552?CCN% ^$$$ LL'((( ;;66666 6 66r7z(?i)(api[_-]?key|token|password|secret)\s*[:=]\s*[^\s]+|\b(?:sk-[A-Za-z0-9_-]{16,}|ghp_[A-Za-z0-9_]{20,}|github_pat_[A-Za-z0-9_]{20,})\b|[A-Za-z0-9_-]{24,}\.[A-Za-z0-9_-]{16,}\.[A-Za-z0-9_-]{16,}textctdt|pd}d|ddS)z@Return a short, non-secret diagnostic string for prefill status.z [REDACTED]r; N)_SECRET_SHAPED_REsubr0rssplit)rcleans r5_redact_prefill_status_textrsD  ! !,DJB @ @E 88EKKMM " "4C4 ((r7cNt|tsgSg}|D]}t|ts|d}|d}|dvs)t|tr|sp|||d|S)z5Normalize a prefill payload to role/content messages.rolecontent>usersystem assistantrr)r/listrqr\r0r>rr)rxmessagesitemrrs r5_valid_prefill_messagesrs eT " " H<<$%%  xx((9%% 6 6 6jRU>V>V 6^e^k^k^m^m 6 '::;;;; Or7r`c tt|}|s@ ddlm}|j|z }n&#t$rtj|z }YnwxYw|S)Nr)_get_config_path) rr0 expanduser is_absolute api.configrparentr^cwd)r`pathrs r5_resolve_prefill_pathrs C>> $ $ & &D     % % 3 3 3 3 3 3##%%,t3DD % % %8::$DDD % KsA B?BicdddgddS)Nnot_configurednoner;rstatusrhrwr message_countrrr7r5_prefill_not_configuredr%s&&2SUhi j jjr7fileloaded)rhrfile_rawrhrc vt|}|jpd}|s d||gdddS tt j|d}||||t|dS#t$r-}d||gdtt|dcYd}~Sd}~wwxYw) Nz prefill fileerrorrzprefill file not foundrrhrwrrrutf-8encodingr) rnameexistsrjsonloads read_textlenr^rr0)rrhrrrwrexcs r5_load_prefill_messages_filer)s-  * *D I 'E ;;==L!VeQSfgsKLL LY*4:dnngn6V6V+W+WXX FUPXknowkxkxyyy YYY!VeQSfgsNORSVOWOWsXsXYY Y Y Y Y Y YYsA B B8 "B3-B83B8 config_datactjddp#t|dpd} t dt t |pddS#t$rYdSwxYw)N,HERMES_WEBUI_PREFILL_MESSAGES_SCRIPT_TIMEOUTr;%webui_prefill_messages_script_timeout皙?g>@g@)osgetenvr0r\maxminfloatr^)rr`s r5_prefill_script_timeoutr5s )BB G G O3{`GPHPHPNLNLOLOC3E#(OOT22333 sss,A(( A65A6ct|ttfr d|DStjt |pd}|sgSt |dkr%t t|d|d<|S)NcJg|] }t|t|!Srr0rs r5 z+_prefill_script_command..?s)777dSYY7D 777r7r;r)r/rtupleshlexrr0rr)r`rs r5_prefill_script_commandr=s#e}%%877c7777 KCI2 ' 'E   5zzQ,U1X6677a Lr7c&t|pd}|sgS tj|}n#t$rd}YnwxYwt |t r|d}t|}|r|Sd|dgS)Nr;rrr) r0r>rrr^r/rqr\r)rstrippedpayloadrs r5$_messages_from_prefill_script_outputrJs4:2$$&&H  *X&& '4  *++j))&w//H( 3 3 44s> A  A c Ntjddp|d}|stSt |}|rt |djnd}|s dd|gddd S tj|d tj tj t|d }nS#tj $r dd|gdd d cYSt$r-}dd|gdtt|d cYd}~Sd}~wwxYw|jdkr.t|jp|jp d|j}dd|gd|d St%|jdt(krdd|gddt(dd St+|j}dd||t%|dS)N$HERMES_WEBUI_PREFILL_MESSAGES_SCRIPTr;webui_prefill_messages_scriptrzprefill scriptrscriptzprefill script is emptyrTF)rstdoutstderrr[checkzprefill script timed outzprefill script exited rzprefill script output exceeded z bytesrr)rrr\rrrr subprocessrunPIPErTimeoutExpiredr^rr0 returncoderrrencode_PREFILL_SCRIPT_OUTPUT_LIMITr)r script_rawcommandrwprocrerrrs r5_load_prefill_messages_scriptrZs}A2FFz+//ZyJzJzJ )&(((%j11G%, BD   ! !2BE O!XSUhiuNOO O [~ ??+K88      $PPP!XSUhiuOPP P P P [[[!XSUhiuPQTUXQYQYuZuZ[[ [ [ [ [ [ [[ !)$+*r*rHraeapHrHrss!XSUhitwxxx 4;  g & &''*FFF[7S[[[    4DK@@H(UPXknowkxkx y yys$4;B00D D"C;5D;DcPt|tr|n t}t|}|ddkr|St jddp#t|dpd}|rt|StS)ahLoad configured WebUI session prefill messages. Supports the same bounded JSON-file shape used by Hermes Agent. WebUI also supports its own explicitly opt-in script hook so admins can bridge Joplin, Obsidian, Notion, llm-wiki, or another local notes source into ephemeral turn context without baking any one note provider into the WebUI. rrHERMES_PREFILL_MESSAGES_FILEr;prefill_messages_file) r/rqrrr\rrr0rr)rr_script_contextrs r5_load_webui_prefill_contextrs$K66 H++JLLC2377N(##'777y7<<kCGGLcDdDdDjhj@k@kH5*8444 " $ $$r7prefill_contextc*|dd|dd|ddt|dpdd |d rd |d diniS) zBStrip message bodies before sending context status to the browser.rrrhrrwr;rr)rrhrwrr)r\r])rs r5_public_prefill_context_statusrs"%%h0@AA!%%h77 $$Wb11_00AAFQGG    ;J:M:Mg:V:V ^G_(("55 6 6\^  r7 all_messages prev_countct||kr ||d}nt||krdSdStd|DS)u!Return True if *new* messages (beyond ``prev_count``) contain an assistant message with non-empty content. ``all_messages`` is ``result.get('messages')`` which includes the full conversation history. ``prev_count`` is ``len(_previous_context_messages)`` — the number of messages present before the current turn started. Only messages at index >= prev_count are inspected so that historical assistant replies don't mask a silent failure on the current turn. If ``len(all_messages) < prev_count`` (an edge-case shrink), there is no reliable new-message slice to inspect. Treat that as "no new assistant reply" so stale historical assistant replies cannot mask a silent failure. When ``len == prev_count``, there are no new messages and we return False. NFc3K|]S}|ddko5t|dpdVTdS)rrrr;N)r\r0r>rrAs r5rz+_has_new_assistant_reply..so  f $LQUU9-=-=-C)D)D)J)J)L)Lr7)rany)rr candidatess r5_has_new_assistant_replyrst <:%%!*++. \  Z ' 'u u   r7c ttpidpd}n.#t$r!t ddd}YnwxYw|pdS)zBReturn the configured assistant display name for user-facing copy.bot_namer;z-Failed to load bot_name for cancellation copyTexc_infoHermes)r0rr\r>r^loggerdebug)rs r5_preferred_agent_display_namersMOO)r..z::@bAAGGII  Dt TTT  8sAA(A21A2ctt|ddpd}|r-|dkr'|dd|ddzSt S)Nrkr;rXr)r0getattrr>upperr)sessionrks r5)_preferred_agent_display_name_for_sessionrsq''9b117R88>>@@G17i''rr{  ""WQRR[00 ( * **r7 agent_namecpt|p tpd}d|dS)Nrz)The run was cancelled by the user before z( finished. No provider failure occurred.)r0rr>)rrs r5_cancelled_turn_hintrs= z<:<< = = C C E E QD et e e eer7Fsilent_failureerr_strr ct|pd}|}|t|jnd}d|vpd|vpd|vpd|vpd|vpd|vp d |vp|duo|d v}| o5d |vp1d |vp-d |vp)d|vp%d|vp!d|vpd|vp|duot|jdv}|rddt dS|rddddSt |}| od|vp|duod|vpd|vpd|vp d|vpd|vpd|v}d |vpd!|vpd"|vpd#|vpd$|vp d%|vpd&|vpd'|v} | od(|vp d)|vp|duod*|v} |rd+d,d-dS| rd.d/d0dS|rd1d2d3dS| rd4d$d5dS|rd6d7d8dSd9d:ddS);zClassify provider/agent failure text for WebUI apperror UX. Keep this string-based until hermes-agent exposes stable structured provider error classes for Codex OAuth plan limits. r;Nzcancelled by userzcanceled by userzuser cancelledz user canceledrcrdcancellederror)CancelledError CanceledErrorzinterrupted by userrezoperation interruptedzoperation was interruptedzoperation abortedzrequest was aborted aborterror)KeyboardInterrupt AbortErrorzTask cancelled cancelled)rwtypehintResponse interrupted interruptedzZThe run stopped before a provider response completed. If you did not cancel it, try again.401AuthenticationErrorauthentication unauthorizedzinvalid api keyinvalid_api_keyzno cookie auth credentials404z not foundzdoes not existzmodel not foundmodel_not_foundz invalid modelzdoes not match any known modelz unknown modelz rate limit429RateLimitErrorzOut of creditsquota_exhaustedzYour provider account is out of credits or usage. Top up, wait for the plan window to reset, or switch providers via `hermes model`.zRate limit reached rate_limitzaRate limit reached. The fallback model (if configured) was also exhausted. Try again in a moment.Authentication failed auth_mismatchThe selected model may not be supported by your configured provider or your API key is invalid. Run `hermes model` in your terminal to update credentials, then restart the WebUI.zModel not foundzThe selected model was not found by the provider. Check the model ID in Settings or run `hermes model` to verify it exists for your provider.zNo response from provider no_responsezThe provider returned no content and no error. This often means a usage/rate limit was hit silently. Check provider status, switch providers via `hermes model`, or try again in a moment.Errorr)r0r?r__name__rrV) r rr rU _exc_name _is_cancelled_is_interrupted _is_quota_is_auth _is_not_found_is_rate_limits r5_classify_provider_errorr/s '-R  GJ&)oS ""2Iz) R  + R z ) R j ( R z )  R j (  R z )  R tO P -P P  !Z / _%3 _&*4 _+j8 _#j0  _ % 2  _ z)  _4]DII$6:]$] %(**    +!p   %W--I   W  :4F$9Y$F ::- :+ :!J.  : !J.  : ,z9   ) * $ ) z ) )  * )  *  ) j (  ) ,z 9  ) j ($m "mew&6m3d?;lO_clOl %%[    ) w    ,#I    &%d    0"Q    gr : ::r7r;err_typerct|pd}|r!t|nd}|p||d}|r||d<|r;|}t|dkr|dddz}|r||d<|S) zABuild a bounded, redacted apperror payload with provider details.r;)r9rriNi…details)r0r r>rrstrip)r9r0r_message _safe_messager_detailss r5_provider_error_payloadr8<s7=b!!H6>FL**00222BM - 98LLG *  x==4  --//%7H  *!)GI  Nr7c tt|ddpgD]Y}t|ts|ddkrdS|ddkrO|d}d}t|t r|}nt|t r}g}|D]c}t|trL|t |d p|dpddd |}| tfd tDrd S[dS) zHReturn True if a visible cancel/interrupted marker is already persisted.rNrrFrrr;rrpc3 K|]}|vV dSr~r)rpattern normalizeds r5rz-_session_has_cancel_marker..`s(LLw*$LLLLLLr7T) reversedrr/rqr\r0rrrrsr>r?r_CANCEL_MARKER_PATTERNS)rmsgrrrrr<s @r5_session_has_cancel_markerr@Ls}T::@bAA#t$$   776??f $ $55 776??k ) ) '')$$ gs # # $DD  & & $E U UdD))ULLTXXf%5%5%R)9L9L%RPR!S!STTT99U##DZZ\\'')) LLLL4KLLL L L 44  5r7Task cancelled.ct|pd}|ds|dz }d|dt|dS)zFReturn cancelled-turn copy matching the verbose provider-error layout.rA.z**Task cancelled:**  **)r0r>endswithr)r9rr5s r5_cancelled_turn_contentrGesp7//006688H   S ! !C 0x 0 0  , , 0 0 0r7r9c xt|d|_d|_g|_d|_t |st |}|jdt||dt|pd dttj ddSdS)aAPersist a user-cancelled terminal state without provider-error wording. cancel_stream() usually writes this marker first, but the streaming thread can later unwind through the silent-failure or exception path. Those paths must not append a misleading provider no-response error after an explicit cancel. NrTrACancellation detailsrr_errorprovider_detailsprovider_details_label timestamp)+_materialize_pending_user_turn_before_erroractive_stream_idpending_user_messagepending_attachmentspending_started_atr@rrrrrGr0r>r]time)rr9rs r5_persist_cancelled_turnrVps0888#G#'G "$G!%G %g . .  >wGG .w CC #G$@/@ A A G G I I&<TY[[)) ! !         r7cd|_d|_g|_d|_ ddl}||jddS#t$r t ddYdSwxYw)zERemove transient /btw session state after a cancel without saving it.NrT missing_okz.Failed to clean up ephemeral cancelled sessionr) rQrRrSrTpathlibrrunlinkr^rr)rrZs r5!_cleanup_ephemeral_cancelled_turnr\s#G#'G "$G!%GV W\""))T)::::: VVV EPT UUUUUUVs2A&A<;A< ephemeralr9r^c|rt|dSt|| |dS#t$r tddYdSwxYw)z?Finalize a cancelled turn for persistent or ephemeral sessions.NrHz Failed to persist cancelled turnTr)r\rVsaver^rr)rr^r9s r5_finalize_cancelled_turnras)'222GW5555H  HHH 7$ GGGGGGHs<&A&%A&cddl}ddl}dg}|d|d|j|jd}|r|d|n|dd |jD}|rw|d |dd D]}|d |t|d kr)|d t|d z dn|d|d|d|d|d|d|d|d|d|d|dd|S)uReturn a multi-line diagnostic string for the "AIAgent not available" path. The bare ImportError ("AIAgent not available -- check that hermes-agent is on sys.path") leaves users guessing at which python is running, where it's looking, and what to fix. We assemble the same evidence a maintainer would ask for first (issue #1695): the python that's running, the agent_dir env var if set, the sys.path entries that mention 'hermes', and the most-common fix (`pip install -e .` in the agent dir). Kept as a separate helper so it stays out of the hot path until we actually need to raise — building it on every successful import would be wasted work. rNz?AIAgent not available -- check that hermes-agent is on sys.pathr;z python: HERMES_WEBUI_AGENT_DIRz HERMES_WEBUI_AGENT_DIR: z# HERMES_WEBUI_AGENT_DIR: (not set)cjg|]0}d|vsd|v.|1S)hermesagent)r?rps r5rz0_aiagent_import_error_detail..s<VVVaAGGII(=(=AGGIIAUAUAUAUAUr7z+ sys.path entries mentioning hermes/agent:z - z ... and z morez0 sys.path: (no entries mention hermes or agent)zD Most common fix: install the agent in editable mode so its modulesz appear on sys.path:z cd /path/to/hermes-agentz pip install -e .z Then restart the WebUI.zI Full troubleshooting: docs/troubleshooting.md ("AIAgent not available")rp) rsysrr executableenvironr\rrrs)_os_sysrt agent_dirrelevantentrys r5_aiagent_import_error_detailrrs# N OE LL LL0t00111  899I< =)==>>>> :;;;WV49VVVHI BCCCbqb\ + +E LL)%)) * * * * x==1   LL@H (9@@@ A A A GHHH LL LLWXXX LL())) LL LL/000 LL'((( LL LL,--- LL LL\]]] 99U  r7) get_session title_from)set_last_workspace>rrrrefusal tool_calls tool_call_idreasoning_contenti@> used_model used_providerrequested_modelrequested_provider) llm_gatewaygatewaymetadataresponse_metadatarouting_metadatausage> rmodelscorereasonrattemptproviderselectedrO latency_ms attempt_indexselection_reasonc|dSt|ttttfrSt|}|sdSt|tttfr|n |ddSdS)Nr)r/r0r]rboolr>)rxrs r5_clean_gateway_routing_scalarrsy }t%#sE4011N5zz!! 4"53t*<==Muu4:M 4r7c2ttsdStfdtDs(tdt rSt D],}|}t|}|r|cS-dS)Nc3 K|]}|vV dSr~r)rr@rs r5rz1_find_gateway_metadata_payload..s' A AA1< A A A A A Ar7routing)r/rqr_GATEWAY_ROUTING_TOP_LEVEL_KEYSr\r_GATEWAY_ROUTING_CONTAINER_KEYS_find_gateway_metadata_payload)rrvnestedfounds` r5rrs gt $ $t A A A A!@ A A AAAZPWP[P[\ePfPfhlEmEm.S!!.v66  LLL  4r7c t|}|sdSi}tD]+}t||}||||<,d|vrt|}|||d<d|vrt|}|||d<g} |d} t | t ro| ddD]d} t | t si} tD]+}t| |}||| |<,| r| | e| r| |d<t|dpd } t|dpd }t|dpd }t|dpd }t| o|o| |k}t|o|o||k}d | D}d |D}td | D}t|pt|d kp|}|ds|ds| s|s|sdS||d <||d<||d<|S)a.Return safe LLM Gateway routing metadata, or None when absent. LLM Gateway response metadata can contain provider/model routing details, but WebUI must only persist display-safe scalars and a bounded routing list. Secrets or provider-specific request objects are deliberately ignored. Nr|r}r r{r;rzcg|]_}|dt|dpd`S)rr;r\r0r>r?ras r5rz7_normalize_gateway_routing_metadata..6sk 55   AEE*   #$$**,,2244r7ch|]}||Srrrgs r5 z6_normalize_gateway_routing_metadata..;s#H#H#H!a#HA#H#H#Hr7c3K|]N}t|dpddvVOdS)rr;>rfailedr[rejectedN)r0r\r>r?rs r5rz6_normalize_gateway_routing_metadata..<sk""  AEE(OO !r""((**00226``""""""r7rprovider_changed model_changed has_failover)rrrr\r/rrq_GATEWAY_ROUTING_ATTEMPT_KEYSrrr0r>r?rrr)rr|r}srcr<rvrxfallback_modelfallback_providerr raw_routingr clean_attemptr{requested_provider_normrzrequested_model_normrrattempted_providersdistinct_attempted_providersfailed_before_selectionrs r5#_normalize_gateway_routing_metadatars ) 1 1C tJ.$$-cggcll;;  #JsO **6GG  %,:J( ):--9:LMM  (/@J+ ,G'')$$K+t$$ ."3B3' . .Ggt,, M4 / /5gkk#6F6FGG$).M#& .}---( ' 9 77=2>>DDFFLLNNM!*..1E"F"F"L"MMSSUU[[]]Z^^L117R88>>@@FFHHJz~~.?@@FBGGMMOOUUWWMr.Er-[rJrssc(<cOcAcddM $I#H/B#H#H#H !"""""(lC0L,M,MPQ,QlUlmmL ''+5>>,+G+GKRVfjwt%5J!""/J!-J~ r7c g}t|tr||d|d|d|d|d|d|gdD](}|$|t ||d)|D]}t |||}|r|cSdS) Nr~rrrrr)llm_gateway_metadatagateway_metadatalast_response_metadatarr last_usager|r})r/rqextendr\rrrr)rfresultr|r}rattr candidater<s r5!_extract_gateway_routing_metadatarLsJ&$   JJ} % % JJy ! ! JJz " " JJ* + + JJ) * * JJw        : :     geT488 9 9 9 8 +1         4r7profile_runtime_envrmrj profile_homec zt|pi}|t|d||d|d|S)aABuild thread-local agent env with per-run values overriding profile defaults. Profile runtime env may include TERMINAL_CWD from config.yaml. Passing it as **kwargs alongside an explicit TERMINAL_CWD raises TypeError before the agent starts, so merge into one dict first and let the active workspace win. 1webui) TERMINAL_CWDHERMES_EXEC_ASKHERMES_SESSION_KEYHERMES_SESSION_IDHERMES_SESSION_PLATFORM HERMES_HOME)rqupdater0)rrmrjrenvs r5_build_agent_thread_envrmsV "(b ) )CJJI('#*#  Jr7evtc vt|tsdS|ddkrdS|dd}|dd}|dd}|dpd}t|dkr |d dd z}d |d |d |d|d S)zCFormat a completed background process notification for agent input.r;r completionrjr exit_codeoutputNz ... (truncated)z[IMPORTANT: Background process z completed (exit code z ). Command: z Output: ])r/rqr\r)r_sid_cmd_exit_outs r5_format_process_notificationrs c4 r wwv,&&r 77< $ $D 779b ! !D GGK $ $E 778   "D 4yy4ETE{00 $  e       r7 process_idc |j5|j|ddddS#1swxYwYdS#t$r tddYdSwxYw)zEBest-effort bridge to the agent registry's private completion marker.Nz*Failed to mark process completion consumedTr)_lock_completion_consumedaddr^rr)process_registryrs r5!_mark_process_completion_consumedrsR  # B B  1 5 5j A A A B B B B B B B B B B B B B B B B B B RRR AD QQQQQQRs'>1 >5>5>&A('A(c|sgS ddlm}n#t$rgcYSwxYwg}g}t|dd}|gS |}n=#t j$rYn!t$rtddYnwxYwt|tr$t| dpd nd }|s| | ||r| |}n#t$rd}YnwxYwt|d d|kr| |t|}|r%| |t!||I|D]E} ||#t$r td dYnwxYw|S) a0Return completion notifications that belong to this WebUI session. The agent registry completion queue is process-wide and events do not carry the WebUI session key directly. Look up the live process session before delivery so completions from other tabs remain queued for their owners. r)rcompletion_queueNTz(Failed to drain process completion queuerrjr; session_keyz*Failed to requeue process completion event)tools.process_registryrr^r get_nowaitqueueEmptyrrr/rqr0r\rris_completion_consumedrrput) rjr notificationsskipped_eventsrrevt_sidr notifications r5"_drain_webui_process_notificationsrsr  ;;;;;;;   "M!#N/1CTJJ I "--//CC{    E    LLCdL S S S E 7Ad6K6KS#cggl++1r222QS   ! !# & & &  66w?? #''00DD   DDD  4 - - ; ;  ! !# & & & 3C88  I   . . . -.> H H H5I8    % % % %    LLEPTL U U U EE  sM AB !%B B  D 6D DDF&GGc2t|tr`t|dp+|dp|dpdSt|pdS)Nrfilenamerr;)r/rqr0r\r>)atts r5_attachment_namers{#t\3776??Rcggj&9&9RSWWV__RPRSSYY[[[ syb>>   ! !!r7z image/pngz image/jpegz image/gifz image/webpz image/bmp image/svg+xml)sPNG  ssGIF87asGIF89asRIFFsBMN _IMAGE_MAGICrmimec|dsdS|ddd}|dkrdS |d5}|d }d d d n #1swxYwYn#t$rYdSwxYwt D]#\}}|||r||vrdS$dS) zCheck that the file's first bytes match the expected image MIME type. Uses simple magic-number detection (no external dependency). SVG is allowed through because it is text-based and has no binary signature. image/F;rrrTrbN)r1ropenreadOSErrorritems)rr mime_basefhheadmagicmimess r5_is_valid_imagers+ ??8 $ $u 3""1%IO##t YYt__ 772;;D                uu$**,, u  !7!7 I>@@HVZZ((.B//5577J6::j))/R006688H|##z#X#v 8r7r_ workspace_ctxmsg_textc |s||zS|t|dkr||zSd||zdg}t|} ddlm}|}||f} n#t $r|f} YnwxYwd} |pgD]} t| tst| dpd } | sR t| tfd| Ds sj} | dks | t krt| d pd p t#jjdpd}|d rt+|s`t-jd }n#t $rYwxYw|d d d|d|id| dz } | r|n||zS)uuBuild native multimodal content parts for current-turn image uploads. WebUI uploads files into the active workspace. For image files, pass the bytes to Hermes as OpenAI-style image_url data URLs so vision-capable main models can consume them in the same request. Non-image files intentionally stay as text path attachments so the agent can inspect them with file tools. When *cfg* is provided, respects ``agent.image_input_mode`` — if the resolved mode is ``"text"``, returns a plain string (attachments are not embedded) so the agent's text-mode pipeline (``vision_analyze``) handles images. Nr)rrr)_attachment_rootrr;c3BK|]}|VdSr~)is_relative_to)rrrs r5rz3_build_native_multimodal_message..Os1FF!t**1--FFFFFFr7rrascii image_urlurlzdata:z;base64,)rrr)r rrresolve api.uploadrr^r/rqr0r\r>ris_filestatst_size_NATIVE_IMAGE_MAX_BYTES mimetypes guess_typerr1rbase64 b64encode read_bytesdecoderr)rr attachmentsrmr_rworkspace_rootrattachment_root_allowed_roots image_countrraw_pathsizerdatars @r5 _build_native_multimodal_messager-s (x'' 4S99VCCx''mh&> ? ? @E)__//1199;;N+//////**,,(/: +++(*+K b#t$$  swwv,"--3355   >>,,..6688DFFFF~FFFFF <<>> 99;;&DqyyD#:::swwv,"--3355c):Nty:Y:YZ[:\:b`bD??8,, OD$4O4O #DOO$5$566==gFFDD    H  !=!=!=t!=!=>      q  =55]X%==s> A55 BB!AH(0H(*H(0A.*?\s*rflagsz-^\s*<\|channel\|?>thought\n?.*?\s*z&^\s*<\|turn\|>thinking\n.*?\s*z1^\s*(the|ther)\s+user\s+is\s+asking[^\n]*(?:\n|$)a*^\s*(?:here(?:'s| is) (?:a |my )?(?:thinking|thought) (?:process|trace|through)\b[^\n]*\n?|let me (?:think|work|reason|analyze|walk) (?:through|about|this|step)\b[^\n]*\n?|i(?:'ll| will) (?:think|work|reason|analyze|break this down)\b[^\n]*\n?|(?:okay|alright|sure|of course),?\s+let me\b[^\n]*\n?)\s+)r0rer IGNORECASEDOTALLr>rss r5_strip_thinking_markupr7es r D A +S!2=29;TUUUA ?ar}_a_hOhiiiA 8#q XZXaHabbbA CS!SUS`aaaA  C Qbm    A vsA$$&&A Hr7c|s|St|}|}d|vrd|vr|Sd}d|d}d|d}tj|d|d|tjtjz }tj|d d|tjtjz }tjd d|tj }|S) uStrip XML-style function_calls blocks that DeepSeek and similar models emit in their raw response text. These blocks are processed separately as tool calls; leaving them in the assistant content causes them to render visibly in the chat bubble. Handles both complete blocks (…) and partial/orphaned opening tags that may appear at the tail of a stream. Also handles variants like <｜DSML｜function_calls> from DeepSeek on Bedrock. function_callsdsmlu(?:\s*｜\s*DSML\s*[｜|]\s*)?z>.*?r;r/z (?:>|$).*$u<\s*｜\s*DSML\s*[｜|]\s*)r0r?r2rr3r4r>)rr6_lo _dsml_prefixopen_tag close_tags r5_strip_xml_tool_callsr@~s   D A ''))Cs""vS'8'8 4L0L000H3l333I  %%)%%  mbi'    A       mbi'    A ,b!2=IIIA 7799r7c\t|pd}tjdd|tj}tjdd|tj}|d}tjdd|}t |rdS|dd S) z?Sanitize LLM-generated title text before persisting to session.r;zB^\s*(?:[*_`~]+\s*)?(?:session\s+title|title)\s*:\s*(?:[*_`~]+\s*)?r/z^\s*title\s*:\s*z "'`*_~r1rNP)r7r2rr3r>_looks_invalid_generated_titler5s r5_sanitize_generated_titlerDstzr**A M  m    A "B???A  !!A vsA$$&&A%a((r SbS6Mr7czt|pd}|sdSttjd|tjptjd|tjptjd|tjptjd|tjptjd|tjpbtjd |tjpAtjd |tjp tjd |tjS) Nr;Tz/|<\|channel\|>thought|<\|turn\|>thinkingr/z^\s*(the|ther)\s+user\s+z^\s*user\s+\w+\s+z$\b(they|user)\s+want(s)?\s+me\s+to\bz(^\s*(i|we)\s+(should|need to|will|can)\bz ^\s*let me\bz2^\s*here(?:'s| is) (?:a |my )?(?:thinking|thought)zA^\s*(ok|okay|done|all set|complete|completed|finished)\b[\s.!?]*$)r0r>rr2searchr3r5s r5rCrCs( DJBA 7799t  Dar}]]] s 90!2= I I I s 9)1BM B B B s 9)rxrrhptypes r5 _message_textrKs%@ K KAa&& f +,,2244EAAA Sv!H!%% 2B2B!HbIIJJJ%dii&6&6&<&<&>&>??? !#ekr"2"2"8"8":": ; ;;r7z,^\s*\[Workspace::v1:\s*(?:\\.|[^\]\\])+\]\s*z^\s*\[Workspace:[^\]]+\]\s*z(\[Workspace::v1:\s*(?:\\.|[^\]\\])+\]\s*z\[Workspace:[^\]]+\]\s*ctt|pdddddS)Nr;\z\\rz\])r0replacers r5_escape_workspace_prefix_pathrPs2 tzr?? " "4 0 0 8 8e D DDr7c(dt|dS)Nz[Workspace::v1: z] )rPrOs r5_workspace_context_prefixrRs F;DAA F F FFr7include_legacyrTct|pd}td|d}|r#||krtd|d}|S)zDRemove WebUI-injected workspace tags without eating user-typed text.r;r)count)r0_WORKSPACE_PREFIX_REr_LEGACY_WORKSPACE_PREFIX_REr>)rrTrxrs r5_strip_workspace_prefixrYsh  OOE#''E';;HG(e++.222uA2FF >>  r7c(t|tr|ddkrdSdt |pdsdSt |dd}t|dg}ttfD]I}| |D]1}| || d 2Jtfd |DS) aMatch the current human turn even if an internal workspace tag leaked mid-text. Normal model-facing messages start with the workspace sentinel. A failed retry/merge path can also return an optimistic draft followed by the sentinel and the real prompt. Only treat that shape as the current turn when the text after the sentinel exactly matches the submitted prompt. rrFrr;rTrSNc3K|]>}dt|pdkV?dS)rr;N)rsr0r)rrneedles r5rz0_looks_like_current_user_turn..sL\\IsxxIO,,224455?\\\\\\r7)r/rqr\rsr0rrKrY_WORKSPACE_PREFIX_ANY_RE_LEGACY_WORKSPACE_PREFIX_ANY_REfinditerrrendr)r?rrrr;matchr\s @r5_looks_like_current_user_turnrbs c4 CGGFOOv$=$=u XXc(.b))//11 2 2F u B// 0 0D)$tDDDEJ,.MN22%%d++ 2 2E   d599;;<<0 1 1 1 1 2 \\\\Q[\\\ \ \\r7cd}d}|pgD]}t|ts|d}|dkr0t|d}|s|r|}\|r|rn]nU|dkrO|rMt|d}|dr|rt |r|r|}|r|rn|dd|ddfS) zReturn (first_user_text, first_assistant_text) snippets for title generation. Prefer the first substantive assistant answer in the opening exchange, skipping empty placeholders and assistant tool-call preambles. r;rrrrrwN)r/rqr\rKrCr user_text asst_textrArrs r5_first_exchange_snippetsrhs* II ^!T""  uuV}} 6>>%aeeI&6&677I  %  Y  [ Y %aeeI&6&677I uu\"" I 9WXa9b9b  &%    E TcT?IdsdO ++r7cd}d}t|pgD]}t|ts|d}|dkrP|sNt |d}|dr|rt |r~|r|}n.|dkr(|s&t |d}|r|}|r|rn|dd|ddfS) zReturn (last_user_text, last_assistant_text) snippets for title refresh. Walks the message list backwards to find the last user+assistant pair, skipping empty or tool-call-only assistant messages. r;rrrrwrNrd)r=r/rqr\rKrCres r5_latest_exchange_snippetsrj%s II hn" % %!T""  uuV}} ;  y %aeeI&6&677Iuu\"" I 9WXa9b9b  &% V^^I^%aeeI&6&677I &%    E TcT?IdsdO ++r7cTd}|pgD]}t|tr|ddkrp|dd}t|trdd|D}t |r|dz }|S) z9Count the number of user messages (rough exchange count).rrrrr;rc3K|]H}t|t|ddk0|ddVIdS)rrr;Nr/rqr\rgs r5rz#_count_exchanges..Hs\"y"yTUW[I\I\"yabafafgmananrxaxax155#4#4axaxaxax"y"yr7r)r/rqr\rrsr0r>)rrVrArs r5_count_exchangesrnAs E ^ a   155==F#:#:eeIr**G'4(( z(("y"yg"y"y"yyy7||!!##   Lr7c  ddlm}|}|dd}t|r"t |dkrt |ndS#t$rYdSwxYw)z9Read the auto_title_refresh_every setting (0 = disabled).rrauto_title_refresh_every0)rrr\r0r>isdigitr]r^)rsettingsvals r5_get_title_refresh_intervalrvNs,,,,,, =??ll5s;;s88>>++3355M#c((Q,,s3xxxAM qqsA)rwrderivedcurrentrs r5_is_provisional_titler|Ys2&&,"G ufVS#m&9r":":;;AACCGvsC (:$;$;<<BBDDI )u i r7rfassistant_textcBd|ddd|dd}ddg}||fS)NzUser question: rdz Assistant answer: aGenerate a short session title from this conversation start. Use BOTH the user's question and the assistant's visible answer. Return only the title text, 3-8 words, as a topic label. Do not use markdown, bullets, labels, or prefixes like Session Title:. Do not output a full sentence. Do not output acknowledgements or completion phrases like OK, done, or all set. Do not describe internal reasoning. Bad: The user is asking..., OK, all set. Good: Title Generation Test, Clarify Dialog Layout, GitHub Issue TriageaRewrite this conversation start as a concise noun-phrase title. Use the actual topic, not the task outcome. Return title text only. Do not use markdown, bullets, labels, or prefixes like Session Title:. Never output acknowledgements, completion status, or meta commentary.r)rfr}qapromptss r5_title_promptsresJ ZIdsdO Z ZNSWTWSWDX Z ZB V TG( w;r7rrrcdt|pdt|pdt|pdg}d|vpd|vS)Nrr;minimaxz minimaxi.com)rsr0r?)rrrrs r5_is_minimax_router~s 88 HN!!## EKR   HN!!##  D   6$ 66r7c| ddlm}|d}t|tr|niS#t$ricYSwxYw)zEReturn title_generation auxiliary config, or an empty dict on errors.r)_get_auxiliary_task_configtitle_generation)agent.auxiliary_clientrr/rqr^)rtgs r5_get_aux_title_configrsgEEEEEE ' '(: ; ;D))1rrr1  s ), ;;ct}|ddpd}|ddpd}|ddpd}t|p|p|o|dkS)zQReturn True when any auxiliary title_generation config field is meaningfully set.rr;rrr)rr\rr?)rrrrs r5_aux_title_configuredrs  Bvvj"%%+H FF7B   %2Evvj"%%+H NNh&M8>>3C3Cv3M O OOr7.@cN t}|d}||S t|}n5#ttf$r!t d|||cYSwxYw|dkr|St d|||S#t$r|cYSwxYw)aReturn the configured timeout (seconds) for auxiliary title generation. Only accepts positive numeric values. Falls back to *default* when the value is ``None``, non-numeric, zero, or negative, and emits a debug log so mis-configurations are visible in server output. r[Nz;aux title timeout: non-numeric value %r, falling back to %srz llm_lengthllm_length_auxrrs r5_title_retry_statusrs  r7c |dvS)uStatuses where re-issuing the next prompt against the same model produces the same failing shape (model burned its budget on hidden reasoning, hit a hard provider gate, etc.). Short-circuit the prompt-iteration loop so we don't issue a second full-budget LLM call (and twice the GPU/credit burn) only to land in the same fallback path. See issue #2083. Add a status here only when retrying the next prompt is provably wasted work (single-call signal already establishes that the next call will return the same shape). Length-truncation WITHOUT reasoning is NOT in the set — that's legitimately recoverable by a larger budget on a different prompt and stays in :func:`_title_retry_status`. >llm_empty_reasoningllm_empty_reasoning_auxrrs r5%_title_should_skip_remaining_attemptsrs  r7rvc|dSt|tr||St||d}|jjdrdS|S)N unittest.mock)r/rqr\r __class__ __module__r1)objrvrxs r5_safe_obj_valuersf {t#twws|| Cd # #E !,,_==t Lr7c|dS|jjdrdSt|pdS)Nr;r)rrr1r0r>rxs r5_safe_text_valuersJ }r !,,_==r u{   ! ! # ##r7r r c&|rdnd} t|dpg}|r|dnd}t|d}tt|d}|r|dfStt|d}tt|d p9tt|d ptt|d }|rdd |fS|d krdd|fSdd|fS#t$r dd|fcYSwxYw)zBReturn (content, empty_status) from an OpenAI-compatible response._auxr;choicesrNr9r finish_reason reasoningrythinkingrlengthr llm_empty)rrr?r^) respr suffixrchoicer9rrrs r5_extract_title_responsersm "VVF(!$ 228b&0D!&)44"?7I#F#FGG  B; ()Q)QRRXXZZ _WkBB C C F9L M MNN F D DEE   65V555 5 H $ $,F,,, ,'v'''' ((('v''''''(s%AC<BC<( C<5C<<DDc:|r|sdSt||\}}t}t|p|p|}|p|ddpd}t |dkrd}|p|ddpd}|p|ddpd}d} |s7t |ddpd} t|||} dd d ii} t|||rd | d < t} d dl m } d}t|D]\}}d|dd|dg}| g} t|D]\}}| d|pd|pd|pd| pd||d| |  }t|d \}}|r||d kr|d krdndfccS|pd}|d kr3t|r$|t!|||n8#t"$r+}d}t$d|dz|Yd}~nd}~wwxYwt)|rt$d|nd|fS#t"$r&}t$d|Yd}~dSd}~wwxYw) z2Return (raw_text, status) via auxiliary LLM route.Nmissing_exchangerr;rrrapi_keyrenabledFTreasoning_splitr)call_llm llm_error_auxrrrrNg?) taskrrrrr max_tokens temperaturer[ extra_bodyrllm_aux llm_aux_retry llm_empty_auxz*Aux title generation attempt %s failed: %srzIAux title generation short-circuiting after %s (reasoning-only response).zAux title generation failed: %s)Nr)rrrr\r0r>r?rrrrr enumeraterrrrrr^rrr)rfr}rrrrr configuredcaller_supplied_routerbase_max_tokensreasoning_extra_timeoutr last_statusidxpromptrbudgets budget_idxrrr` empty_statuses r5generate_title_raw_via_auxrs (N('' N;;KB&((J !>U!>h???:>>*b99?RH 8}}""$$..  6Z^^GR00 6BE?:>>*b99?RHG CjnnY339r::@@BB.xIIO"Y$67O5(332-1)*-%%''333333% $W--% % KC!f55B//H''G W.7.@.@bb*J #8/!)!1T#mt!)!1T '4!)#-$' (#2   D)@$(O(O(O%Ce"#((zQYYTcdddddd"."A/K!Q+>{+K+K'EhPUW_'`'`aaa%b& W W W-  I3QR7TUVVVVVVVV W 5[AA  _   [  %%% 6:::$$$$$$%sO+8I*$AH>I*>H?I* H5 !H0+I*0H554I** J4JJc|r|sdS|dSt||\}}tt|ddt|ddt|dd}dd i}t|d d} ||_t |D]\}} d | d d |d g} |g} d} t | D]\} }d}d}t|dddkrt|| }|ddd|vr||d<||}||\}}|r |j pdnd}|sd}nt|dddkrddl m }m }||j | d||t|dd |t|dd}||}||t|dd \}}|r |j pdnd}|sd}n|| }|ddd|d<d|d<t!t|ddt|ddt|ddr.t#|dpi}d|d <||d<d!|vr||d!<n||d"<|d#$jjjd-i|}t/|\}}t1|pd}|r||dkr| dkrd%nd&fcc||_S|pd} | dkr`t5| rQ| t9t|ddt|ddt|ddnX#t:$rK}d'} t<d(|d)zt|ddt|dd|Yd}~nd}~wwxYwtA| rt<d*| nd| f||_S#t:$r-}t<d+|Yd}~||_d,Sd}~wwxYw#||_wxYw).z1Return (raw_text, status) via active-agent route.rN)N missing_agentrr;rrrFreasoning_configrrrrapi_modecodex_responsestoolsmax_output_tokensanthropic_messagesr)build_anthropic_kwargsnormalize_anthropic_response_is_anthropic_oauth_anthropic_base_url)rrrrris_oauth preserve_dotsr)strip_tool_prefixrrrr[rTrmax_completion_tokensrrrllm llm_retry llm_errorzGAgent title generation attempt %s failed: provider=%s model=%s error=%srzKAgent title generation short-circuiting after %s (reasoning-only response).z!Agent title generation failed: %s)Nrr)!rrrrr_build_api_kwargspop_run_codex_stream_normalize_codex_responseragent.anthropic_adapterrrr_anthropic_preserve_dots_anthropic_messages_createrrqr\_ensure_primary_openai_clientchat completionscreaterr0r>rrrrr^rrr)rfrfr}rrrdisabled_reasoningprev_reasoningrr api_messagesrrrrr`r codex_kwargsrassistant_message_rr ant_kwargs api_kwargsrrs r5generate_title_raw_via_agentrds (N('' }$$ N;;KB.z2&&w##z2&&O $U+U$6==N\0!3$W--T T KC!f55B//L''GE ) .7.@.@::*J C#%Luj"559JJJ','>'>|'L'L $(($777.,>>@JL)<=$66|DD/4/N/Nt/T/T,)1CT\08>BZ\"7+6L  B77;OOOpppppppp%;%;"'+%1"&'1-?%,U4I5%Q%Q*/*H*H*J*J%,U4I4%P%P & & &  %?? KK/K/K GECXZ_4`4`000,)1DU\08>BZ\"7+6L%*%<%<\%J%J "w55547 =104 9-,WUJ-K-KWUZ\cegMhMhjqrwzDFHkIkIJJB)-jnn\.J.J.Pb)Q)QJ<@J'897AJ|42j@@BLJ'>??7AJ|4uuBBJ\B]]bnu  (  -DD,I,I)\ciR....00C]"cQhh:??UUP[\\\\\>"0=#/"=+K!Q+>{+K+K'E#E:r::#E7B77#E:r::((m:v   )  ]!GE:t44E7D11  5[AA  a   [ "0 !!! 8!<<<    !/ !"0////sc2)PI4NPA,NP OAOPO4P Q"Q =Q QQ Qct|||\}}|sd|dfSt|}|r||dfSddt|ddfS)zGGenerate a title via active-agent route, then sanitize/validate result.Nr; llm_invalidrW)rrDr0)rfrfr}r`rtitles r5%_generate_llm_session_title_for_agentrsi.uiPPKC  VR %c * *E !fb  C# ..r7)use_agent_modelrc|r6|r4t|dd}t|dd}t|dd}nd}d}d}t|||||\}}|sd|dfSt|} | r| |dfSddt|ddfS) aGenerate a title via dedicated auxiliary LLM route, then sanitize/validate result. When use_agent_model is False (default), the auxiliary client resolves provider/model/base_url from config.yaml auxiliary.title_generation, which prevents the session's chat model (e.g. a Chinese model) from overriding the dedicated title model. When True, the agent's attrs are passed through (legacy fallback behaviour). rr;rrrNllm_invalid_auxrW)rrrDr0) rfr}rfrrrrr`rrs r5#_generate_llm_session_title_via_auxrs55*b11w++5*b11, KC  VR %c * *E !fb  "CHHTcTN 22r7rr raw_previewc ||d}|r||d<|r||d<|r||d<|d|td|||pd|pd|pddd dS) N)rjrrrr title_statuszCtitle_status session=%s status=%s reason=%s title=%r raw_preview=%r-r;rW)rinfo) put_eventrjrrrrrs r5_put_title_statusr s'6::G #" ! -!,  Ing&&& KKM #   DSD! r7cz |pd}t|pd}|sdSt|}tjdd|}tjdd|}|d| |d|}dt dtfd}dt dt fd}||}|r||s._contains_latins BIk4:266777r7ctjd|}|r)|dpdStjd|}|r)|dpdSdS)Nz"([^"\n]{2,24})"rr;u“([^”\n]{2,24})”)r2rFgroupr>)rrAs r5_extract_named_topicz;_fallback_title_from_exchange.._extract_named_topics} I)4 0 0  .GGAJJ$"++-- - I/ 6 6  .GGAJJ$"++-- -rr7c3 K|]}|vV dSr~rrr@combineds r5rz0_fallback_title_from_exchange..+s'||Q1=||||||r7)rUschedule efficiencymanagefitnesssinging calligraphyzTime management discussionc3 K|]}|vV dSr~rrs r5rz0_fallback_title_from_exchange..-s'DDQ1=DDDDDDr7)recodexaizAI productivity discussionzConversation topicc3 K|]}|vV dSr~rrs r5rz0_fallback_title_from_exchange..0s'xxqH}xxxxxxr7z time managementc3 K|]}|vV dSr~rrs r5rz0_fallback_title_from_exchange..2s'@@qH}@@@@@@r7z AI productivityz discussionc3 K|]}|vV dSr~rrs r5rz0_fallback_title_from_exchange..6s' = =Q1= = = = = = =r7)rz session titlec3 K|]}|vV dSr~rrs r5rz0_fallback_title_from_exchange..6sHFCFCXYa8mFCFCFCFCFCFCr7)summarysummarz short titlec3 K|]}|vV dSr~rrs r5rz0_fallback_title_from_exchange..7s'AAqH}AAAAAAr7)testokzreply okzSession title auto-summary testzSession title auto-summaryc3 K|]}|vV dSr~rrs r5rz0_fallback_title_from_exchange..:s' ? ?Q1= ? ? ? ? ? ?r7)rZ clarificationc3 K|]}|vV dSr~rrs r5rz0_fallback_title_from_exchange..:s(GrGrZ[X GrGrGrGrGrGrr7)dialogcardzClarify dialog cardc3 K|]}|vV dSr~rrs r5rz0_fallback_title_from_exchange..<s' < .<s(DxDxWXQ(]DxDxDxDxDxDxr7)triagebugreviewzGitHub Issue Triagez[.!?\n]r>thefromhereintojustneedr&thatthisrwantwithaboutcouldneedsreplythererwantswouldpleaseshouldr#testingruA-Za-z0-9À-ÖØ-öø-ÿ[z][z_./+-]*<)r>r7rYr2rr?r0rrrfindallrrrrs)rfr} combined_rawrr topic_namerstop_en latin_wordtokenspickedtok lower_tokrs @r5_fallback_title_from_exchangerVsb''))I+N,@bAAGGIIN t' 22IvsI..4466IVFC88>>@@N..n..4466<<>>H22.2288::L8c8d888833&%l33J *z** (||||*{||||| 433DDDD*CDDDDD 433'' xxxx&wxxx x x 3 222 2 @@@@&?@@@ @ @ 3 222 2)))) = = = ="< = = ===,#FCFCFCFC^BFCFCFCCCCC, AAAA&@AAA A A 544++ ? ? ? ?"> ? ? ???%CGrGrGrGr_qGrGrGrDrDr%$$ < < < <"; < < <<<%DxDxDxDx\wDxDxDxAxAx%$$ 8J * *1 - 3 3 5 5D tG-J Z>Z>>:>>> E EF $## FIIKK   3y>>A#5#5  f   MM#    v;;!   E %xx$$  r7cpt|pddvS)zMReturn True for low-information fallback labels that should not be persisted.r;>conversation topicr=)rs r5_is_generic_fallback_titlerY`s2 u{   ! ! # # ) ) + +/E EEr7placeholder_titlec  t|}n1#t$r$t||ddY|dd|idSwxYwt|j}t |ddr:|s8t||ddt |jpd  |dd|idSt |jpd }||kp|d vpt||j p|} | s$t||dd | |dd|idSd d l m } | |dt5t} |r5| s3t|||\} } }| s| dvrt!|||d\} } }n1t!||\} } }| s|r| dvrt|||\} } }| }| s]t#||}|r.t%|std|} d}n|rtd|dddn #1swxYwY|dkr| rd| nd}d}|}| rt)|5t*5t-j||}t |jpd }t|j}||kp|d vpt||j p|} dddn #1swxYwY| s/t||dd | ddd|dd|idS| |kr-| |_d|_|d|j}d}dddn #1swxYwY|r?|dkrt||||||nt|||| |||d||dnt||d|pd|||dd|idS#|dd|iwxYw)zFGenerate and publish a better title after `done`, then end the stream.skippedmissing_session stream_endrjNllm_title_generatedFalready_generatedr;)UntitledNew Chatr; manual_titlerprofilesbackground titlelogger_overriderrTrfrrrz1Using local fallback for session title generationfallbackz@Skipping generic local fallback for session title generation: %rzlocal_summary: local_summarytouch_updated_atrrjr unchanged)rsKeyErrorr rCrrr0r>r|rapire!profile_env_for_background_workerrrrrrVrYrrrrr\r_r`)rjrfr}rZr rfr6_invalid_existingr{ still_auto profiles_apiaux_title_configured next_title llm_statusrrhfallback_titlefallback_reason wrote_titleeffective_titleinvalid_existing_nows r5_run_background_title_updateresGQ< J''AA    iY@Q R R R X  ,z :;;;;;] ;17CC 1+U 3 3 b0b0b:_`egpsA;B;B7J KF u!>y.!Y!Y!u*D^*T*TuLL!TUUU!/J'FF#uLL!cesttt% u u u u u u u u u u u u u u u*## # *Z ) ) )    !  '(44 ' '   Z33A&)!'-R&8&8&>&>&@&@O+I!'+R+R('+<<0*.JJ00!*MM00                "%iYXghhh ' ' ' ' ' '>  ,z :;;;;;#00(AG,0A)FFEF222&'gO"&K) ' ' ' ' ' ' ' ' ' ' ' ' ' ' ',  u##!)ZRacnoooo!)Z_^ijjj Igj?SS T T T T iY@U+Wfhs t t t ,z :;;;;; ,z :;;;;sN=AN=AAN=#AN=#N=5CH N=HN= H!(N= M A3K M K M K M 1 N= 3M ? N= MN=MAN==O c z t|}n#t$rYdSwxYwt|jpd}||krt ||dd|dS|r|dvrdSddlm}||dt 5t} |r5| s3t|||\} } } | s| d vrt|||d \} } } n1t||\} } } | s|r| d vrt|||\} } } dddn #1swxYwY| st ||d| pd|| dStjdd|} tjdd| }| |krt ||dd|| dSt!|5t"5t%j||}t|jpd|krRt ||ddt|jpd dddddddS| |_d |_|j}dddn #1swxYwY|ddddn #1swxYwYt ||d| || |d||dtd||dS#t.$r!td|d YdSwxYw)uRRefresh an existing LLM-generated title using the latest exchange text. Unlike _run_background_title_update, this does NOT guard on llm_title_generated — it assumes the title was already LLM-generated and the session has progressed enough to warrant a refresh. It does NOT emit stream_end (the caller already did). Nr;r\rcrarbrrdrfrgriTrjrkrefresh_skippedemptyr1r same_titleFrn refreshedrrpz/Adaptive title refresh: session=%s new_title=%rz.Background title refresh failed for session %sr)rsrrr0rr>r rsrertrrrrr2rr?rrrr\r_r`r r^r)rjrfr}rwr rfr6 effectiverwrxryrzrnormalized_currentnormalized_newr~s r5_run_background_title_refreshrs4b J''AA    FF  2&&,,..  % % iYPY Z Z Z F I)AAA F000000  ; ;A?Qci ; j j B B#8#:#:  B1 B6[\acln|6}6}3 J !\j4P&P&P:]^giw@EW[;\;\;\7J K6YZces6t6t3 J !BeB >b0b0b:_`egpsA;B;B7J K B B B B B B B B B B B B B B B  i5F H]V]_hju v v v FVFC;;AACCIIKKZ88>>@@FFHH  / / i5F V_al m m m F $Z 0 0 + + * *LQ//qw}"%%++-->>%iYX[\]\c\igiXjXjXpXpXrXrsss  * * * * * * + + + + + + + +%(,%"#' * * * * * * * * * * * * * * * FFEF * * * + + + + + + + + + + + + + + + )Zj/[fggg '*OOPPP EzSbccccc bbb Ez\` aaaaaabsL !L!AL'L/#LA7D LDLDL:BL LK!AB??M $X\\2L%M%M N N  $j1 & & &M %     & qz??] * * I!'!-G"O"OPPN"AL)-A & &-Q0BD%I%I ")04JD)Q)Q &(,WQ8Mr-R-R-XVX(Y(Y %'.q2F'M'M $!%A %)A "$&A !#'A  @ %@@@ PS__ ) -;*%;")C&(A%'?$$ ) -;*%;")C&(A%'?$???? F '&&&&&<<((  04H -)-H %,0H )+-H (*.H ' MM5UM C C C KKN       $ LLL JKKKKKK WWW FQU VVVVVVWs\J ABJ B41J 3B44B>J 3AG#8+J #,HJ A2J $K1%KKc t}|dkrdSt|jpd}|r|dvrdSt |ddsdSt |j}|dks ||zdkrdSt|j\}}|s|sdStj t|j |||||fd dS) zJCheck if the session is due for an adaptive title refresh and schedule it.rNr;rr_FTtargetargsdaemon) rvr0rr>rrnrrj threadingThreadrrjstart)rr rfrefresh_intervalrwexchange_countlast_ulast_as r5_maybe_schedule_title_refreshrTs2441 +,,2244M M-EEE 715 9 9%g&677Nn/??1DD.w/?@@NFF & , &&-E R egggggr7ct|ts|Sg}|D]]}t|ts|ddksd|vr6|t j|^|sdSt|dkrI|dddkr*t|ddpdS|S)aReturn provider-safe content with native image parts removed. Text-only provider endpoints (for example DeepSeek/OpenAI-compatible text models) reject historical OpenAI-style ``image_url`` parts before the agent can recover. When WebUI is configured for text-mode image handling, preserve textual content from mixed content arrays and drop only the native image blocks from replayed history. rrr;rrr) r/rrqr\rrcopydeepcopyrr0)r clean_partsrs r5&_strip_native_image_parts_from_contentrks gt $ $K00$%%   88F  { * *kT.A.A 4=..//// r ;1Q!3!3F!;!;v!E!E;q>%%f--3444 r7c$t|tr|sdSd}|D]}t|ts|d}|dvre|dp+|dp|dpd}t |rd}|dkrNt |dp|d pdrdS|d vrdS|S) NFr>rrrrrr;Tr>rrr)r/rrqr\r0r>)r saw_reasoningr part_typers r5!_content_has_reasoning_only_partsrs+ gt $ $GuM  $%%  HHV$$ 1 1 188J''Z488K+@+@ZDHHVDTDTZXZD4yy   % $    3txx'7'7'T488I;N;N'TRT#U#U#[#[#]#] 55 = = =55 > r7ct|tr|ddkrdS|drdS|dd}t|rdSt |dp|dpdrd St |S) a&Return True for display-only assistant Thinking entries. These entries keep partial Thinking cards visible after reload/cancel, but they are not API-safe history: providers only see a blank assistant turn. Visible assistant replies that also carry reasoning metadata are kept. rrFrwrr;rryT)r/rqr\rKr>r0r)r?rs r5$_is_reasoning_only_assistant_messagers c4 CGGFOO{$B$Bu ww|uggi$$GW##%%u 377;   E377+>#?#? E2FFLLNNt ,W 5 55r7c|duot|dk}t}|D]}t|ts|ddkrr|dpgD]Z}t|trC|dp|dpd}|r||[g}|D]7}t|tst |r)|d r?|d r7t|d pds|d}|d kr|d pd}|r||vrd| D} |r)d | vr%t| d | d <| dr| | 9|S)aReturn a deep copy of messages with only API-safe fields. The webui stores extra metadata on messages (attachments, timestamp, _ts) for display purposes. Some providers (e.g. Z.AI/GLM) reject unknown fields instead of ignoring them, causing HTTP 400 errors on subsequent messages. Also strips orphaned tool-role messages whose tool_call_id cannot be linked to a preceding assistant message with tool_calls. Strictly-conformant providers (Mercury-2/Inception, newer OpenAI models) reject histories containing dangling tool results with a 400 error: "Message has tool role, but there was no previous assistant message with a tool call." If ``agent.image_input_mode`` resolves to ``text``, native historical ``image_url`` content parts are stripped too. Current-turn uploads already respect text mode in ``_build_native_multimodal_message``; this closes the remaining replay gap where an older native image in the saved transcript kept causing 400s on every later text-only turn (#2297). Nrrrrwidcall_idr;rL_partialrtoolrxc,i|]\}}|tv||Sr_API_SAFE_MSG_KEYSrr@vs r5 z._sanitize_messages_for_api..)MMMdaQ:L5L5LQ5L5L5Lr7) r setr/rqr\rrr0r>rrrr) rr_strip_native_imagesvalid_tool_call_idsr?tctidrr sanitizeds r5_sanitize_messages_for_apirs5&T/V.G.L.LPV.V #uu55#t$$   776??k ) )ggl++1r 5 5b$''5&&,,A"&&*;*;ArC5+//444 E$$#t$$   0 4 4   778     77:   s3779+=+=+C'D'D'J'J'L'L  wwv 6>>''.))/RC #%888MMciikkMMM  d9 #9#9#I)--XaJbJb#c#cIi ==  $ LL # # # Lr7ct}|D]}t|ts|ddkrr|dpgD]Z}t|trC|dp|dpd}|r||[g}t |D]\}}t|tst |r,|drB|dr7t|d pds|d}|d kr|d pd}|r||vrd | D}|dr| ||f|S) zCReturn [(original_index, sanitized_message)] for API-safe messages.rrrwrrr;rLrrrrxc,i|]\}}|tv||Srrrs r5rz/_api_safe_message_positions.. rr7) rr/rqr\rrrr0r>rrr) rrr?rroutrrrs r5_api_safe_message_positionsrs"uu55#t$$   776??k ) )ggl++1r 5 5b$''5&&,,A"&&*;*;ArC5+//444 Ch''))S#t$$   / 4 4   778     77:   s3779+=+=+C'D'D'J'J'L'L  wwv 6>>''.))/RC #%888MMciikkMMM ==  ) JJY' ( ( ( Jr7c|s|St}g}|D]D}t|}|||vr|||||E|S)zRemove duplicate messages from context by identity, keeping first occurrence. Prevents the agent from seeing the same message twice in conversation_history when result_messages contain duplicates that weren't caught by display-merge. )r_message_identityrrr)rseendedupedr?rvs r5_deduplicate_context_messagesr sy  55DG$$ ?sd{{  ? HHSMMMs Nr7cB|r|s|St|}t|}d}d}|t|kra||\}}||}|t|kr||nd}t|trt|tr||||kr|ddkr5|dr |ds |d|d<|dr!|ds |d|d<nJ|dr5|ds |ds |d|d<|d z }\|d z }|t|ka|S) arCarry forward display-only metadata lost during API-safe history sanitization. The provider-facing history strips WebUI-only fields like `reasoning`. When the agent returns its new full message history, prior assistant messages come back without that metadata unless we merge it back in by API-history position. This also preserves existing timestamps for unchanged historical messages. Without that, older turns that come back from the agent without `_ts` / `timestamp` can be re-stamped with the current time on every new assistant response, making prior messages appear to "move" in time. crttsdSfdDS)NcXi|]&\}}|tvd#||'S)r)rr\)rr@rr?s r5rzI_restore_reasoning_metadata.._safe_projection..8 s:\\\A5G0G0GCGGTZOO0G10G0G0Gr7)r/rqrr?s`r5_safe_projectionz5_restore_reasoning_metadata.._safe_projection5 s<#t$$ 4\\\\\\\\r7rNrrrrO_tsr)rrrr/rqr\) previous_messagesupdated_messages prev_safersafe_posprev_idxrprev_msgcur_msgs r5_restore_reasoning_metadatar$ s  $4 ,--+,=>>I]]] H S^^ # #) !$X.083?O;P;P0P0P"8,,VZ h % % *Wd*C*C HXHXYaHbHbfvfvw~ffHH||F##{22x||K7P7P2Y`YdYdepYqYq2'/ '< $||K(( 11I 1'/ '< $$e$$ 1W[[-?-? 1 T_H`H` 1!)% MH A  S^^ # #" r7ct||}|r|s|St|}d|D}d}t|D]\}|vst|st fd|D|z}|t |kr||nd}t |trt|ry||tj ||dz }|S)zFRestore display-only thinking rows for visible transcript persistence.ch|]\}}|Srr)rrrs r5rz6_restore_display_reasoning_metadata..U s000FCC000r7rc3.K|]\}}|k dVdS)rNr)rrrrs r5rz6_restore_display_reasoning_metadata..Z s+CCVS!C(NNqNNNNCCr7Nr) rrrrsumrr/rqinsertrr) rrr safe_indicesinserted_reasoning_onlyrrrrs @r5#_restore_display_reasoning_metadatarO s123DFVWW  $4 +,=>>I00i000L'(9::%%( | # #+OPX+Y+Y # CCCCyCCCCCF]]19C@P    !r!r7cFt|tsdSt|dpd}|dd}t |}|dkrt |d}|s|ds|dsq|d rZd t|d pddd }|ddd |zfSdS|d t|pdddt|dpdtj |dpgddfS)Nrr;rrTrSrxrwrrr __partial__rdF sort_keys ensure_ascii) r/rqr0r\rKrYrsrrdumps)r?rrr reasoning_keys r5rrk s c4 t swwv$" % %Dggi$$G  ! !D v~~ 'tDAAA // 8M8M 77:   HHS)=)=)C%D%D%J%J%L%LMMdsdSM -   t  TZR&&(())$3$/ CGGN # # )r** 377<((.B$USSS  r7ct|pgt|pgkrdSt|pgD]0\}}t|pg|t|krdS1dS)NFT)rrr)rprefixrexpecteds r5_messages_have_prefixr s 8>rS2....u"6|S)aDrop a candidate prefix that is already the suffix of existing_messages. Compression/continuation can replay the active tail from state.db after the previous WebUI context/display already contains it. Prefix-only merge logic then treats that replayed tail as a fresh delta and duplicates a whole turn. Strip the largest exact suffix/prefix overlap before appending. rrc,g|]}t|Srrrs r5rz*_strip_replayed_prefix.. s!MMM1#A&&MMMr7Nc,g|]}t|Srrrs r5rz*_strip_replayed_prefix.. s!FFFA$Q''FFFr7)rrrrange)existing_messagesr max_overlapoverlapleftrights r5_strip_replayed_prefixr  s.4"55j&B''Jc+,,c*oo>>Ka,,((MM0A7())0LMMMFFHWH1EFFF 5==ghh' ' ' '  r7ct|trt|tsdS|d|dkrdSdt |dd}dt |dd}t |dkst |dkrdSd}||r||sdS|dd |dd kS) a%Return True for repeated LCM/session summaries with refreshed hints. LCM summary cards can be re-injected with the same long recovered context and a different tail such as an expand hint. Exact identity misses those, but appending both copies bloats every later model prompt. Frrrr;iz[Session Arc SummaryNi)r/rqr\rsrKrrr1) previous_msg candidate_msg previous_textcandidate_textmarkers r5(_looks_like_replayed_session_arc_summaryr s> lD ) )M41P1Pu=#4#4V#<#<<<uHH]<+;+;Ir+J+JKKQQSSTTMXXmM,=,=i,L,LMMSSUUVVN =D  C$7$7$$>$>u #F  # #F + +>3L3LV3T3Tu $ >%4%#8 88r7c  t|pg}t|pg}|r|s|Sd|D}d|D}d|D}g}d}d}|t|kr|| t fd|Dr|dz }=d}tt|D]} d} || zt|krw| | zt|kra||| z|| | zkrI| dz } || zt|kr.| | zt|kr||| z|| | zkI| |kr| }||kr||z }| |dz }|t|k|S)zDDrop replayed non-adjacent context blocks before persisting context.c,g|]}t|Srrrs r5rz1_strip_replayed_context_items.. s!GGG(++GGGr7c,g|]}t|Srrrs r5rz1_strip_replayed_context_items.. s!AAA)!,,AAAr7c<g|]}t|t|Sr)r/rqrs r5rz1_strip_replayed_context_items.. s'JJJAjD6I6IJaJJJr7rrJc38K|]}t|VdSr~)r)rprevr?s r5rz0_strip_replayed_context_items.. s.^^t7cBB^^^^^^r7r)rrrrrr) rr existing_keyscandidate_keysexisting_largecleanedr min_blockbestrrr?s @r5_strip_replayed_context_itemsr s.4"55j&B''J JGG5FGGGMAAjAAANJJ!2JJJNG CI J  o ^^^^~^^^ ^ ^  1HC 3}--..  EFf s>2222FNS%7%777"3<0M%&.4QQQ!  f s>2222FNS%7%777"3<0M%&.4QQQ}} 9   4KC s q- J  . Nr7ct|pg}t|pg}|r|s|St||s|S|t|d}t||}|rt ||}||zS)zAKeep model context append-only without replayed blocks/summaries.N)rrrr r)previous_contextresult_messagesrs r5!_dedupe_replayed_context_messagesr! s,233?0b11O ? 2B C C %5!6!6!7!78J'(8*EEJQ23CZPP j ((r7c"t||S)zDKeep model context append-only without re-appending a replayed tail.)r!)rr s r5_dedupe_replayed_active_contextr# s ,-= O OOr7c t|Sr~)r!rs r5_is_context_compression_markerr% s ( - --r7@raw_textrSct|tsdS|}|sdStjdd|}t ||kr|d|dz d}|S)z8Normalize a text blob used in compression summary cards.Nr1rrir2)r/r0r>r2rr)r'rStxts r5_compact_summary_textr* s h $ $t ..  C t &c " " ( ( * *C 3xx%[uqy[!&&& Jr7ct|tsdSt|dpd}|r|dkrdS|dd}t |}t |dkr |dd}|dp|d}|d}t|t rt |nd }|s|s|sdS||||d S) Nrr;rrrrOr%r)rtsrr%)r/rqr0r\rKrr)r9rrrr-r% attach_counts r5_compression_anchor_message_keyr/ s  gt $ $t w{{6""(b ) )D 46>>tkk)R((G  ! !D 4yy3DSDz U   7w{{;77B++m,,K'1+t'D'DK3{###!L  RtD N NNr7ct|pgD]P}t|tst|s(t |d}|r|cSQdS)Nr)r=r/rqr%rKr\)rrArs r5"_compression_summary_from_messagesr1/ sy hn" % %!T""  -a00  QUU9--..  KKK  4r7c dt|pd}d}t|pgD]\}}t |t r|ddkr4|}t||r|cSdtt|ddd}|r ||vs||vr|cS|S)Nrr;rrrTrS) rsr0rrr/rqr\rbrYrK)rrr\rlrr?rs r5_find_current_user_turnr3; s  XXc(.b))//11 2 2FHhn"--  S#t$$ 6(A(A  (h 7 7 JJJxx #cggi4455#   egg     v~~JJJ Or7ct|pg}|s|Std|d}|r#t|d|kr |ddS|S)zEReturn model history without an eager-checkpointed current user turn.rrrN)rr)rrhistorycurrent_user_keys r5,_drop_checkpointed_current_user_from_contextr7O si8>r""G (&X)N)NOO-gbk::>NNNss| Nr7cddlm}||dt5|dddddS#1swxYwYdS)zCPersist a streaming checkpoint under the session's profile context.rrdzstreaming checkpointrgT)rN)rsrertrr`)rrws r5_save_streaming_checkpointr9Z s,,,,,,  7 7 8  &&   %%% &&&&&&&&&&&&&&&&&&sAA A ctt|pdd}tjdd|}|dS)Nr;TrSr1ru .!?。！？,，~～)rYr0r2rr>r?rs r5_normalize_fresh_chat_textr;f s\ "3tzr??4 H H HD 6&#t $ $ * * , , 2 2 4 4D ::3 4 44r7ct|rtdkrdSd}tfd|DrdSdvS)zGReturn True for short opener messages that should not resume old tasks.F)continueresumezcarry onzgo onu继续u接着u往下u 下一步c3 K|]}|vV dSr~r)rtermrs r5rz0_is_casual_fresh_chat_message.. s' 7 7D44< 7 7 7 7 7 7r7> 嗨你好哈喽在么在吗您好hi there hello therehiheyhello)r;rr)rcontinuation_termsrs @r5_is_casual_fresh_chat_messagerNl sr %h / /D 3t99r>>u  7 7 7 7$6 7 7 777u  r7c|pgD]p}t|tst|dd}|sPd|vrd|vrYd|vsd|vs d|vsd|vsd |vrd Sqd S) zJDetect compacted model context that tells the agent to resume an old task.rr;zcontext compactionzcontext compressionz active taskzresume exactlyz current taskztask list was preserved in_progressTF)r/rqrKr\r?)rr?rs r5"_has_task_resume_compaction_markerrQ s~2#t$$  SWWY3344::<<   t + +0ET0Q0Q  T ! !4''%%(D00$$44% 5r7cft||}t|rt|rgS|S)zGReturn provider-facing history for a new user turn from a message list.)r7rNrQ)rrr5s r5_new_turn_context_from_messagesrS s<:8XNNG$X..3UV]3^3^ Nr7c<tt||S)a%Return provider-facing history for a new user turn. Compacted agent sessions can carry a hidden "resume the active task" summary in context_messages. If the user starts a fresh casual greeting in that old session, do not feed that stale active-task summary back to the model. )rSr)rrs r5_context_messages_for_new_turnrU s ++DW+M+Mx X XXr7cJt|ot|dd|kS)a/Return True only while a worker still owns the session writeback. cancel_stream() intentionally clears ``active_stream_id`` early so the UI can accept a follow-up turn while the old worker is unwinding. That old worker must not later persist its stale result over the newer transcript. rQN)rr)r stream_ids r5_stream_writeback_is_currentrX s'  ?? Vww0BDIIYVVr7ct|ddrdSt|ddrdSt|ddrdStt|ddpg}t|dkrdS|d}t|tr|d sdS|d d krdSt |d pd }d|vsd|vrdSdt |pd }|sdSt|ddD]}t|ts|d r.|ddkrHdt |d pd }||kcSdS)aAllow a finishing worker to replace its own stale-repair marker. The stale-pending repair path can occasionally run while the original worker is still alive but temporarily missing from the in-memory stream registry. It clears ``active_stream_id`` and appends a "Response interrupted" marker. If the original worker later finishes, treating ``active_stream_id is None`` as stale drops the real answer and leaves the misleading marker visible. This is intentionally narrow: only a session with no active/pending turn and whose last visible row is the recovery marker for this exact user prompt may be superseded. If a newer turn has appended anything after the marker, the normal stale-writeback guard still wins. rQNFrRrSrrrrLrrrr;rzbefore this turn finishedrrr) rrrr/rqr\r0rsrr=)rrrlastrrr?actuals r5/_stream_writeback_can_supersede_recovery_markerr\ sw*D11uw.55uw-t44uGGZ66<"==H 8}}qu B_merge_display_messages_after_agent_result.. s6   -a00    r7c,h|]}t|Sr)rrs r5rz=_merge_display_messages_after_agent_result..( s! 1 1 1Q a 1 1 1r7rrc3^K|]'}t|kpt|V(dSr~)rrb)rrAr6rs r5rz=_merge_display_messages_after_agent_result..* sW%%  ! 00^4QRSU]4^4^%%%%%%r7rc3nK|]0}t|to|ddvV1dS)r)rrNrmrs r5rz=_merge_display_messages_after_agent_result..9 sU   q$   JAEE&MM5J$J      r7rrrrr)rrr=r/rqr\rrrrrrrrr r3rrrbr%rr)previous_displayrr r _partial_seen _deduped_revrArv_dedupedrcurrent_user_idxmarker_candidatesturn_candidatesmergedrcurrent_user_in_candidates!current_user_already_checkpointedcurrent_user_msg insert_atr?is_current_user_turn display_msgr6s ` @r5*_merge_display_messages_after_agent_resultrp s7,233EEML & ' ' a   '155#4#4 '#A&&C-''!!#&&&AH\**++H 8}}s+,,,, \  ! !CMM 137G3H3H#h--    ,233?0b11O  _.>?? 9$S)9%:%:%;%;< +,R"9#:"&*--1AAA0XFFB  O3%% ;../!&*--44  )# . . 3?sd{{  o#)9"9"9>R"93%%#:6))-,,K%-K " dmK00111 ? HHSMMM Mr7c t|pg}t|pg}t||r|t|d}n!t||}| ||dzdn|}t d|DS)zEReturn True only when the just-finished turn produced assistant text.Nrc3 K|]~}t|tod|ddkoK|d o5t|dpdVdS)rrrLrr;N)r/rqr\r0r>rs r5rz<_assistant_reply_added_after_current_turn.. s  1d 0 EE&MM[ ( 0h  0 i  &B ' ' - - / / r7)rrrr3r)r rrrrfs r5)_assistant_reply_added_after_current_turnrsv s?0b11O,233_.>??q$S)9%:%:%;%;< 2?HMM?O?[_%5%9%:%:;;ap     r7ri.i]capruc|sdS ddlm}t||pd}n#t$rd}YnwxYw|dkrdSt |t|pdS)a(Return a bounded rough token delta for live tool metering. Tool-result callbacks can fire before the agent's next exact prompt accounting is available. The live usage ring should show a conservative in-flight hint, not replay a full large tool payload into `last_prompt_tokens`. r)estimate_messages_tokens_rough)agent.model_metadatarwr]r^r)rrurwdeltas r5_bounded_live_tool_prompt_deltarz s qGGGGGG228<<ABB  zzq uc#(mm $ $$s ' 66)exact_prompt_tokensrruturn_tool_prompt_tokensturn_capbase_prompt_tokensr{r|r}c4t|pd}t|pd}|r ||kr|dddStdt|pd}tdt|pd} t|t||z| } || zd| dS)zCompute the live `last_prompt_tokens` estimate after a tool update. Exact compressor/provider prompt accounting wins. When no newer exact prompt is available, add only bounded live tool deltas to the persisted base. rF)last_prompt_tokens estimatedr|rtT)r]rrrz) r~r{rrur|r}baseexactprior_turn_delta turn_ceilingnext_turn_deltas r5+live_usage_prompt_estimate_after_tool_deltar s !&Q ' 'D #(q ) )E  $"''(   1c"9">Q??@@q#hm!,,--L:8MMMMO #_4#2  r7c|dkrdSt|pd} t|tr|ntj|}t|trP|dp+|dp|dp|}t|}n#t $rYnwxYw|d|S)zDExtract a bounded result preview from a stored tool message payload.rr;rrrN)r0r/rqrrr\r^)r`rSrr,previews r5_tool_result_snippetr s zzr syb>>D  d++AssD1A1A dD ! ! hhx(([DHHX,>,>[$((7BSBS[W[Gw<. sR | | |2Jr44H4H |RVVTZ^^ |`b`f`fgm`n`nr{`{`{B`{`{`{r7r`rrrrK)rS) rr/rqr\rrrr^rrrrrr)rlive_tool_callsrw pending_names pending_argspending_asst_idxtool_msg_sequencerrArrrrrfnrrr`seqliveseq_idxlive_tcs r5!_extract_tool_calls_from_messagesr s8JMLB//+*+* !T""  uuV}} ;  eeIr**G'4(( <#<r)r9tool_sig tool_callargs_sigs r5_partial_message_signaturer0 s gt $ $|H[[!677=2  )T**   8z f%%+" HH  8 8 89==006B77HHH 8  f%%+ , ,  vu-- . . z511 2 2  i((JIMM),D,DJ K K       GKK " " (b))//11 GKK $ $ *++1133 h s 2A>>.B/.B/ before_idxrrc dt|trt|tsdSt|tr|nt |}t dt |t |}d}t|dz ddD]?}||}t|tr |ddkr|dz}n@t|}|||D]B}t|tr+|drt||krdSCdS) zECheck for an equivalent partial marker in the current user turn only.FrrrrrrT) r/rrqr]rrrrr\r)rrrr`rrr? candidate_sigs r5_partial_marker_already_presentrO s5 h % %Z 4-H-Hu":s33 F**XC aS#h--(( ) )C ES1Wb"%%sm c4  SWWV__%>%>!GE E.y99Mc " c4  SWWZ%8%8 =WX[=\=\`m=m=m44 5r7cd|dtj|dd}|j|d|jdS)z+Write one SSE event to the response stream.zevent: z data: F)rr|rN)rrwfilewriterflush)handlereventr,rs r5_sserb seQQQtz$U'K'K'KQQQG Mw//000 Mr7c btt|ddpd}|sdSd|}|rt t t|ddpgddD]}t |tr|dd kr1dt|d pd}||krdSttj }t|d d}t |ttfr|d krt|}d ||d d}t|dd}|rt ||d<|j |d S)aPersist the pending user prompt before clearing runtime stream state. Error paths often clear ``pending_user_message`` before appending an assistant error marker. In deferred session-save mode that pending field can be the only durable copy of the user's current turn, so clearing it makes the user bubble disappear on reload/reconcile. Return True when a recovered user turn was appended. rRNr;FrrirrrrTrT)rrrO _recoveredrSr%)r0rrsrr=rr/rqr\r]rUrrrr) r pending_textnormalized_pendingrr recovered_tsrT recoveredrSs r5rPrPi sww(>EEKLLL u,"4"4"6"677 ggz4&H&H&NB!O!OPRPSPS!TUU  Hh-- f1E1E1O1OHHSi)@)@)FB%G%G%M%M%O%OPPM 222uu3ty{{##L *>EE$sEl33/8JQ8N8N-.. ! I "'+@$GG=#'(;#<#< -  I&&& 4r7c ddlm}m} |tvr!t|rdS||j}|dz d|jdz }||ntj}|5||||dddddS#1swxYwYdS#t$r.t d t|d d YdSwxYw) zFinal-exit guard: if the stream exits with pending_user_message still set, sync messages from the core transcript or add an error marker. Called from the outer finally block of _run_agent_streaming. Must never raise. r)_get_profile_home _apply_core_sync_or_error_markerNsessionssession_rF)stream_id_for_recheckrequire_stream_deadz1_last_resort_sync_from_core failed for session %srj?) rrrris_setrkrj contextlib nullcontextr^r exceptionr)rrW agent_lockrrr core_path _lock_ctxs r5_last_resort_sync_from_corer sw ONNNNNNN   $ $i)@)G)G)I)I $ F((99  :-0T7;M0T0T0TT ","8JJj>T>V>V    , ,&/$)                            ? G\3 / /       s:(B:B.B > B BBBB4CCc ddlm}m}ddlm}m}m}ddlm}|} | st ddS|5| |ddddn #1swxYwY|||||} t d||| S#t$r(} td ||| Yd} ~ dSd} ~ wwxYw) aTry to silently refresh credentials after a 401/auth error (#1401). Returns a new ``(agent, rt_dict)`` tuple on success so the caller can retry the conversation. Returns ``None`` when self-heal is not applicable (e.g. auth.json unchanged, provider unresolvable). Steps: 1. Re-read ``~/.hermes/auth.json`` to pick up fresh credentials that may have been written by a concurrent ``hermes model`` CLI invocation. 2. Evict the session's cached agent so it is rebuilt with fresh keys. 3. Evict the provider's credential-pool cache entry. 4. Re-resolve the runtime provider. 5. Return a new agent + resolved-provider dict (the caller must re-invoke ``run_conversation`` with these). r)read_auth_json0resolve_runtime_provider_with_anthropic_env_lock)SESSION_AGENT_CACHESESSION_AGENT_CACHE_LOCK invalidate_credential_pool_cacheresolve_runtime_providerz7[webui] self-heal: auth.json empty or missing, skippingN requestedzJ[webui] self-heal: credential refresh succeeded for provider=%s session=%sz8[webui] self-heal: failed for provider=%s session=%s: %s) api.oauthrrrrrrhermes_cli.runtime_providerrrrrr r^warning) provider_idrj_agent_lock_refrrrrrr _fresh_auth_new_rt _heal_errs r5_attempt_credential_self_healr s$(                   IHHHHH%n&&   LLR S S S4& 6 6  # #J 5 5 5 6 6 6 6 6 6 6 6 6 6 6 6 6 6 6 )(555CB $!     X      F Y   ttttt sA>B(B(A' B('A++B(.A+/8B(( C2CCc|dSddl}||pdddS)aReturn the cache-signature component for runtime credentials. Credential-pool providers can legitimately hand WebUI a different runtime token on each request (round-robin pools, OAuth refresh, auth self-heal). The AIAgent object is also where cross-turn memory-provider state lives, so using the volatile token itself in the cache signature silently defeats the per-session agent cache and drops warmed Hindsight prefetch results. Nzcredential-poolrr;r)hashlibsha256r hexdigest)r*credential_pool_hashlibs r5_agent_cache_api_key_sigr sU"   ??,2::<< = = G G I I#2# NNr7 agent_kwargsc |t|tsdS|d}| ||_n#t$rYnwxYw|dpd}|sdS|dpt |ddpd}t |ddrdS|t |ddpdkrt |dS t |d dd krt|d r||d pt |d d|d pt |d d|||d pt |d ddSdSt|drt|ds!||_ |r||_ t |dStt |dipi}||d<|r||d<||_ ||_ |r||_ t|dr| |j t|d}|rt ||S#t$r tddYdSwxYw)awRefresh volatile runtime credentials on a reused cached AIAgent. The cache key intentionally ignores credential-pool token churn, but the cached agent's LLM client still needs the latest selected/refreshed runtime key. Keep long-lived provider/session state (memory prefetch, turn counters, tool state) while swapping only the runtime credential/client. NFrrr;Tr_fallback_activatedrr switch_modelrr)rrr_client_kwargs_replace_primary_openai_client"_apply_client_headers_for_base_urlwebui_credential_refreshrz:[webui] Failed to refresh cached agent runtime credentialsr)r/rqr\_credential_poolr^r._refresh_cached_agent_primary_runtime_snapshothasattrrrrrrrrrr)rfrnew_poolnew_keynew_base client_kwargsrebuilts r5_refresh_cached_agent_runtimer s }J|T::}u 122H %-E " "    D y))/RG t ++Swuj"/M/MSQSHu+U33u75)R006B776u===t( 5*d + +/C C Cun-- "" $$W--N1N1N $$Z00TGE:t4T4T#%)--j99[WUJXZ=[=[ #t5u.// wuFf7g7g $EM *!) :5 A A A4WU, ? ? E  4 4U^ D D Du;;C];^^__  B :5 A A A  Q\` aaauus/: AA B+I8?I9B"I&JJc~t|dd}t|tsdSt|d|d}t|d|dd}tt|ddp|dipi}||d<||d<||d<t|dd}|_t |dr||_t |dr||_d |vrt|d||d <d |vrt|d||d <nd |vr||d <d |vr||d <t|d dd krkt |d rt|d |d<t |drt|d|d<t |drt|d|d<dSdSdS)amKeep AIAgent's primary-runtime snapshot aligned with refreshed creds. Long-lived AIAgent instances use `_primary_runtime` to restore the preferred provider after fallback/transport recovery. If WebUI refreshes a cached agent's runtime token but leaves that snapshot stale, a later restore can resurrect the old credential and undo the refresh. _primary_runtimeNrrr;rrcontext_compressorcompressor_base_urlcompressor_api_keyrr_anthropic_api_keyanthropic_api_keyranthropic_base_urlris_anthropic_oauth)rr/rqr\rrr)rfrtrrrccs r5rrE s& *D 1 1B b$  uj"&&*<*<==HeYy"(=(=>>G(8$??d266/[]C^C^dbdeeMBzNByM'B ,d 3 3B ~ 2z " " #"BK 2y ! ! ! BJ B & &(/J(I(IB$ % 2 % %'.r9g'F'FB# $ B & &(0B$ % 2 % %'.B# $uj$''+??? 5. / / K&-e5I&J&JB" # 5/ 0 0 M'.u6K'L'LB# $ 5/ 0 0 M'.u6K'L'LB# $ $ $ @?  M Mr7)r^model_provider goal_relatedc      !"#$%tj##dSttjdt |||t | t $n0#t$r#d$t ddYnwxYw|sS tdtjdn,#t$rt d dYnwxYwd%i} d} d} d} d} d}d}i}tj !t5!t<d t<d t <gt"<dddn #1swxYwYd d gd gd gt%d t&f fd d t&ffd  fdt)tj "fd}tj|d}|!#$fd""fd}d d}d t1%t3dt t5|%_|%_|3t | ntC%dd}|pd%_"tG!$r5tK%|ddddn #1swxYwY"dddi   ||&d%LtC%ddkr6tC%ddr$t3d !tO%tQt5tj)dtj)dtUj)dtj)dt!j)dt#j)dtWj)dtYj)dt[ddddS#1swxYwYdS d d"l.m/}m0}m1}|tC%d#d}t |}||}n4#td$r'tfj4d$d }i}d}YnwxYwtC%d#d}|s$ d d%l.m5}|}n#t$rd}YnwxYwtm|t %j|}tod=i|tqtr5d&|D}tfj4d'} tfj4d(} tfj4d)} tfj4d*} tfj4d+}tfj4d$}tfj4:|t %jtfj4d'<d,tfj4d(<tfj4d)<tfj4d*<d-tfj4d+<|r)|tfj4d$<||t5|dddn #1swxYwY d d.l;m<}|n#t$rYnwxYwd/} d}! d d0l=m>}"m?}!"fd1}#|"|#d} n*#td$rt d2YnwxYwd/}$d}% d d0l@m>}&m?}%"fd3}'|&|'d}$n*#td$rt d4YnwxYwd5 d/d/}(d gtjAd6z gd gd g"fd7 d8td tfd9 d:td t f fd;   "fd<})  "fd=}* "fd>}+d gt%t%d?fd@fdA  "f dB},"fdC}-"f dD}.t}/|/tetd}0 d dElDmE}1|rt5|dFz nd}2|1|2G}0n+#t$r}3tdH|3dIYd}3~3nd}3~3wwxYwtt||\}4}5}6d}7 d dJlImJ}8d dKlKmL}9|8|9|5L} | dM}7|5s| dN}5|6s| dO}6n+#t$r}:tdP|:dIYd}:~:nd}:~:wwxYwt|5|7|6\}5}7}6d dQlNmO};|;}"dSt|=dTd dUlNmR}?|?|<}@ d dVlSmT}AmU}B|BdWz }C|CVr.|AW}D|DrtC|DdXdnd}E|Er|E}@n.#t$r!}FtdYdZ|FdIYd}F~Fnd}F~FwwxYwd[}Gg}Ht%}Id}Jd\D]?}K|G|<|KD]}Lt |LdNpd  t |Ld]pd  t |LdOpd Xd^ f}M|M|Ivr|IY|M|HZ|LA|Hpd}Jd dl[}Nt%|N\|/j]j^d}O d}Pt||)|*|, !"fdde}[dfvr|Z|Z|[df<dgvr|[)dgddhvr|+|[dh<divr|-|[di<djvr|.|[dj<dkvr||[dk<dlvr|O|O|[dl<davr|S|S|[da<dmvr| dm|[dm<dnvr| do|[dn<dpvr| dq|[dp<drvr| dr|[dr<dsvr|[ds<|r'|/d=i|[ t dtnd dlb}\d dlc}]d dulNmd}^me}_| dr}`|]f|4pd t|7|`|6pd |5pd | dmpd | dopd | dqpgt |`|Opd |Spd |Jpi|@rt|@ng|Zpit|=|pd gdv}a|\i|ajkddw}bd |_5|^}c|cr|cd6|bkr{|cd  |^lt dx d dylmmn}d|d n-#t$r t dzdYnwxYwdddn #1swxYwY t |[stpd{ tC d|d jqrn#t$rYnwxYw|_5|^)ddddn #1swxYwYd  |[d} _s|[d~ _tt dir|[di _vt djr|[dj _wt dkr|[dk _xt dhr|[dh _yt dr|[d _zt dr|[d _{dg|[vr;t dgr*t|[dgpg _}|0Mt d|r4 jq,  jqrn#t$rYnwxYw|0 _qt drd  _~t drd/ _t drd _n|/d=i|[ d dylmmn}d|d n-#t$r t ddYnwxYwg}e|_5 |bf|^<|^ld dlNm}ft|^|fkrD|^d/\}g}h|eZ|g|hft|^|fkDdddn #1swxYwY|eD]\}i}j t|jtr|jd nd}kd}l|kb d dlmm}mm}nm}o|m|i|kd|n|is |o|ind/}ln/#t$r"d/}lt d|idYnwxYw|lr,|k*tC|kd|d|kjqrn-#t$r t d|idYnwxYwt d|it dt5 tT<tvr3t$r  dn*#t$rt dYnwxYw5tK%|ddddn #1swxYwY"dddi ddd| r9|!7 |!n*#t$rt dYnwxYw|$r9|%7 |%n*#t$rt dYnwxYwtr5|D]7\}p}q|q!tfj4)|pd(|qtfj4|p<8| !tfj4)d'dn| tfj4d'<| !tfj4)d(dn| tfj4d(<| !tfj4)d)dn| tfj4d)<| !tfj4)d*dn| tfj4d*<|!tfj4)d+dn|tfj4d+<|!tfj4)d$dn|tfj4d$<dddn #1swxYwY  ||&d%LtC%ddkr6tC%ddr$t3d !tO%tQt5tj)dtj)dtUj)dtj)dt!j)dt#j)dtWj)dtYj)dt[ddddS#1swxYwYdSdddn #1swxYwYtt %j}rd%jd}sd}ttC%dd}u|ur$|<d_i}v|vdi}wt|wtr|u|wvr|w|u}xt|xtr|xdd p|xdd g}y|xdr|yZd|xd|xdr|yZd|xdd&d|yD}tnt |x}tt|td-tC%d#d%jd _tC%dd}z|zr|zntj}{ttC%dd}|tt%||pg}}tt%d|||}~t!|~}~tCtC dddd } %fd}tj  5%dd/dddn #1swxYwYtj|dddd}|t%}|}|r+d&g||}t'|r||||<} ||st+|~|<|}!$rc  ||&d|rt-%n5tK%d/ t%jdtjddn,#t$rt ddYnwxYwdddn #1swxYwY"dddi | r9|!7 |!n*#t$rt dYnwxYw|$r9|%7 |%n*#t$rt dYnwxYwtr5|D]7\}p}q|q!tfj4)|pd(|qtfj4|p<8| !tfj4)d'dn| tfj4d'<| !tfj4)d(dn| tfj4d(<| !tfj4)d)dn| tfj4d)<| !tfj4)d*dn| tfj4d*<|!tfj4)d+dn|tfj4d+<|!tfj4)d$dn|tfj4d$<dddn #1swxYwY  ||&d%LtC%ddkr6tC%ddr$t3d !tO%tQt5tj)dtj)dtUj)dtj)dt!j)dt#j)dtWj)dtYj)dt[ddddS#1swxYwYdS|rd }t1|dRpgD]U}t|tr>|ddkr%t |dd }nV"d|dRgdd d dd|d   d dl}|%jdn#t$rYnwxYw | r9|!7 |!n*#t$rt dYnwxYw|$r9|%7 |%n*#t$rt dYnwxYwtr5|D]7\}p}q|q!tfj4)|pd(|qtfj4|p<8| !tfj4)d'dn| tfj4d'<| !tfj4)d(dn| tfj4d(<| !tfj4)d)dn| tfj4d)<| !tfj4)d*dn| tfj4d*<|!tfj4)d+dn|tfj4d+<|!tfj4)d$dn|tfj4d$<dddn #1swxYwY  ||&d%LtC%ddkr6tC%ddr$t3d !tO%tQt5tj)dtj)dtUj)dtj)dt!j)dt#j)dtWj)dtYj)dt[ddddS#1swxYwYdS  ||&d!$r5tK%d/ t%jdtjddn,#t$rt ddYnwxYwdddn #1swxYwY"dddi | r9|!7 |!n*#t$rt dYnwxYw|$r9|%7 |%n*#t$rt dYnwxYwtr5|D]7\}p}q|q!tfj4)|pd(|qtfj4|p<8| !tfj4)d'dn| tfj4d'<| !tfj4)d(dn| tfj4d(<| !tfj4)d)dn| tfj4d)<| !tfj4)d*dn| tfj4d*<|!tfj4)d+dn|tfj4d+<|!tfj4)d$dn|tfj4d$<dddn #1swxYwY  ||&d%LtC%ddkr6tC%ddr$t3d !tO%tQt5tj)dtj)dtUj)dtj)dt!j)dt#j)dtWj)dtYj)dt[ddddS#1swxYwYdS5|s$t9%st;%|r.tdtC%dntdtC%dtC%dd ddd| r9|!7 |!n*#t$rt dYnwxYw|$r9|%7 |%n*#t$rt dYnwxYwtr5|D]7\}p}q|q!tfj4)|pd(|qtfj4|p<8| !tfj4)d'dn| tfj4d'<| !tfj4)d(dn| tfj4d(<| !tfj4)d)dn| tfj4d)<| !tfj4)d*dn| tfj4d*<|!tfj4)d+dn|tfj4d+<|!tfj4)d$dn|tfj4d$<dddn #1swxYwY  ||&d%LtC%ddkr6tC%ddr$t3d !tO%tQt5tj)dtj)dtUj)dtj)dt!j)dt#j)dtWj)dtYj)dt[ddddS#1swxYwYdS|dRp|~}!$rtK%d/ t%jdtjddn,#t$rt ddYnwxYw"dddi ddd| r9|!7 |!n*#t$rt dYnwxYw|$r9|%7 |%n*#t$rt dYnwxYwtr5|D]7\}p}q|q!tfj4)|pd(|qtfj4|p<8| !tfj4)d'dn| tfj4d'<| !tfj4)d(dn| tfj4d(<| !tfj4)d)dn| tfj4d)<| !tfj4)d*dn| tfj4d*<|!tfj4)d+dn|tfj4d+<|!tfj4)d$dn|tfj4d$<dddn #1swxYwY  ||&d%LtC%ddkr6tC%ddr$t3d !tO%tQt5tj)dtj)dtUj)dtj)dt!j)dt#j)dtWj)dtYj)dt[ddddS#1swxYwYdSt?|~|}tA|~|}t!|%_tE|}|~tG|}||%_%jD]}t|tr|ddkr|d}t|trtK|}||kr||d<vt|tr[|D]X}t|trAt|d:trtK|d:|d:<Y|dRpg}t|~}tM||~|}| sؐ sԐ!$rtK%||sZ t%jdtjddn,#t$rt ddYnwxYw"dddi ddd| r9|!7 |!n*#t$rt dYnwxYw|$r9|%7 |%n*#t$rt dYnwxYwtr5|D]7\}p}q|q!tfj4)|pd(|qtfj4|p<8| !tfj4)d'dn| tfj4d'<| !tfj4)d(dn| tfj4d(<| !tfj4)d)dn| tfj4d)<| !tfj4)d*dn| tfj4d*<|!tfj4)d+dn|tfj4d+<|!tfj4)d$dn|tfj4d$<dddn #1swxYwY  ||&d%LtC%ddkr6tC%ddr$t3d !tO%tQt5tj)dtj)dtUj)dtj)dt!j)dt#j)dtWj)dtYj)dt[ddddS#1swxYwYdStC ddp|dpd }|rt |nd }tO||t | }|ddk}|ddk}|r|d}|d}|d}nr|rN|(sKd}tQ|5pd }|(tdĦ|} |dM}7|5s|dN}5|6s|dO}6t|5|7|6\}5}7}6|7|[dM<|6|[dO<|4|[d]<|5|[dN<drvr|dr|[dr<|/d=i|[ t5 tT<dddn #1swxYwYd dulNmd}me}|5 |bf|<|ldddn #1swxYwYd}(d/  ||st+|~|<|}|dRpg}tS||p}n4#t$r'}tpd|d/}Yd}~nd}~wwxYw|r}|{|}|dRp|~}t?|~|}tA|~|}t!|%_tE|}|~t?|}||%_d}|sd}d}d}n!|rd}d}d}n|d}|d}|d}|rntU|p|dȝ||}"d|tW%d%_d%_g%_d%_dd|d|dp|d|d͝t'tjddΜ}|dϦr |d|d<|dkrd|d<n |dkrd|d<%jZ| %n#t$rYnwxYw ddd| r9|!7 |!n*#t$rt dYnwxYw|$r9|%7 |%n*#t$rt dYnwxYwtr5|D]7\}p}q|q!tfj4)|pd(|qtfj4|p<8| !tfj4)d'dn| tfj4d'<| !tfj4)d(dn| tfj4d(<| !tfj4)d)dn| tfj4d)<| !tfj4)d*dn| tfj4d*<|!tfj4)d+dn|tfj4d+<|!tfj4)d$dn|tfj4d$<dddn #1swxYwY  ||&d%LtC%ddkr6tC%ddr$t3d !tO%tQt5tj)dtj)dtUj)dtj)dt!j)dt#j)dtWj)dtYj)dt[ddddS#1swxYwYdS}d}tC dd}d/}|r*|kr#}|}|}|}|%_%js&|r$|%_td||tc%||%_tf5|thvrtij)|th|<dddn #1swxYwYtj5tl|<tmj)|ddddn #1swxYwYd dulNmd}^me}_|_5|^)|d}|r||^|<dddn #1swxYwYd}|s+tC dd}|rtC|dd |krd}|r+to%jdզ}d}tq%jD]\}}ts|r|}|to%jd|dզ}tud t|d6z %_tdtC%ddצ|t|%jnto|}dզ}|r)tud t|d6z %_n|r d %_nd%_tdtC%ddצ|rt|nd %j%jnd٦%j}||r|t|kr ||}n |r |d}nd}|rty|nd%_t}t%jpt%j%_|%j}"d||||ddܜtj}%jD]S}t|tr<|dݦs'|dަst'||d<T%jdks%jdks%js#t%j%j%_%jdkp%jdkp%j }t%j%j}t%j}|s|s|otC%dd/ p|}d }d }|rt%j\}}tC dd pd }tC dd pd }tC dd}tC dd pd }tC dd pd }tC%dd pd }tC%dd pd }tud ||z }tud ||z }t||}t||}|d kr|%_|d kr|%_||%_|d kr|%_|d kr|%_t%j}|%_d%_d%_g%_d%_|rd|D}Ðt1%jD]}|Ġddkrut |Ġdd }d|vr-|dd n|}|dd|vs |dd|vr||d<nrW%jrOt1%jD]8}t|tr!|Ǡddkr|d<n9 tudtjt|{z }n#t$rd}YnwxYwd}|r(|d kr"tt||z d6}ɐt ||4p||5}|rN|ʐ%_ttC%ddpg}|ˠZ|ʦ|dd%_%jrkt1%jD]T}t|tr=|̠ddkr$t|d|d<|Ɂ||d<|r||d<nUtC dd}|rKtC|dd pd %_tC|dd pd %_tC|dd pd %_tC%dd s d dlm}d}d} t|uRun agent in background thread, writing SSE events to STREAMS[stream_id]. When ephemeral=True, session mutations are skipped — used by /btw to get a streaming answer without persisting to the parent session. Nstarting)rj started_atphasermrrr^z.Failed to initialize run journal for stream %sTrworker_started)r created_atz2Failed to append worker_started turn journal eventr;rr,cjddkrdSd}}|: t|dd}|rt|ddpd}n#t$rd}YnwxYw|s6 t}t|ddpd}n#t$rd}YnwxYwt|pdd<dd<dS)zDCapture the latest exact prompt size before adding live tool deltas.rNrr)rr^rsr])_base_agent_cc _session_obj_live_prompt_estimate_tokens_live_prompt_exact_tokensrfrjs r5_seed_live_prompt_estimatez8_run_agent_streaming.._seed_live_prompt_estimate s ' *Q . ./2 2   f&:DAAG#C)=qAAFQE      *:66  .BAFFK!    *-ejq//$Q''CA'F!!$+A..s#&A AA"A<< B  B c|sdStdd|d}|dd<|dd<dS)z?Increment a rough next-prompt estimate from live tool activity.r)r~r{rr|rr|)r)r_usager'_live_prompt_estimate_tool_delta_tokensrrs r5_bump_live_prompt_estimatez8_run_agent_streaming.._bump_live_prompt_estimate s 3/2 2""$$$<8; 9! <$KA$N     +11E*F$Q'5;._live_usage_snapshot s !""#!% !"#    &z22LL   LLL    )09PRS)T)T)YXY~&*1&:UWX*Y*Y*^]^'+26;WYZ+[+[+`_`'(.5f>Y[\.].].bab*+/6v?[]^/_/_/dcd+,,     f&:DAA^/6sPRS1T1T1YXYF-.3:3@TVW3X3X3]\]F/0      #u  zz&)))0vq)I)I)NQv$ "&**-A"B"B"GaHH&> JJ* + + 0q JJ~ & & +!' ' "#  K#6:STU:V#V#V+> %a (.A ( +9: 3A 6 6 )! ,/B B B+G+JF' ( sC ..A.B%% B21B26AD DD8E EEc t}|dkrdS|rdSt}|d<|d<d|~)NTg$@rjrmetering)r# get_intervalwait get_stats)intervalstatsr+_metering_stoprrjs r5_metering_tickerz._run_agent_streaming.._metering_ticker-s #ww++--H4""8,, GG%%''E",E, 1133E'N C E " " " #r7)rrcr|dvrdS ||}t|tr|pidnd}|r |t <n.#t $r!td|dYnwxYw  ||fdS#t $rtdYdSwxYw)N)cancelrevent_idz3Failed to append run journal event %s for stream %sTrzFailed to put event to queue) rappend_sse_eventr/rqr\rr^rr put_nowait)rr, journaledr7 cancel_eventq run_journalrWs r5rz!_run_agent_streaming..put<s(     U2E%E%E F  " u'88EE AK9VZ@[@[eIO00<<(3 u u u RTY[dos ttttt u 9 LL% ' ' ' ' ' 9 9 9 LL7 8 8 8 8 8 8 9s$AA00(BBB88$C C ct|pd}t|pd}|sdS|}|dkod|vp d|vpd|vpd|v}|rddd dSt||}|rd d |d dSdS) aBridge Agent lifecycle status into WebUI SSE. Passes compression events as 'compressing' events and rate-limit/fallback events as 'warning' events so the frontend can surface them to the user. All other lifecycle messages are dropped silently. r;Nr<zpreflight compression compressingzcompacting contextzcontext too largez'Auto-compressing context to continue...)rjr9rrl)rr9)r0r>r?rB) r8r9r5_kind_lower_is_compression_start_is_fallback_noticerrjs r5_agent_status_callbackz4_run_agent_streaming.._agent_status_callbackUs&w}"%%++--DJB%%''--//  F!! [  '611 F*1'611'&0  !  C (D      F=UHMM  F C J8DD E E E E E F Fr7running)r rjrzTask cancelled before start.r]r6r9zCancelled before startr[rQrR finalizing)r )patch_skill_home_modulesget_hermes_home_for_profileget_profile_runtime_envrkr)get_active_profile_namecNi|]"}|tj|#Sr)rrlr\)rrvs r5rz(_run_agent_streaming..s(XXXCsBJNN3$7$7XXXr7rrrrrrr)discover_mcp_toolsF)register_gateway_notifyunregister_gateway_notifyc d|dS)Napprovalr) approval_datars r5_approval_notify_cbz1_run_agent_streaming.._approval_notify_cbsJ .....r7z6Approval module not available, falling back to pollingc d|dS)NrZr) clarify_datars r5_clarify_notify_cbz0_run_agent_streaming.._clarify_notify_cbsI|,,,,,r7z5Clarify module not available, falling back to pollingcNt}d|pgD}t|pd||dtj|d} ddlm}m} n#t $r YdSwxYw|||} tj|z} |r| | dS| tjz } | dkr| | dS| j td |  r,t| j pd } | pdS) z+Bridge Hermes clarify prompts to the WebUI.c,g|]}t|Srr)rrs r5rzH_run_agent_streaming.._clarify_callback_impl..sFFFFCKKFFFr7r;rZ)questionchoices_offeredrjr8 requested_atrar)submit_pending clear_pendingzrThe user did not provide a response within the time limit. Use your best judgement to make the choice and proceed.Tg?rG)rbr0rU api.clarifyr]r^rE monotonicrrr/rrr>)rZrsid cancel_evtr r[ choices_listr,_submit_clarify_pending_clear_clarify_pendingrqdeadline remainingresponses r5_clarify_callback_implz4_run_agent_streaming.._clarify_callback_impls.00GFFw}"FFFLB//#/!! $ #* D zzzzzzzzz   N  ,+C66E~'''1H $$&&**3///R%t~'7'77 >>**3///R;##CY,?,?#@@"5<#5266<<>>H UU! sA AArc.tj}|dz dkrdS|d<t}|d<|d<|dd|ddd|dS) Nrrrjr tps_availableFrr-)rUr`r#r0 setdefault)nowr2r+_metering_last_emitrrjs r5_emit_meteringz,_run_agent_streaming.._emit_meteringNsn&&,Q//#55F),#A&))++&0l#!5!5!7!7g  %888  e444J&&&&&r7rxcptjddt|pdS)Nr1rr;)r2rr0r>rs r5_compact_for_echo_comparez7_run_agent_streaming.._compact_for_echo_compareZs.vfc3u{+;+;<<BBDDDr7rc |}|sdStjdttt |dzd d}t |o||S)NFr;rr)r r\rrr0rrF)rr visible_tailrqrWs r5_is_visible_output_echoz5_run_agent_streaming.._is_visible_output_echo]s55d;;  ! 588'+Ir::CCIIQR@RTW.on_tokenfs<F"  333' 222c$ii?222Gfd^,,,(***a/***$$Y0G0JKKK     r7c.|dSt|}|rdS|z tvrtxx|z cc<dd|idxxdz cc<tddS)Nrrrr)r0r r#record_reasoning)rreasoning_deltarort_metering_reasoning_deltas_reasoning_textrrWs r5 on_reasoningz*_run_agent_streaming..on_reasoningvs<F"%d)) +*?;;F?2 555))444G444K&/!:;;;*1---2---((4Nq4QRRR     r7c|dSt|}|sdSt|ddp |}d||ddS)Nalready_streamedFinterim_assistant)rr)r0r>rr\)r cb_kwargsvisiblerrtrs r5on_interim_assistantz2_run_agent_streaming..on_interim_assistants<Fd))//++F#' 6H%(P(P#Q#Q#uUlUlmtUuUu '#(8**r7ci}t|trct|ddD]9\}}t |}|ddt |dkrdndz||<:|S)NrKrWrr;r)r args_snapr@rs2s r5_tool_args_snapshotz1_run_agent_streaming.._tool_args_snapshots dD))S $TZZ\\ 2 22A2 6SS1 VV')$3$xCGGcMM55r'R !   r7c |r|vrdS||dt|pdtjt |t r|nidddd}dd|gd gdS) NFrr;T)rr)rr)rrrr)rrrw)rr0rrr/rq)rxrr _tool_callr_live_prompt_estimate_seen_idss r5_record_live_tool_startz5_run_agent_streaming.._record_live_tool_starts#!|7U'U'U 5.22<@@@&& #DJB%)Z 48N8N0VTVejvz%{%{%{!! +*'!#-,--, tr7cn|sdSt|}dt|pd||dgdS)NFrr;)rrrxrT)rr0)rxrfunction_result _result_textrs r5_record_live_tool_completez8_run_agent_streaming.._record_live_tool_completes^#! 53ODD **" OO$0+ --, tr7c d}d}d}d}t|dkr|dd\}}}}nRt|dkr |\}}}d}n6t|dkr|\}}nt|dkr |d}d}|dvr|dkr|n|}|rt|}|rdS|z tvrtxx|z cc<d d |idxxdz cc<tddS|}|d vrd vrdS|d vr8|t |tr|nid tvr;t|t |tr|niddd|pd|||dt } | d<| d<d|  ddl m } m } m } | rK| 5t| i} dddn #1swxYwY| r d| n#t$rYnwxYwdS|dkrdvrdS|dkrt!D]x}|dr|r|d|krEd|d<|d|d<t#|dd|d<nytvrt!tD]x}|dr|r|d|krEd|d<|d|d<t#|dd|d<nydxxdz cc<d|||||dt#|dddt } | d<| d<d| dSdS) NrKrJ tool.startedrrr)reasoning.available _thinkingrrr)Nrtool_start_callback)rrF)rrrr) event_typerrrrjrr-) has_pending_pendingrrRtool.completedtool_complete_callbackrrTdurationr tool_complete)rrrrrr)rr0r r#r|rrr/rqr r0tools.approvalrrrr\rEr=r)cb_argsrrrrr reason_text reason_deltar _tool_stats _has_pendingrrrhr shared_tc _agent_params_checkpoint_activityrort_live_tool_callsr+r~rrrrjrWs r5on_toolz%_run_agent_streaming..on_tools! w<<1$$6=bqbk3Jgtt\\Q&&*1'D'4!/JJ\\Q&&'.$J\\Q&&"1:D!/J!EEE-7;P-P-P''VZK")'*;'7'7 32<@@#"F'<7$(===1)<<< L<<<K&,)?@@@21555:55500(> FB-- !$:::.y9@@$(,6tT,B,B$JDD$)BB C&0&BN $#* ) !! #(''"3"3"5"5K0:K -+?+?+A+AK(C K000__________'< 333!&GG$(j")E)E$F$FGGGGGGGGGGGGGGG 3 #J 2 2 2&F!1116NR_6_6_F!111#+,<#=#=""";;v..%$#"w{{6':':d'B'B.2GFO2;-- 2K2KGJ/26y}}ZQV7W7W2X2XGJ/!E (C !$:::)12H2S)T)T&&I(}}V44) (#'&9==+@+@D+H+H48 & 18A j8Q8Q * 58.on_tool_start=sg++L$EEE# >>29=DD(,0:40F0F(NB(-'3 FF F*8$('+$7$7$=$=#/ %%#(''"3"3"5"5K0:K -+?+?+A+AK(C K00000 gggLL!VaeLffffffgsC6C;;&D%$D%c   ||||r_| vrZ |t|}t D]k}|dr|d|ks.|ds%|d|kr d|d<||d<nltvrttD]k}|dr|d|ks.|ds%|d|kr d|d<||d<nldxxdz cc<dd || ||d d t }|d < |d <d|dS#t$r t ddYdSwxYw)NrrrTrrrrrF)rrrrrrrjrr-z8Failed to update live prompt estimate on tool completionr) rrr=r\r r#r0r^rr)rxrrrresult_snippetrrrrr_live_tool_event_complete_idsr+rrrrjrWs r5on_tool_completez._run_agent_streaming..on_tool_complete]sp"l..|T?SSS# >>-56LY6W-X-X** #,==#8#8!-$,#,==#7#7<#G#GPYP]P]^cPdPd#Girivivw}i~i~CGjGjG8rr)_raw_items_entries_entry _provider_models r5_fallback_entriesz/_run_agent_streaming.._fallback_entriess)dD))"VFFd++!FFI$  F%fd33! #FJJz$:$:$@b A A G G I II G!4!4!:;;AACCF$!F! OO!'$-$*JJz$:$:#)::i#8#8#)::i#8#8 %% r7)fallback_providersrr/rf max_turnsr)parse_reasoning_effortreasoning_effortc"||Sr~r)rZrrir;rrjs r5z&_run_agent_streaming..Is .D.D ':|S//r7)rrrrplatform quiet_moderrrj session_dbprefill_messagesstream_delta_callbackreasoning_callbacktool_progress_callbackclarify_callbackrrinterim_assistant_callbackrrstatus_callbackmax_iterationsr acp_commandracp_argsrrgateway_session_keyz.[webui] Created ephemeral agent for session %s)rr)rrz+[webui] Reusing cached agent for session %s)register_agentz5Lifecycle register_agent failed for cached session %sz[[webui] Cached agent runtime could not be safely refreshed; rebuilding agent for session %s _session_dbrrrr_api_call_count _interrupted_interrupt_messagez2Lifecycle register_agent failed for new session %s)SESSION_AGENT_CACHE_MAX)rZ)commit_session_memoryhas_uncommitted_workunregister_agent)rfr/z*Lifecycle commit on eviction failed for %sz,Failed to close evicted agent for session %sz([webui] Evicted LRU agent from cache: %sz([webui] Created new agent for session %sz&Failed to interrupt agent before startCancelled by userz&Failed to unregister approval callbackz%Failed to unregister clarify callbackz#Active workspace at session start: aj Every user message is prefixed with [Workspace::v1: /absolute/path] indicating the workspace the user has selected in the web UI at the time they sent that message. This tag is the single authoritative source of the active workspace and updates with every message. It overrides any prior workspace mentioned in this system prompt, memory, or conversation history. Always use the value from the most recent [Workspace::v1: ...] tag as your default working directory for ALL file operations: write_file, read_file, search_files, terminal workdir, and patch. Never fall back to a hardcoded path when this tag is present. personality personalities system_promptrtonezTone: stylezStyle: rpc3K|]}||V dSr~rrgs r5rz'_run_agent_streaming..3s'7O7OaQ7O7O7O7O7O7O7Or7)rhrjrkrm)rfrTrj)state_messages)prefer_contextrrcompression_countc>d}ds d}||kr+5tdddn #1swxYwY|}n2#t$r%}td|Yd}~nd}~wwxYwddSdS)NrrFz#Periodic checkpoint save failed: %s)r/r9r^rr)last_saved_activitycurr _agent_lockr_checkpoint_stopr6s r5_periodic_checkpointz2_run_agent_streaming.._periodic_checkpointps$&'#*//33OO215!444!,>> :1 = = =>>>>>>>>>>>>>>>25/$OOO %JANNNNNNNNO+//33OOOOOs9AA AA  A A A BA>>Brzckpt-)rrrr|r) user_messagesystem_messageconversation_historytask_idpersist_user_message)r^rr)rrrz-Failed to append cancelled turn journal eventrrrr)rjr)rr)rrr^answerrXz:Superseding stale recovery marker for session %s stream %szMSkipping stale stream writeback for session %s stream %s; active_stream_id=%s _last_errorrrrr r#rwrz;[webui] self-heal: retrying stream after credential refreshz([webui] self-heal: retry also failed: %sr"r$rCapperrorz**z:** rDrE)rrrOrLr3rMrJrNzInterruption detailsz?Stamped profile=%r on continuation session %s after compression)auto_compressionz@[ANCHOR-MARKER] session=%s marker_raw=%d vis_before=%d anchor=%drz4[ANCHOR-FALLBACK] session=%s vis_before=%d anchor=%dr compressedz4Context auto-compressed to continue the conversation)rjold_session_idnew_session_idcontinuation_session_idr9rrOrrarbr_r$r%r&r'r(rr)rcJg|] }t|t|!Sr)rrs r5rz(_run_agent_streaming..s0*k*k*k1WghiWjWj*k+;A+>+>*k*k*kr7rz [Attached files:rLr%rgrgateway_routing_historyirJ _turnDuration_turnTps_gatewayRoutingr"r#r)get_model_context_lengthcustom_providers)config_context_lengthrrc3K|]J}tj|tr(j|ddkF|VKdSrrNr/rrqr\rrr6s r5rz'_run_agent_streaming..9slnn&qz#==nBC*S/BUBUV\B]B]alBlBlBlBlBlBlnnr7assistant_started)rrassistant_message_indexz5Failed to append assistant_started turn journal event completedc3K|]J}tj|tr(j|ddkF|VKdSrrrs r5rz'_run_agent_streaming..usm%z%zS(21:c?D(I(I%zNOjY\oNaNabhNiNimxNxNx&)NxNxNxNx%z%zr7z-Failed to append completed turn journal event)mark_turn_completed)rfz+Memory lifecycle mark failed for session %srpsync_to_insights)sync_session_usage)rjrrrrrrrkz"Failed to sync session to insights)rrrrr r!turn_cache_hit_percentduration_secondstpsgateway_routing_drain_pending_steerpending_steer_leftover)rjrz,Failed to drain pending steer for session %s)evaluate_goal_after_turnhas_active_goal)rgoal evaluatinguEvaluating goal progress…goal_evaluating_progress)rjstater9 message_key)user_initiatedrshould_continue continuingidlergoal_continuing message_args)rjrr9rr!decisioncontinuation_prompt goal_continue)rjr#rr9rr!r"z0Goal continuation hook failed for session %s: %s)rrw)rrrkrr-rr^z[webui] stream error: z<[^>]+>rr1r!rzI[webui] self-heal (except path): retrying stream after credential refresh _agent_kwargszWSkipping stale stream self-heal writeback for session %s stream %s; active_stream_id=%sz0[webui] self-heal (except path): retry succeededz1[webui] self-heal (except path): retry failed: %s)zAuthentication errorr#zThe selected model may not be supported by your configured provider. Run `hermes model` in your terminal to switch providers, then restart the WebUI.)r&rr;zSSkipping stale stream error writeback for session %s stream %s; active_stream_id=%sz/Failed to append interrupted turn journal eventr)rr\rrUr0rr$r^rrr%rEventrrr r r rr]r# begin_sessionrrrsrrrrrmrr>r?rrrrrarsrrrr r rr api.profilesrIrJrKrErrlrLrrrG _ENV_LOCKrtools.mcp_toolrNrrOrPr_r`rMrr hermes_staterprintrrrrrrr6rrrrrrrrrload_metadata_onlyr4rrrinspect signature__init__ parametersr/rqrrrrrrrsortedrrr move_to_endapi.session_lifecyclerrrrcloserrrrrrrrrrrrrrrrpopitemrrrr interruptrrRrephemeral_system_promptr'r(rSrr`rr-run_conversationrr\rjr=rZrr[rXr\r rr!rrprrr@rsr/rrr8rPrQrRrSrTrkrparent_session_idrrrrr"rr%rcompression_anchor_visible_idxr/compression_anchor_message_keyr*r1compression_anchor_summaryrrtr|rCrhr&rrrrr rrwrrroundrrrr"r#rrxrrrnextrr rapi.state_syncr api.goalsrrrcompactrr0rlrr traceback format_excr2rrrdir(&rjrrrmrWr%r^rr_rtold_cwd old_exec_askold_session_keyrold_session_platformold_hermes_homeold_profile_envr4_metering_threadrD _ckpt_threadprovider_contextrIrJrK_profile_home_path _profile_home_profile_runtime_env_resolved_profile_namerL _thread_envrN_approval_registered _unreg_notify _reg_notifyrT_clarify_registered_unreg_clarify_notify_reg_clarify_notifyrW _self_healedrzrrrrr_AIAgentrr_state_db_path_db_errresolved_modelr)r+r*rr_e _get_config_cfg_prefill_context_prefill_messagesr _toolsetsrr _session_path _session_meta _override_ts_errr_fallback_chain_fallback_seen_fallback_resolved _fallback_key _fb_entry _identity_inspect_max_iterations_cfg_raw_max_iterations_agent_cfg_for_iterations_parsed_max_iterations_max_tokens_cfg_raw_max_tokens_agent_cfg_for_tokens_parsed_max_tokens _parse_reff _effort_cfg _effort_raw_reasoning_configr%r_jsonrrr _sig_blob _agent_sig_cachedr_evicted_itemsr evicted_sid evicted_entry _evicted_sid_evicted_entry_evicted_agent_should_close_evicted_agent_lifecycle_commit_lifecycle_has_uncommitted_work_lifecycle_unregister_agent_key _old_valuerworkspace_system_msg_personality_prompt_pname _agent_cfg_personalities_pval_parts_pending_started_at_turn_started_at_external_state_messages_previous_messages_previous_context_messages_pre_compression_countr_process_notifications_agent_msg_textrr_answer_mrZ_result_messages_next_context_messages _raw_content_cleaned_part_all_result_messages _prev_len_assistant_added _last_err_err_str_classificationr+r, _err_label _err_type _err_hint _heal_result_heal_rt_SAC_SAC_L_heal_all_msgs_heal_ok _retry_exc_error_payload_error_message_compression_origin_session_id$_compression_continuation_session_id _agent_sid _compressedrnew_sid _cached_entry _compressor visible_after_last_marker_raw_idx_mi_visible_before_markervisible_before_anchor_vis_idx anchor_msg_now_looks_default_looks_provisional_invalid_existing_title_should_bg_title_u0_a0rrrrr prev_input_tokensprev_cache_read_tokensturn_input_tokensturn_cache_read_tokensr!rrwdisplay_attachmentsrAr base_text_rm_turn_duration_seconds _turn_tps_gateway_routing_history_dm _cc_for_saver _cfg_ctx_len_cfg_custom_providers_model_cfg_for_ctx _raw_cfg_ctx_parsed_cfg_ctx_raw_cp _resolved_cl _legacy_cl_latest_assistant_idx_latest_assistantr _load_settingsrrr_get_cl_fb_cl _sess_lptr _leftoverrr_goal_decision_last_goal_response _goal_msg _goal_content _goal_parts _goal_part _goal_textr" _goal_messager# _goal_exc raw_session meter_statsrr  _stripped _exc_lowerr _exc_is_quota_exc_is_rate_limit _exc_is_auth_exc_is_not_found_exc_is_cancelled_exc_is_interrupted _exc_label _exc_type _exc_hint _heal_kwargs _heal_agent_SAC2_SAC2_L _retry_exc2rrrrrrirqrortrrrrrrrr+rnrxr~r3rrrrryrrfr;rr<r=r6s&` ` @@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@@r5_run_agent_streamingru s"  IAy9;;i..y//    a&z9== aaa  Ey[_ `````a ^ ^ 0*$)++FF      ^ ^ ^ LLMX\L ] ] ] ] ] ^ A CGLONOO?$$L //". Y)+I&+-i(,.y) /////////////// E$%3 !"/0c+%(UU"//////////. / / / / / / / / / /?????????D GG)$$$ _&&N # # # # # # # #!'/?MMM999999992FFFFFFHLKi#-  # #)9LLLL$y//4466>>@@AA )    % % ' ' - - / / /,d33  ,3t-j99       i i(iIghhhh i i i i i i i i i i i i i i i C9&>? @ @ @ FF  '  " " "  #   b  ) ) ) MA1488IEEA5t<<F i| < < < < '9k B B B  - - K 4 ( ( (  Y - - -   4 0 0 0  #It 4 4 4 ! %i 6 6 6 " &y$ 7 7 7  #It 4 4 4 $Y 5 5 5 !) , , , - - - - - - - - - - - - - - - - - -OF ,           "=!>*;<>2K#L#L  jnn];;O J  2 3 3 3),Q[)9)9BJ~ &,/BJ( )/9BJ+ ,.8BJ* +4;BJ0 1 B,9 =),7,,T--@-@AAA1 B B B B B B B B B B B B B B BR  9 9 9 9 9 9       D  %  S         / / / / / K $7 8 8 8#'  S S S LLQ R R R R R S$ $ R          - - - - -  ,> ? ? ?"&   R R R LLP Q Q Q Q Q R* * * X{ BK L O! $(>#3#3a#7"8 '(c #*+ & ' ' ' ' ' ' ' ' E E E E E E Oc Od O O O O O O O ! ! ! ! ! ! ! ! !  ! ! ! ! ! ! ! ! ! !*      %&3 ), &,/EE ) ! ! !      &     v v v v v v v v v v v v v v v v p g g g g g g g g g g g g@# l# l# l# l# l# l# l# l# l# l# l# l# lJ%H!">"@"@AAAK 222222GT!^$}"5"5 "B"BZ^'i???    qhoqqy}~~~~~~~~~ CY+E3CDDDD @N-/@ $  ]VVVVVVPPPPPPFF,/$'779#5#5 (<(+ (;(;%(<(+ (;(;% ] ] ]O2OOW[\\\\\\\\\ ] Fp!#35FFF B /1B = < < < < <;==D:4@@  0 4 4Z @ @ FB  C (9:JKK##    9 8 8 8 8 8--d33I w;;;;;;;; +.B.B.B B  '')) .$+$>$>z$J$JMUb k 7I4 P P PgkI .$-  w w wiR\ii`giiquvvvvvvvvv w   0!O UUN!% !I 6 6 !2!2488M3J3J!K!K 6 6IIMM*55;<<BBDDJJLLIMM'228b99??AAGGIIIMM*55;<<BBDDKKCPPVVXX!I !N22 "&&y111#**95555 6"1!8D  ' & & & 2 283D E E PQQM#'  +&*#EOPTVZE[E[,cDHHWb,A,A,Aac)7>>U*C*G*G *T*T'&.:dD3I3I.+/((;*?*?'&2-01D-E-E*-11.D+ + + +&*### +#O '"&((<"8"8"*,0HHWb,A,A)!"7>>R*?*C*CL*Q*Q".),_)=)=&)A--*< ' ' '"& ' )LLLLLL7A$7M7MUdhhw333SU EOP[]aEbEblkoo.@AAAhl $/K $<$<!! ) ) )$(!!! )!$**(!!*1%&!2&.#/'.%M2"]227H7T4E 01!66!!"4d;;;+}<<>R :;$ 557D 34'=88:J 67 M113I /0=005H5T2E ./},,1L.= l+]**,/GGJ,?,? j) --/2wwy/A/A m,]**,/GGFOO j) M113677;L3M3M /0 % 557A 34 R Y 11=11 MzZZZZ****$$$$TTTTTTTT#&77+<#=#= !KK"(b,-=?OPP%+%+GGJ''-2GGI&&,"GGFOO)r)**'-2#)r&,")2:F9%%%%+23CDD"'R+),"-(## .&__Y-=-=-?-?@@JJLLSbSQ - } }155jAAG }71:#;#; ' +77 CCC %RT^___}LLLLLL*N:u====(}}}"LL)`blw{L|||||} } } } } } } } } } } } } } } }$9 NN %y&!&umTBBN % 1 7 7 9 9 9(!!! D!5FF/33JEEEFFFFFFFFFFFFFFF $$3@2C2CD[2\2\E/3@3D3DE]3^3^E0u&;<<]4A4E4EF[4\4\1u&>??c7D7H7HIa7b7b4u&788U0=0A0ABS0T0T-u&BCCk;H;L;LMi;j;j8u&:;;[3@3D3DEY3Z3Z0u&899W1>1B1BCU1V1V.)]::wuN`?a?a:15m6G6GHZ6[6[6a_a1b1b.". #5-88%U=N=Z% % 1 7 7 9 9 9 9#,%%% $%,7)u&788201-un553-2*u&:;;8370$H55}55EvHHHHHH&z59999$vvv %Y[ept uuuuuv%'N1PP;@*:M+J7+77 CCCFFFFFF!"5669PPP9L9T9TZ_9T9`9`6K*11; 2NOOO""5669PPP PPPPPPPPPPPPPPP9G__4 nvBL^]bBcBc-m^A->->imN:>7-9 !|%&%&%&%&%&%&%&%&%&%& %6$5l._c$d$d$d$d+J+J<+X+X%L(C(CL(Q(Q(Q(QFK(C'0!|!|!|BG$?$*LL1]_kvzL${${${${${!| ;C~?Y^eftwDFJ_K_K_W . : @ @ B B B(vvv"LL)WYeptLuuuuuv %OQ]^^^^LL!KZXXX  -2 * ,,i1H1O1O1Q1Q,O(@AAAA$OOO %MNNNNNO$qq0iQoppppqqqqqqqqqqqqqqqC9.A"BCCC      r"    $ K (AK!M*---- KKKLL!IJJJJJK" J'<'HJ))*5555 JJJLL!HIIIIIJ B B(7(=(=(?(?88$D*!)2:>>$+E+E+E+E-7"*T**?BJNN>4$H$H$H$H3:bj0'8I4)P)P)P)P6Bbj!23"*BJNN;OQU,V,V,V,V9Hbj!56!)2:>>:Mt+T+T+T+T8Fbj!45'/@Y[_1`1`1`1`>Rbj!:;"*BJNN=$,O,O,O,O2Abj/ B B B B B B B B B B B B B B BH  '  " " "  #   b  ) ) ) MA1488IEEA5t<<F i| < < < < '9k B B B  - - K 4 ( ( (  Y - - -   4 0 0 0  #It 4 4 4 ! %i 6 6 6 " &y$ 7 7 7  #It 4 4 4 $Y 5 5 5 !) , , , - - - - - - - - - - - - - - - - - -i*                6c!+6F6FGGMPakPPP !#' Q t44F 9!XXgr22 !+!D!Dnd33 9.8P8P*62E!%..9"'))OR"@"@"[EIIhXZD[D[!\ 99V,,D"MM*B5=*B*BCCC 99W--F"MM*DE'N*D*DEEE.2ii7O7O67O7O7O.O.O++.1%jj+ -K#%",&q)T::!" !!---E )#*!-A4"H"H  7JZ22ty{{ 'DWQP\^bEcEc'd'd $!%8#; ""  *I8#'#;  ** &*GGa)b)b &%,3T::#Q&& "( O O O O O O O O )00  @ @??? @ @ @ @ @ @ @ @ @ @ @ @ @ @ @%++D-Z^--L    %G %S%S "&O% ["(++.Q0F.Q.Q"R"R"X"X"Z"Z;M?\girx|}}}L++)3%?@Z`d%e%e%e"%- ,F""$$ #/$((***+ %%b%111i5a8888$ i i0eDDDD i@ ! )-:26)++.9!"!" )iii"LL)XcgLhhhhhi i i i i i i i i i i i i i i iHy*=>???l    $ K (AK!M*---- KKKLL!IJJJJJK" J'<'HJ))*5555 JJJLL!HIIIIIJ B B(7(=(=(?(?88$D*!)2:>>$+E+E+E+E-7"*T**?BJNN>4$H$H$H$H3:bj0'8I4)P)P)P)P6Bbj!23"*BJNN;OQU,V,V,V,V9Hbj!56!)2:>>:Mt+T+T+T+T8Fbj!45'/@Y[_1`1`1`1`>Rbj!:;"*BJNN=$,O,O,O,O2Abj/ B B B B B B B B B B B B B B BH  '  " " "  #   b  ) ) ) MA1488IEEA5t<<F i| < < < < '9k B B B  - - K 4 ( ( (  Y - - -   4 0 0 0  #It 4 4 4 ! %i 6 6 6 " &y$ 7 7 7  #It 4 4 4 $Y 5 5 5 !) , , , - - - - - - - - - - - - - - - - - -_% "6::j#9#9#?R@@B!"d++v+0M0M"%bffY&;&;"<"<F.8fjjQ[]_F`F`aa./!DD!%%  $/$((***"NNNLL((//4/@@@@ DB    $ K (AK!M*---- KKKLL!IJJJJJK" J'<'HJ))*5555 JJJLL!HIIIIIJ B B(7(=(=(?(?88$D*!)2:>>$+E+E+E+E-7"*T**?BJNN>4$H$H$H$H3:bj0'8I4)P)P)P)P6Bbj!23"*BJNN;OQU,V,V,V,V9Hbj!56!)2:>>:Mt+T+T+T+T8Fbj!45'/@Y[_1`1`1`1`>Rbj!:;"*BJNN=$,O,O,O,O2Abj/ B B B B B B B B B B B B B B BH  '  " " "  #   b  ) ) ) MA1488IEEA5t<<F i| < < < < '9k B B B  - - K 4 ( ( (  Y - - -   4 0 0 0  #It 4 4 4 ! %i 6 6 6 " &y$ 7 7 7  #It 4 4 4 $Y 5 5 5 !) , , , - - - - - - - - - - - - - - - - - -w$ + $$&&&'!!"!---""$$  e e,Q%@@@@ e<L%)6.2ikk*5%eee %T_c ddddde e e e e e e e e e e e e e e eHy*=>???X    $ K (AK!M*---- KKKLL!IJJJJJK" J'<'HJ))*5555 JJJLL!HIIIIIJ B B(7(=(=(?(?88$D*!)2:>>$+E+E+E+E-7"*T**?BJNN>4$H$H$H$H3:bj0'8I4)P)P)P)P6Bbj!23"*BJNN;OQU,V,V,V,V9Hbj!56!)2:>>:Mt+T+T+T+T8Fbj!45'/@Y[_1`1`1`1`>Rbj!:;"*BJNN=$,O,O,O,O2Abj/ B B B B B B B B B B B B B B BH  '  " " "  #   b  ) ) ) MA1488IEEA5t<<F i| < < < < '9k B B B  - - K 4 ( ( (  Y - - -   4 0 0 0  #It 4 4 4 ! %i 6 6 6 " &y$ 7 7 7  #It 4 4 4 $Y 5 5 5 !) , , , - - - - - - - - - - - - - - - - - -M$w qw q )Ea)S)SFq(SS  X#A|Z@@%  k#A|Z@@%#A'94@@  w qw qw qw qw qw qV    $ K (AK!M*---- KKKLL!IJJJJJK" J'<'HJ))*5555 JJJLL!HIIIIIJ B B(7(=(=(?(?88$D*!)2:>>$+E+E+E+E-7"*T**?BJNN>4$H$H$H$H3:bj0'8I4)P)P)P)P6Bbj!23"*BJNN;OQU,V,V,V,V9Hbj!56!)2:>>:Mt+T+T+T+T8Fbj!45'/@Y[_1`1`1`1`>Rbj!:;"*BJNN=$,O,O,O,O2Abj/ B B B B B B B B B B B B B B BH  '  " " "  #   b  ) ) ) MA1488IEEA5t<<F i| < < < < '9k B B B  - - K 4 ( ( (  Y - - -   4 0 0 0  #It 4 4 4 ! %i 6 6 6 " &y$ 7 7 7  #It 4 4 4 $Y 5 5 5 !) , , , - - - - - - - - - - - - - - - - - -m#$*::j#9#9#W=W &&((,Q%@@@@ e<L%)6.2ikk*5%eee %T_c dddddeC9.A"BCCCAw qw qw qw qw qw qV    $ K (AK!M*---- KKKLL!IJJJJJK" J'<'HJ))*5555 JJJLL!HIIIIIJ B B(7(=(=(?(?88$D*!)2:>>$+E+E+E+E-7"*T**?BJNN>4$H$H$H$H3:bj0'8I4)P)P)P)P6Bbj!23"*BJNN;OQU,V,V,V,V9Hbj!56!)2:>>:Mt+T+T+T+T8Fbj!45'/@Y[_1`1`1`1`>Rbj!:;"*BJNN=$,O,O,O,O2Abj/ B B B B B B B B B B B B B B BH  '  " " "  #   b  ) ) ) MA1488IEEA5t<<F i| < < < < '9k B B B  - - K 4 ( ( (  Y - - -   4 0 0 0  #It 4 4 4 ! %i 6 6 6 " &y$ 7 7 7  #It 4 4 4 $Y 5 5 5 !) , , , - - - - - - - - - - - - - - - - - -K#*E.$**&*K.***&&CCY%Z%Z"G&.78JL\]]  * Y YB!"d++ Yv+0M0M')vvi'8'8 %lC88Y'<\'J'JH'<77089 ' d;;Y)5YY#-eT#:#:!Yz%))TZJ[J[]`?a?a!Y4I%PV-4X4XE&M(.zz*'='='C$ :;; #L(.$$ (t t#**,,0iHHHH( m m D$%L$-1>6:ikk2=%&%&!"!"!"!"$-mmm & -\gk l l l l lmHy2E&FGGGIw qw qw qw qw qw qV    $ K (AK!M*---- KKKLL!IJJJJJK" J'<'HJ))*5555 JJJLL!HIIIIIJ B B(7(=(=(?(?88$D*!)2:>>$+E+E+E+E-7"*T**?BJNN>4$H$H$H$H3:bj0'8I4)P)P)P)P6Bbj!23"*BJNN;OQU,V,V,V,V9Hbj!56!)2:>>:Mt+T+T+T+T8Fbj!45'/@Y[_1`1`1`1`>Rbj!:;"*BJNN=$,O,O,O,O2Abj/ B B B B B B B B B B B B B B BH  '  " " "  #   b  ) ) ) MA1488IEEA5t<<F i| < < < < '9k B B B  - - K 4 ( ( (  Y - - -   4 0 0 0  #It 4 4 4 ! %i 6 6 6 " &y$ 7 7 7  #It 4 4 4 $Y 5 5 5 !) , , , - - - - - - - - - - - - - - - - - -C!!(}d C C `vzzRYGZGZ `^`I1:Bs9~~~H&> !+/>>'9'''O !0 7;L LI.v6/IH m<%4W%= $3F$; $3F$; !i<,i<(, #@-3Z$$$/"KK(efff"*C/7||I/F/F,#4M41A1A*1M1M1SQS+CNT]+^+^+mbm#,111 &$NPZ!"!"!",1 1 ( 8L,D)54:::j3I3I3gMg 09T$>$4:":" 6:[$>$::":" 66SSi5j5j 2-W$6$>$?@RTd$e$e$, ."." 48 0/)@J(7I!N& " <%< $3 J" &5W%= $3F$; $3F$; ())@$8:(8(8(8%%** J777 DAFFF-1*15.02-/3,$/'zJ'z'zN$ 33G]N+CDD&-77G]N+CD )).999!FFHHHH(!!! D! Ow qw qw qw qw qw qV    $ K (AK!M*---- KKKLL!IJJJJJK" J'<'HJ))*5555 JJJLL!HIIIIIJ B B(7(=(=(?(?88$D*!)2:>>$+E+E+E+E-7"*T**?BJNN>4$H$H$H$H3:bj0'8I4)P)P)P)P6Bbj!23"*BJNN;OQU,V,V,V,V9Hbj!56!)2:>>:Mt+T+T+T+T8Fbj!45'/@Y[_1`1`1`1`>Rbj!:;"*BJNN=$,O,O,O,O2Abj/ B B B B B B B B B B B B B B BH  '  " " "  #   b  ) ) ) MA1488IEEA5t<<F i| < < < < '9k B B B  - - K 4 ( ( (  Y - - -   4 0 0 0  #It 4 4 4 ! %i 6 6 6 " &y$ 7 7 7  #It 4 4 4 $Y 5 5 5 !) , , , - - - - - - - - - - - - - - - - - -_2<.7;4$UL$?? # >'* ":":(G(G5<2;B8#*AL9)?$:  ]2G"7q'BBB+2A'FF"h..08 W0E0EHW-FFFFFFFFFFFFFFF 2??7B+G4+/>>>??????????????? YXXXXXXX1II(;(?(?(N(N (I;H/8IIIIIIIIIIIIIII#'K"+")%1Et"L"LK"+w{PQQ44A0<C?@|<C &D*H*N3W#Y!5!5!7!7 ''y{{*44B!"d++4BFF;4G4G4PRPVPVW\P]P]4*-d));7j((AGz,A,A,A(QW==AG"#'Z"7"_17j;P"_XYX_T_%:17AJ%O%O"*H*Q*Q'#T'9T=Tb$Q(=uEEE`I`!#D7 CCHC 'u.EqIINQ '/JA N N SRS !(0Ld!S!S$+E3NPQ$R$R$WVW!%,U4PRS%T%T%YXY"$+A~q$A$A$FQ!)04G)K)K)Pq&$'<:K+K$L$L!),Q0ADZ0Z)[)[&%==NP\$]$]!)ABXZk)l)l&!##%1AN 1$$&3AO!-'5A$$q((*;A'%))+=A(?J$4  * %)")-&(*%'+$ &*k*k *k*k*k'%aj11&&55==F22&)!%% 2*>*>&?&?G]sw]]7M(N(Nq(Q(W(W(Y(Y(YFNI("~88GCRCLHC ,!E1-0dikkEJZD[D[6[-\-\** 111-0***1  X%;a%?%? %eM&:&:=S&SUV W WI#D$2$;e'8 $$$ $?(8A%#GA/H$$O$O$USUVVHOO$455508A-:"' 33""%c400"SWWV__ 5S5S389OQR3S3SC0(42;J/J9I$5 6!E 'u.BDII _'.|=Mq'Q'Q'VUVA$)0?QST)U)U)ZYZA&+2+>;JL,5z+B%-%-%-)-%-GQQUW[F\F\&fdhh/A&B&B&BbfG)'488@8? 5(!!! D!'?'?#E7N4HbIIOR#E:r::@b2>%6%<"-B ((( ( > D",,L ,@3? 0(!!! D!$!qQZq,0nnnnc!*oo.A2r(J(Jnnn--) -8,-J7L,M) q@ ! )-@278I8M8Mk8Z8Z8i^b^g^i^i2j2j?T!"!" )qqq"LL)`koLpppppq&&((,Q%@@@@ e<L%)6.2ikk*5%eee %T_c dddddeC9.A"BCCCIw qw qw qw qw qw qV    $ K (AK!M*---- KKKLL!IJJJJJK" J'<'HJ))*5555 JJJLL!HIIIIIJ B B(7(=(=(?(?88$D*!)2:>>$+E+E+E+E-7"*T**?BJNN>4$H$H$H$H3:bj0'8I4)P)P)P)P6Bbj!23"*BJNN;OQU,V,V,V,V9Hbj!56!)2:>>:Mt+T+T+T+T8Fbj!45'/@Y[_1`1`1`1`>Rbj!:;"*BJNN=$,O,O,O,O2Abj/ B B B B B B B B B B B B B B BH  '  " " "  #   b  ) ) ) MA1488IEEA5t<<F i| < < < < '9k B B B  - - K 4 ( ( (  Y - - -   4 0 0 0  #It 4 4 4 ! %i 6 6 6 " &y$ 7 7 7  #It 4 4 4 $Y 5 5 5 !) , , , - - - - - - - - - - - - - - - - - -C&&((,Q%@@@@ e<L%)6.2ikk*5%eee %T_c dddddeC9.A"BCCCkw qw qw qw qw qw qV    $ K (AK!M*---- KKKLL!IJJJJJK" J'<'HJ))*5555 JJJLL!HIIIIIJ B B(7(=(=(?(?88$D*!)2:>>$+E+E+E+E-7"*T**?BJNN>4$H$H$H$H3:bj0'8I4)P)P)P)P6Bbj!23"*BJNN;OQU,V,V,V,V9Hbj!56!)2:>>:Mt+T+T+T+T8Fbj!45'/@Y[_1`1`1`1`>Rbj!:;"*BJNN=$,O,O,O,O2Abj/ B B B B B B B B B B B B B B BH  '  " " "  #   b  ) ) ) MA1488IEEA5t<<F i| < < < < '9k B B B  - - K 4 ( ( (  Y - - -   4 0 0 0  #It 4 4 4 ! %i 6 6 6 " &y$ 7 7 7  #It 4 4 4 $Y 5 5 5 !) , , , - - - - - - - - - - - - - - - - - -a!ee<L%)4.2ikk;?%z%z%z%zE#aj//A:MrSU4V4V%z%z%z$(<"<"    %eee %T_c ddddde qqMMMMMM++ALFFFFF$qqq %RTUT`ko pppppqmw qw qw qw qw qw qw qw qw qw qw qw qw qw qw qr CFFFFFF!>##''(:;;AAAAAA&&#$<%&^%8q&'o&:'('7#g&)!*oo !(9d ; ; C C C ABBBBB C!-!."0%6&8%6*@$)*@!$D$D  E$(e  <+;'(%!5t<!)!)!)$(D!)BLTSWBXBX"b$((+=">">">^b%gt44<4;1$ !(#E7N4HbIIOR#E:r::@b2>%6%<"-B """%!(#E7N4HbIIOR#E:r::@b"" 928./ D 99122 <#A';Q??D1 <2;E./ Y'.u6Ld'S'S$6JT00222PT C0&0 #I33 Y Y Y KZXXXXX Y= hOOOOOOOO#??:Ta+b+b+b%'NN*,'%-aj.>B%?%? ))T::%immF>S>SWb>b>b$(1 i(D(D %mT:: K*,K.;LL #-j$#?#?!L1;1G1G1d:>>ZcKdKdJ'1%L(3(:(:3z??(K(K(K26))K2H2H//25m6Ir2J2J/C&0!-#@'A !! &>%="+'+%2 &&&N */R #HLL$;$;$Ar B B H H J J  C&019>O1P1P!\V\#0'/||M'B'B'r\iGqGXGXoq(0 ^(D(D(J$, !!<< 122*-hll;P.Q.Q.WUW*X*X*^*^*`*`'* 25jAAAO*43F$7'4+3<< +F+F+[J[,4LL,H,H,NB(0.. h h h OQ[]fgggggggg h))++QZz(Z(ZZK C$7 $D$DuUU V V V''++--K(2K %  " "?E : : :  " "; 6 6 6 C K ( ( ( =C =C = 7,S#agm2D2D2J2J2L2LcSXY%'''' L<"<===.ae<<<    $ K (AK!M*---- KKKLL!IJJJJJK" J'<'HJ))*5555 JJJLL!HIIIIIJ B B(7(=(=(?(?88$D*!)2:>>$+E+E+E+E-7"*T**?BJNN>4$H$H$H$H3:bj0'8I4)P)P)P)P6Bbj!23"*BJNN;OQU,V,V,V,V9Hbj!56!)2:>>:Mt+T+T+T+T8Fbj!45'/@Y[_1`1`1`1`>Rbj!:;"*BJNN=$,O,O,O,O2Abj/ B B B B B B B B B B B B B B B    $ K (AK!M*---- KKKLL!IJJJJJK" J'<'HJ))*5555 JJJLL!HIIIIIJ B B(7(=(=(?(?88$D*!)2:>>$+E+E+E+E-7"*T**?BJNN>4$H$H$H$H3:bj0'8I4)P)P)P)P6Bbj!23"*BJNN;OQU,V,V,V,V9Hbj!56!)2:>>:Mt+T+T+T+T8Fbj!45'/@Y[_1`1`1`1`>Rbj!:;"*BJNN=$,O,O,O,O2Abj/ B B B B B B B B B B B B B B B B" N(N(N( ')*>*@*@@MMMMa&&F:sG44 F63 2288::   G]]__ 27A>>     }#/$((***+ %%b%111+6+BKK H^H`H` ii,Q)DDDD$ i i@ ! )-:26)++.9!"!" )iii"LL)XcgLhhhhhiiiiiiiiiiiiiiii C9&9: ; ; ; FFF`  '  " " "  #   b  ) ) ) MA1488IEEA5t<<F i| < < < < '9k B B B  - - K 4 ( ( (  Y - - -   4 0 0 0  #It 4 4 4 ! %i 6 6 6 " &y$ 7 7 7  #It 4 4 4 $Y 5 5 5 !) , , , - - - - - - - - - - - - - - - - - -s(/3DD .f5E^P]L]&v./A +F37HH+F3{B-f5F h D(/&*A?SYCZ$- JJ d D(/&*A?SYCZ$- JJ` DN i8%+Z'KK klll#'L"C'/||I'>'>$,E,4LL,D,D),E,4LL,D,D)Mw)+;=NNNJ%'79J;JSUU:R:R4 #6#6#6XZL.>L+/@L,,:L)/@L,(M99:B,,GX:Y:Y %67"*(":":\":":K%AA5@ 2AAAAAAAAAAAAAAAllllllll 66-8*,Ej)))*555666666666666666#(K+i'2'C'C)5+?1KLflp1q1q1q$.19 (D(( =/; 0 4 4 6 6 6+7 , 1 1" 1 = = =7B7N T^TjTlTlI!*))'0!+9UVWYb9c9c!+$*KK)B(/<(L(L(1(/3Et(L(L %&%&%& %+))))))))))T  '  " " "  #   b  ) ) ) MA1488IEEA5t<<F i| < < < < '9k B B B  - - K 4 ( ( (  Y - - -   4 0 0 0  #It 4 4 4 ! %i 6 6 6 " &y$ 7 7 7  #It 4 4 4 $Y 5 5 5 !) , , , - - - - - - - - - - - - - - - - - -W4@3C3CJ3O3O3mSm 09T$>@P:":" 6:[$>$::":" 66SSi5j5j 2-W$6$>$?@RTd$e$e$, ."." !"1)))))))))))))))2 $VWWW`  '  " " "  #   b  ) ) ) MA1488IEEA5t<<F i| < < < < '9k B B B  - - K 4 ( ( (  Y - - -   4 0 0 0  #It 4 4 4 ! %i 6 6 6 " &y$ 7 7 7  #It 4 4 4 $Y 5 5 5 !) , , , - - - - - - - - - - - - - - - - - -s%iii'Z\ghhhhhhhhi0 ,J 99  D(/&*A?SYCZ$- JJ D"5 D(/&*A?SYCZ$- JJ0D ,J 90)YOO =+ $$&&&'!!"!---(3'> JDZD\D\I+ g+ g )Ea)S)SKKm<<<!#5t<<  + g+ g+ g+ g+ g+ g+ g+ g+ g+ gb  '  " " "  #   b  ) ) ) MA1488IEEA5t<<F i| < < < < '9k B B B  - - K 4 ( ( (  Y - - -   4 0 0 0  #It 4 4 4 ! %i 6 6 6 " &y$ 7 7 7  #It 4 4 4 $Y 5 5 5 !) , , , - - - - - - - - - - - - - - - - - -e>>%)")-&(*%'+$'^J^^N4F4Fy4Q4Q4\U\^^{DcLbvjsbvbvbvbvJL M!$TY[[!1!1" "" "%%i00S9G 9RN#56 ++?UN#;<<-//?UN#;< !!.111FFHHHH D g g<L%)6.2ikk*3%ggg %Vae fffffgU+ g+ g+ g+ g+ g+ g+ g+ g+ g+ g+ g+ g+ g+ g+ gX J'''''''']N(f  '  " " "  #   b  ) ) ) MA1488IEEA5t<<F i| < < < < '9k B B B  - - K 4 ( ( (  Y - - -   4 0 0 0  #It 4 4 4 ! %i 6 6 6 " &y$ 7 7 7  #It 4 4 4 $Y 5 5 5 !) , , , - - - - - - - - - - - - - - - - - -  '  " " "  #   b  ) ) ) MA1488IEEA5t<<F i| < < < < '9k B B B  - - K 4 ( ( (  Y - - -   4 0 0 0  #It 4 4 4 ! %i 6 6 6 " &y$ 7 7 7  #It 4 4 4 $Y 5 5 5 !) , , , - - - - - - - - - - - - - - - -s"B44*C! C!'%D &D65D6'*FF!$F!C*FH-N  FH NFHNFH`??FHD(E20(fE2 g#f<7E2<g&E2(AiE2 i-i(#E2(i--AAAF)EAE0E/AF)E0'AFFAF)FAFFAF)F E2F)AF-F-E2F0AF-F12E2G$,AHHE2H AHHE2HAHHE2H#AIH: E2IAI I E2I AI IF"E2O1AP P E2P APPE2PAPPA"E2Q<ARRE2R'AR:R7E2R9AR:R:E2SA6AkZ5A[ [ Ak[ $A[3[0Ak[2A[3[3Ak[9A\\ Ak\A\ \Ak\ A\ \!Ak\4 E2\?FH] A]%]$FH]%$A^ ^ FH^ A^ ^ FH^ A^ ^FH^ $A__FH_A__ FH_E9Aee FHeAeeFHeAeeFHg5B8Aj:j:Aj>kAj>k E2kAkkE2kAkkJE2uAvu6 E2vAvvE2v Avv DE2zA|z3,A{ {A|{ &A| |A||A| | A|| E2|A||E2|A|| E2|3FH} A}}FH}$A~}=FH}?A~~FH~ A~~FH~$A~;~8FH~:A~;~; FHE9BE D> FHE BEEFHEBEEFHG)B8BJ.J.BJ2J5BJ2J;CE2N3BN4N3E2N4 BON>E2OBOOE2OFHO BO+O*FHO+$BPPFHPBPPFHP BP&P%FHP&$BQ Q FHQ BQ Q FHQE9BWW FHWBW W FHW#BW W$FHY;B8B]]B]]B]] A E2^B`^*,B__B`_&B`_=B`_?B``B`` E2`B``E2`B``E2`*FHa BaaFHa$Ba7a4FHa6Ba7a7FHa? Bb b FHb $Bb2b/FHb1Bb2b2 FHbFHyCyyFHy CyyFHy$Cy<y9FHy;Cy<y< FHzE9D@ ? FH@ D@@FH@D@@FHB*B8DE/E/DE3E6DE3E)DH3H' EYH3DH7 H7EYH:DH7 H; EYI#DI5I) EYI5DI9 I9EYI<DI9 I= EYJ DJ4J( EYJ4DJ8 J8EYJ;DJ8 JDmk?DllDmlDllADmmDn/m Dm)m&Dn/m(Dm)m)ADn/n.EYn/ Dpn;ADo>o=Dpo> Dp pDpp Dp p DppEYp DppEYpDppA"EYq?ADssEYs'Ds:s7EYs9Ds:s:+EYt&,DuuEYu&Du<u9EYu;Du<u<EYv E2vFHv4 Dwv?FHw$Dw'w$FHw&Dw'w'FHw/ Dw;w:FHw;$Dx"xFHx!Dx"x" FHx,E9D~1~% FH~1D~5~5FH~8D~5~9FHAB8EDDEDDEDD"=EYE ,EF F EYF &EF6F3EYF5EF6F6EYG E2GFHG. EG:G9FHG:$EH!HFHH EH!H!FHH) EH5H4FHH5$EIIFHIEII FHI&E9EO+O FHO+EO/O/FHO2EO/O3FHR B8EUUEUUEUUEYUA2EWWEYW'EW<W9EYW;EW<W<EYXEXXEYX.EYY EYYEYYEYY E2YEY#Y#E2Y&EY#Y'E2Y+BE[2[1E2[2%E\\E2\E\\BE2^5 Ed$_AEb`E`2`1Eb`2EaaEbaEaaAEbbEd$b EbbEd$bEbbEd$b 8EccEd$c=EddEd$dEdd Ed$d#E2d$ Ed1d.E2d0Ed1d13E2e%AEf(f'E2f(&EggE2gEggE2gJEq'q&E2q' Erq1ErrE2rErrD6E2wFHw( Ew4w3FHw4$ExxFHxExxFHx# Ex/x.FHx/$EyyFHyEyy FHy E9E% FH%E))FH,E)-FH2FH@ F@@FH@$FA@=FH@?FAAFHA FAAFHA$FA;A8FHA:FA;A; FHBE9FH G> FHH FH HFHHFH HFHHFHHGD&H F~=H&D F~8L2FN-M,FM5M4FN-M5&FNNFN-NFNNFN-N! F~8N-FN1 N1F~8N4FN1 N5F~8OGD&QB8FT$T$FT(T+FT(T1FF~8Z7 F[[ F~8[F[ [F~8[F[ [F~8[' F\\ F~8\F\ \F~8\F\ \F~8\"A;Fn^AFh_3 Fn_>GD&bB8FeeFee"Fee(B Fhg4 FnhFh hFnhFh hFnh&GD&j>B8FnnFnn Fnn FonFn?n8F~8n?FooB,F~8q2AF~s F~8sGD&u+B8Fx0x0Fx4x7Fx4x=CF~| F|"|!F~|" F|/|,F~|.F|/|/F~|5,F}"}!F~}"'F~ ~ F~~ F~ ~ F~~ F~8~F~ ~F~8~"F~ ~#F~8~3GD&~8F~=~=GD&AB8GDDGDD GDD&BGJ F;B8GI?I3 GJ I?GJ JGJ JGJ JGJ bodyc.ddlm}m}ddlm}t |piddpd}t |piddpd}|s ||dS|s ||dS|j5|j |}d d d n #1swxYwY|s||d d d d S|d}t|d s||d dd d S t|} n #t$r||d dd d cYSwxYwt| dd pd } | s||d dd d S|j5| |jv} d d d n #1swxYwY| s||d dd d S t!||} nC#t$$r6} t&d|| ||d d| d cYd } ~ Sd } ~ wwxYw||| d | d S)uDInject a /steer payload into the active agent for a session. Mirrors the CLI's `/steer ` command (cli.py:6140-6155): - Look up the cached AIAgent for the session (PR #1051's SESSION_AGENT_CACHE). - Verify a stream is currently active for this session. - Call agent.steer(text) — thread-safe, stashes text in _pending_steer for application at the next tool-result boundary. The agent's loop calls _apply_pending_steer_to_tool_results() at the end of every tool batch and appends the steer text to the last tool result's content with a marker, so the model sees the steer as part of the tool output on its next iteration. The user's stream is NOT interrupted. If no agent is cached, the agent is too old to support steer, or no stream is active, return {"accepted": False, "fallback": ""} so the frontend can fall back to interrupt or queue mode. The fallback path is the existing behaviour from PR #1062. Returns 200 with {"accepted": bool, "fallback": str|None, "stream_id": str|None}. r)jbadconfigrjr;rzsession_id requiredz text requiredNFno_cached_agent)acceptedrlrWsteeragent_lacks_steersession_not_foundrQ not_running stream_deadz'agent.steer() raised for session=%s: %s steer_error) api.helpersrrrsrr0r\r>rrrrsrrrrrrr r^rr)rrrrrbrarcachedrfr6rQ stream_aliver rs r5_handle_chat_steerrxs0#""""""""""""" tzr|R006B 7 7 = = ? ?C  ++1r 2 2 8 8 : :D 3s71222 -s7O,,, &33)--c22333333333333333 /qu:K(,..// / 1IE 5' " "/qu:M(,..// / /    ///qu:M(,..// / / //q"4d;;Ct /qu-(,..// / 88'4<7 888888888888888 /qu-(,..// /; D))** ;;; >SIIIqu-(8::;; ; ; ; ; ; ;; 1W8$466 7 77sT$C  CCD!!D>=D>- FF F!"G H+G?9H?HrWc *ddlm}t}t}t}t }t }||vr6t|d||ur#|j}|j}|j}|j}|j}|5||vr ddddS||}|r| ||}|r` | dny#t$r<} ddl } | j td|d| Yd} ~ n8d} ~ wwxYwddl } | j td |d  dd lm} |r!t|d dr| |jn*#t$rt&d YnwxYw||} d} ||d||d||d|rt|d dnd}||d}|s+t|d|}||ur||d}t+j|d}|s5t|dt*}|t*ur||d}t-j|g}|s5t|dt,}|t,ur||g}dddn #1swxYwY|r=t/|5 t1|}t3t|ddt4sg|_t9||stC|dpd)2*tg*fd&thDr|(}'n|"s|$s|%rd%|"dtEtGj#d'})|$r|)|)d(<|%rt5||)d)<tk|j|)|'*s|j6|'|)|&sZ|j$d%tod+tq|dd+d,tEtGj#d-|9n+#t$rt&d.|YnwxYwdddn #1swxYwY| rG| rE | :d/d0difn*#t$rt&d1YnwxYwdS)2u/Signal an in-flight stream to cancel. Returns True if the stream existed. Eagerly releases the session lock (pops STREAMS/CANCEL_FLAGS/AGENT_INSTANCES and clears session.active_stream_id) so new /api/chat/start requests succeed immediately after cancel, even if the agent thread is still blocked. The worker thread's finally block uses .pop(key, None), so the double-pop is a safe no-op. Session cleanup runs outside STREAMS_LOCK to preserve lock ordering (streaming thread does LOCK → STREAMS_LOCK; inverting would deadlock). rrrNFrz%Failed to interrupt agent for stream rozCancel requested for stream zM before agent ready - cancel_event flag set, will be checked on agent startup)r^rjz,Failed to clear clarify prompt during cancelTr;r r r rzMSkipping stale cancel writeback for session %s stream %s; active_stream_id=%srQrRrSrTrrrrO)rrrOr%z7Failed to recover pending user message on cancel for %sz)]*>.*?r/z]*>.*rrrc3 K|]}|vV dSr~r)rr;_contents r5rz cancel_stream..s(ZZww(2ZZZZZZr7)rrrrOrrrrArJrKz.Failed to clear session state on cancel for %sr6r9z#Failed to put cancel event to queue);rsrrrr r rrr\rr7r^logging getLoggerr'rr_r^rjrrr r rrsr/rrrXr rr=rqr0r]rUrrrQrRrSrTr>r2rr4r3rr@rrr?rr>rrrGrr`r9)+rW _live_configstreams cancel_flagsagent_instances partial_texts streams_lockflagrfrrrer<_emit_cancel_event_cancel_session_id_cancel_partial_text live_partials_cancel_reasoninglive_reasoning_cancel_tool_calls live_tools_cs _pending_user_pending_atts_raw _pending_atts_pending_started_msgs_for_recovery _last_userr_already_persisted _last_content_last_ts _user_turn partial_textr_re_has_reasoning _has_tools_cancel_marker_exists_cancel_marker_idx_idx _partial_msgrs+ @r5 cancel_streamr;s} +*****GL%O'MLGL)W$M$MU\$\$\&#0 &6$8 #0 QCQC G # #QCQCQCQCQCQCQCQC  **   HHJJJ ##I..    34444   !!(++11LILLLL  NNN G h ' ' - -KyKKK     I K K K K K K 9 d;; 9&&u'7888 I I I LLG H H H H H I KK " "!  It$$$D)))It,,,DIRWUL$???d,00B??$ H#L2GWWMM11'4'8'8B'G'G$15iDD  F$\3JLabbN%:::$2$6$6y"$E$E!37 2FF! C /GI_``J!777%/^^Ir%B%B"cQCQCQCQCQCQCQCQCQCQCQCQCQCQCQCprc $%7 8 8q cq cp c!"455!'#z4"@"@$GG&#%CL3CCC  KKg*!%7>>  */&%q cq cq cq cq cq cq cq cH'$+C1G$N$NM(/5JD(Q(Q%?IJ[^bdi]j?k?k$sD):$;$;$;qsM'.s4H$'O'O'TST$9CCLRV9W9W)a]a&$B);)G%) "*+=">">&&B)"d33&v&8P8P-/ %-2*%1,6NN9,E,EM'1~~k'B'B'GaH *-==>(N^B^B^#0M#A#A]VcEcEc9=$61B(.+8-0-=-=00J -J.I!(!K!KKP577 !$(C(*I.1j3>.I!(!K!KKP577"&&7&UB#?#?#E#E#G#G#M#M#O#OZZZZBYZZZZZ"15.!E"$N$N*$N +#,$(%(%5%5 **L &N4E4K4K4M4M [1!W"?CCU>V>V %:; ; $#5N  ++,> MMM- L'' +#:-EcJJ$$#',=2H%(%5%5 ) )     c c c MOabbbbb caq cq cq cq cq cq cq cq cq cq cq cq cq cq cq cf@a@ @ LL(Y0C$DE F F F F @ @ @ LL> ? ? ? ? ? @ 4s'K6:AK6=CK6 D2DK6D3K6 )E76K67$FK6FE K66K:=K:`6A8_?E(T_?%T-*_?,T--K_?>`6?%`'$`6&`''`66`:=`:a $bb)rWr~)r;)rAN)r,N)NN)r;r;r;)r)r&)ri)__doc__r!rrrrrrr2rrjrrrUrCrrZrtypingrrr'rrrrrrr r r r r rrrrrrrrrrrrrrrrrrrr api.compression_anchorr!r" api.meteringr#api.run_journalr$api.turn_journalr% api.usager&rr'r(Lockr)r2r0rr6rrBrGrKrIrErMrVr]rbr>r>rrqryrcompilerrrrrrrrrrrrrrrrrrrr/r8r@rGrVr\rarrrsrt api.workspacerurrrrrrrrrrrrrr frozensetrbytes__annotations__rr r-r7r@rDrCrKrWrXr]r^rPrRrYrbrhrjrnrvr|rrrrrrrrrrrrrrrrr rVrYrrrrrrrrrrrrrrrrr rrr!r#r%r*r/r1r3r7r9r;rNrQrSrUrXr\rprs_TOOL_RESULT_SNIPPET_MAX_LIVE_TOOL_PROMPT_DELTA_MAX_LIVE_TOOL_PROMPT_TURN_MAXrzrrrrrrrrrPrrrrrrrr;rr7r5rLs'       8 $ $:9999999]]]]]]]],,,,,,AAAAAA......^^^^^^^^ IN   %BTzBDjBTzB 3:sTz3: -. BBBB@  s t     0!!!!!!!GGG$34.  c C    V EGG8D>c@'+ 7 7   7d^ 7  7 7 7 7BJB )c)c)))) d4j     st 'kkkkkAGV^ Y Y Y# Y# YPS Ycg Y Y Y Y% DI     5s 5tDz 5 5 5 5 "zt"z"z"z"z"zL#'%%$% %%%%(DT4ST>s+#++++ffS4Zf3ffff f;uf;f;f;cf;f;Y]f;f;f;f;R  S C s D     42S#PT*`c8I    T    0 V V V VC>C>CC>3C>`cC>mqC>C>C>C>L      2%%%%%%PCC$       \`cTXjdh&"D""""J   >:::z O3 O O O OItIIIIIX-M-M-M-Ml p'-p'-p'-p'-p'-p'-FPI7dI7tI7I7I7I7XpSpTpppppps DDD