+ iDRt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RI t ] P!] 4t ^RI t ^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIHt^RIt^RIHtHtHtHt^RIHt^RIt^RI H t ^RI!H"t"^RI#H$t$^RI%H&t&]$!4t']"!](4PRR , t*]&!]']*R 7t+]+'d]+Ft,] P[R ],4K M] P[R 4^R I.H/t/H0t0H1t1H2t2^RI3H4t4^RI5H6t7^RI8H9t9^RI#H:t:^RI;Ht>H?t?H@t@HAtAHBtBHCtC^RIDHEtEHFtFHGtGHHtHHItIHJtJHKtKHLtL^RIMHNtN^RIOHPtP^RIQHRtR^RI=HStSHTtTHUtUHVtVHWtWHXtXHYtYHZtZ^RI[H\t\H]t]^RI^H_t_H`taHbtcHdtdHetf^RIgHhthHitiHjtk^RIlHmtmHntn!RR4toRR ltp!R!R"4tq]r!R#04ts]r!0R?m4tt]r!0R@m4tu^tv]P!R$]P4ty]P!R%4tzR&R'lt{R(R)lt|R*R+lt}R,R-lt~]P!R.4t]P!R/]EP4tR0R1ltR2R3ltR4R5ltR6tR7tR8R9lt!R:R;4tRAR<R=llt] R>8Xd]EP!]4R#R#)Bao AI Agent Runner with Tool Calling This module provides a clean, standalone agent that can execute AI models with tool calling capabilities. It handles the conversation loop, tool execution, and response management. Features: - Automatic tool calling loop until completion - Configurable model parameters - Error handling and recovery - Message history management - Support for multiple model providers Usage: from run_agent import AIAgent agent = AIAgent(base_url="http://localhost:30000/v1", model="claude-opus-4-20250514") response = agent.run_conversation("Tell me about the latest Python updates") N)SimpleNamespace)ListDictAnyOptional)OpenAI)datetime)Pathget_hermes_home)load_hermes_dotenvz.env) hermes_home project_envz$Loaded environment variables from %sz7No .env file found. Using system environment variables.)get_tool_definitionsget_toolset_for_toolhandle_function_callcheck_toolset_requirements) cleanup_vm) set_interrupt)cleanup_browser)OPENROUTER_BASE_URL)build_memory_context_block)DEFAULT_AGENT_IDENTITYPLATFORM_HINTSMEMORY_GUIDANCESESSION_SEARCH_GUIDANCESKILLS_GUIDANCEbuild_nous_subscription_prompt)fetch_model_metadataestimate_tokens_roughestimate_messages_tokens_roughestimate_request_tokens_roughget_next_probe_tierparse_context_limit_from_errorsave_context_lengthis_local_endpoint)ContextCompressor)SubdirectoryHintTracker)apply_anthropic_cache_control)build_skills_system_promptbuild_context_files_prompt load_soul_mdTOOL_USE_ENFORCEMENT_GUIDANCETOOL_USE_ENFORCEMENT_MODELSDEVELOPER_ROLE_MODELS!GOOGLE_MODEL_OPERATIONAL_GUIDANCEOPENAI_MODEL_EXECUTION_GUIDANCE)estimate_usage_costnormalize_usage) KawaiiSpinnerbuild_tool_previewget_cute_tool_message_detect_tool_failureget_tool_emoji)convert_scratchpad_to_thinkhas_incomplete_scratchpadsave_trajectory)atomic_json_writeenv_var_enabledcLa]tRt^ntoRtR tRtRtRtRt Rt Rt Rt Vt R #) _SafeWriteru<Transparent stdio wrapper that catches OSError/ValueError from broken pipes. When hermes-agent runs as a systemd service, Docker container, or headless daemon, the stdout/stderr pipe can become unavailable (idle timeout, buffer exhaustion, socket reset). Any print() call then raises ``OSError: [Errno 5] Input/output error``, which can crash agent setup or run_conversation() — especially via double-fault when an except handler also tries to print. Additionally, when subagents run in ThreadPoolExecutor threads, the shared stdout handle can close between thread teardown and cleanup, raising ``ValueError: I/O operation on closed file`` instead of OSError. This wrapper delegates all writes to the underlying stream and silently catches both OSError and ValueError. It is transparent when the wrapped stream is healthy. c4\PVRV4R#)_innerN)object __setattr__)selfinners&&&/home/ubuntu/hermes-agent/run_agent.py__init___SafeWriter.__init__s451cVPPV4# \\3d)\ T\ 4'd\ T4u#^u#i;i)r@writeOSError ValueError isinstancestrlen)rCdatas&&rErL_SafeWriter.writesK =;;$$T* *$ = *4 5 53t9 <1 < =s2AAAclVPP4R# \\3dR#i;iN)r@flushrMrNrCs&rErV_SafeWriter.flushs.  KK   $   s 33c6VPP4#rU)r@filenorWs&rErZ_SafeWriter.filenos{{!!##rHchVPP4# \\3dR#i;i)F)r@isattyrMrNrWs&rEr]_SafeWriter.isattys1 ;;%%' '$  s 11c.\VPV4#rU)getattrr@)rCnames&&rE __getattr___SafeWriter.__getattr__st{{D))rHN)r@)__name__ __module__ __qualname____firstlineno____doc__ __slots__rFrLrVrZr]rb__static_attributes____classdictcell__ __classdict__s@rEr>r>ns4$I2=  $ **rHr>cV^8dQhRR/#returnNrd)formats"rE __annotate__rts;;T;rHcRFLp\\VR4pVfK\V\4'dK2\ \V\V44KN R#)zHWrap stdout/stderr so best-effort console output cannot crash the agent.N)stdoutstderr)r`sysrOr>setattr) stream_namestreams rE_install_safe_stdior|s=+ k40  j&E&E Ck&&9 :,rHca]tRt^toRtV3RlRltV3RlRltV3RlRlt]V3RlR l4t ]V3R lR l4t R t Vt R #)IterationBudgetu9Thread-safe iteration counter for an agent. Each agent (parent or subagent) gets its own ``IterationBudget``. The parent's budget is capped at ``max_iterations`` (default 90). Each subagent gets an independent budget capped at ``delegation.max_iterations`` (default 50) — this means total iterations across parent + subagents can exceed the parent's cap. Users control the per-subagent limit via ``delegation.max_iterations`` in config.yaml. ``execute_code`` (programmatic tool calling) iterations are refunded via :meth:`refund` so they don't eat into the budget. c <V^8dQhRS[/#)rq max_totalint)rsrns"rErtIterationBudget.__annotate__s&&#&rHcTWn^Vn\P!4VnR#rKN)r_used threadingLock_lock)rCrs&&rErFIterationBudget.__init__s" ^^% rHc <V^8dQhRS[/#rqrrbool)rsrns"rErtrsrHc VP;_uu_4VPVP8d RRR4R#V;P^, unRRR4R# +'giR#;i)z7Try to consume one iteration. Returns True if allowed.NFTrrrrWs&rEconsumeIterationBudget.consumesC ZZZzzT^^+Z JJ!OJ ZZZsA A  A1 c<V^8dQhRR/#rprd)rsrns"rErtrs   rHc VP;_uu_4VP^8dV;P^,unRRR4R# +'giR#;i)z6Give back one iteration (e.g. for execute_code turns).N)rrrWs&rErefundIterationBudget.refunds/ ZZZzzA~ a ZZZs +A  A c <V^8dQhRS[/#rr)rsrns"rErtrscrHcVP#rU)rrWs&rEusedIterationBudget.useds zzrHc <V^8dQhRS[/#rr)rsrns"rErtrs7737rHcVP;_uu_4\^VPVP, 4uuRRR4# +'giR#;ir)rmaxrrrWs&rE remainingIterationBudget.remainings. ZZZq$..4::56ZZZs 'A A rN) rerfrgrhrirFrrpropertyrrrkrlrms@rEr~r~sP &&   77rHr~clarifyz(?:^|\s|&&|\|\||;|`)(?: rm\s|rmdir\s| mv\s| sed\s+-i| truncate\s| dd\s| shred\s| git\s+(?:reset|clean|checkout)\s )z[^>]>[^>]|^>[^>]c0V^8dQhR\R\/#)rqcmdrrrPr)rss"rErtrtsrHcV'gR#\PV4'dR#\PV4'dR#R#)zJHeuristic: does this terminal command look like it modifies/deletes files?FT)_DESTRUCTIVE_PATTERNSsearch_REDIRECT_OVERWRITE)rs&rE_is_destructive_commandrs3 ##C((!!#&& rHc$V^8dQhR\/#rr)rss"rErtrts))$)rHca\V4^8:dR#VUu.uFqPPNK pp\;QJdRV4F 'gK RM RM !RV44'dR#.pVEF pVPPp\P !VPP 4p\T\4'g/\P!RT\T4P4R#T\9di\YV4oSfR#\;QJdT3RlT4F 'gK RM RM!T3RlT44'dR#TP!S4KT\"9gEK R# R#uupi \d9\P!RTTPP R,4R#i;i)z?Return True when a tool-call batch is safe to run concurrently.Fc32"TF q\9xK R#5irU)_NEVER_PARALLEL_TOOLS).0ras& rE 1_should_parallelize_tool_batch..s @ZT( (ZsTu@Could not parse args for %s — defaulting to sequential; raw=%sNNu6Non-dict args for %s (%s) — defaulting to sequentialc3<<"TFp\SV4xK R#5irU)_paths_overlap)rexisting scoped_paths& rErr)sXX>+x88s)rQfunctionraanyjsonloads arguments ExceptionloggingdebugrOdicttypere_PATH_SCOPED_TOOLS_extract_parallel_scope_pathappend_PARALLEL_SAFE_TOOLS) tool_callstc tool_namesreserved_paths tool_call tool_name function_argsrs& @rE_should_parallelize_tool_batchrsi :!-78Zr++""ZJ8 s @Z @sss @Z @@@!#N &&++   JJy'9'9'C'CDM-.. MMH]#,,   * *6yPK"sXXsssXXXX  ! !+ .  0 0; > I9  MMR"",,T2    sF *F>GGcJV^8dQhR\R\R\R,/#)rqrrrrN)rPrr )rss"rErtrt4s&==C==PT=rHcV\9dR#VPR4p\V\4'dVP 4'gR#\ V4P 4pVP4'd2\ \PP\V444#\ \PP\\ P!4V, 444#)z8Return the normalized file target for path-scoped tools.Npath) rgetrOrPstripr expanduser is_absoluteosrabspathcwd)rrraw_pathexpandeds&& rErr4s**  (H h $ $HNN,<,<H~((*HBGGOOCM233 DHHJ$9 :; < >>rHz[\ud800-\udfff]z5\[BUDGET(?:\s+WARNING)?:\s+Iteration\s+\d+/\d+\..*?\]c0V^8dQhR\R\/#)rqtextrrrP)rss"rErtrtYsssrHch\PV4'd\PRV4#V#)zReplace lone surrogate code points with U+FFFD (replacement character). Surrogates are invalid in UTF-8 and will crash ``json.dumps()`` inside the OpenAI SDK. This is a fast no-op when the text contains no surrogates. �) _SURROGATE_RErsub)rs&rE_sanitize_surrogatesrYs- D!!  400 KrHc0V^8dQhR\R\/#rqmessagesrr)listr)rss"rErtrtdsDTrHcBRpVEFp\V\4'gKVPR4p\V\4'd9\P V4'd\P RV4VR&RpK{\V\4'gKVF|p\V\4'gKVPR4p\V\4'gKD\P V4'gKa\P RV4VR&RpK~ EK V#)zSanitize surrogate characters from all string content in a messages list. Walks message dicts in-place. Returns True if any surrogates were found and replaced, False otherwise. FcontentrTr)rOrrrPrrrr)rfoundmsgrpartrs& rE_sanitize_messages_surrogatesrds E#t$$ '')$ gs # # (<(? FF:sM:3? [)D177<< 7 (C' 2 2a GGO $3"">#>?i%%1!$459!<=%%-J/N O 3 2  EsK 00 12<2BC034!!$Q( (  s6CD%D-$D% D" D%% E005E+%E0+E0c3 a]tRtRtoRt]V3RlRl4t]PV3RlRl4tRRRRRRRRR^ZR RRR R R R^dRRRRRR RRRRRRRRRRRRRRRRR R RRRRRR ^2R R 33V3R lR lltRt RRlt Rt RR /V3RlRllt V3RlRlt V3RlRltRV3RlRlltV3RlRltV3RlRltV3RlRltV3R lR!ltV3R"lR#ltV3R$lR%ltV3R&lR'ltV3R(lR)ltV3R*lR+ltR,tR-tR.tRV3R/lR0lltV3R1lR2ltRV3R3lR4lltRV3R5lR6lltV3R7lR8lt V3R9lR:lt!V3R;lR<lt"V3R=lR>lt#]$V3R?lR@l4t%V3RAlRBlt&V3RClRDlt']$V3RElRFl4t(V3RGlRHlt)RIR/V3RJlRKllt*]$V3RLlRMl4t+RV3RNlROllt,RV3RPlRQllt-V3RRlRSlt.V3RTlRUlt/V3RVlRWlt0RV3RXlRYllt1V3RZlR[lt2]V3R\lR]l4t3RV3R^lR_llt4]$V3R`lRal4t5]6!0Rm4t7]$V3RblRcl4t8]$V3RdlRel4t9]$V3RflRgl4t:V3RhlRilt;Rjt]$V3RolRpl4t?RV3RqlRrllt@V3RslRtltAV3RulRvltBRwR /V3RxlRylltCV3RzlR{ltDV3R|lR}ltEV3R~lRltFV3RlRltGV3RlRltHV3RlRltI]$V3RlRl4tJV3RlRltK]$V3RlRl4tLV3RlRltMV3RlRltNV3RlRltOV3RlRltPV3RlRltQV3RlRltRRV3RlRlltSRV3RlRlltTRR /V3RlRlltURR /V3RlRlltVV3RlRltWV3RlRltXV3RlRltYRR/V3RlRlltZV3RlRlt[V3RlRlt\V3RlRlt]V3RlRlt^V3RlRlt_V3RlRlt`RR/V3RlRlltaV3RlRltbV3RlRltc]6!0Rm4tdV3RlRlte]$V3RlRl4tf]$V3RlRl4tgV3RlRlthV3RlRltiV3RlRltjV3RlRltkV3RlRltlV3RlRltmV3RlRltnV3RlRlto]$V3RlRl4tpV3RlRltqRV3RlRlltrRRRR/V3RlRlltsRV3RlRllttRV3RlRlltuRV3RlRlltvRV3RlRlltwV3RlRltxV3RlRltyV3RlRltzRV3RlRllt{RV3RlRllt|Rt}Vt~R#)AIAgentiz AI Agent with tool calling capabilities. This class manages the conversation flow, tool execution, and response handling for AI models that support function calling. c <V^8dQhRS[/#rr)rsrns"rErtAIAgent.__annotate__s#rHcVP#rU) _base_urlrWs&rEbase_urlAIAgent.base_urls ~~rHc$<V^8dQhRS[RR/#)rqvaluerrNr)rsrns"rErtr.s>>c>d>rHc^WnV'dVP4VnR#RVnR#rN)r0lower_base_url_lowerrCr4s&&rEr1r2s05u{{}2rHNrg?FTcb<V^8dQhRS[RS[RS[RS[RS[RS[S[,R,RS[R S[S[,R,R S[R S[R S[R S[S[,RS[S[,RS[RS[RS[RS[RS[RS[RS[S[,RS[S[,RS[S[,RS[RS[RS[RS[RS[RS[RS[RS[R S[R!S[R"S[R#S[R$S[R%S[R&S[R'S[S[S[3,R(S[S[S[S[3,,R)S[R*S[R+S[R,S[R-R.R/S[S[S[3,R0S[R1S[R2S[R3S[/1#)4rqr1api_keyproviderapi_mode acp_commandacp_argsNcommandargsmodelmax_iterations tool_delayenabled_toolsetsdisabled_toolsetssave_trajectoriesverbose_logging quiet_modeephemeral_system_promptlog_prefix_chars log_prefixproviders_allowedproviders_ignoredproviders_order provider_sortprovider_require_parametersprovider_data_collection session_idtool_progress_callbacktool_start_callbacktool_complete_callbackthinking_callbackreasoning_callbackclarify_callback step_callbackstream_delta_callbacktool_gen_callbackstatus_callback max_tokensreasoning_configprefill_messagesplatformskip_context_files skip_memoryparent_session_iditeration_budgetr~fallback_modelcheckpoints_enabledcheckpoint_max_snapshotspass_session_idpersist_session) rPrrfloatrrcallablerr)rsrns"rErtr.sw w w w  w   w   w s)d"w w 3i$w w w w s)w  9w  w  !w "#w $"%%w &'w ()w * 9+w , 9-w .c/w 01w 2&*3w 4#&5w 67w 8!)9w :&;w <!)=w >$?w @%Aw B#Cw D Ew F (Gw H$Iw J"Kw LMw NsCx.Ow PtCH~.Qw RSw T!Uw VWw Z[w \,]w ^S#X_w b"cw d#&ew fgw hiw rHc4 3\4\V \4'dT M \V 4VnWnT-;'g \ V 4VnWnWnWn VVn VVn V(Vn RVn RVnV)VnV2VnV3VnV/VnVVnV'dV R2MRVnT;'gRVn\V\4'd5VP-4'dVP-4P/4MRp4T4;'gRVnT;'gTVn\5T;'g T;'g.4VnVR9dW@nMVP0R8Xd RVnMV4f!RVP:9dRVnRVnMtVP0R 8XgV4f!R VP:9dRVnR VnM?VP:P=R 4P?R 4'd RVnMRVnVP8R8XdVPA4'dRVnVP0R 8XgVPC4'd(\DPF!RRR7PI4VVn%VVn&VVn'VVn(VVn)RVn*V Vn+V!Vn,V"Vn-V$Vn.V#Vn/RVn0RVn1RVn2RVn3\DPh!4Vn5^Vn6.Vn7\DPp!4Vn9VVn:VVn;VVn<VVn=VVn>VVn?Wn@WnAV%VnBV&VnCT';'g.VnDVPC4p5RVPP/49p6VP8R8Hp7T5;'d T6;'gT7TnERVnFRVnGRVnHRVnIRVnJ\P!4VnLRVnMRVnN^VnO^RIPHQp8HRp9V8!\R7VP'dV9!4\PR4MNVP'd=RF6p:\P!V:4P\P4K8 RVnZRVn[RVn\RVn]/Vn^RVn_RVn`VP8R8Xd^RIaHbp;Hcp<VP0R 8Hp=V='dT;'gVV>VndV>VneWnf^RIaHgp?V?!V>4Vn`V;!V>V4Vn_RVnh/VniVP'gM\RVP R24V>'d,\V>4^ 8d\RV>R, R V>RR 24EM]V'dV'dR!VR"V/p@VP0R#8XdVP2X@R$&VP6V@R%&TpAR VAP/49dR&R'R(R)R*R+/X@R,&EMcR-XAP/49d^R.IlHmpBVB!4X@R,&EM7VnhVP'g\RVP 24V'd\R?V 24X@PR!R@4pKVK'd4XKRA8wd-\XK4^ 8d\RBXKR, R VKRR 24M \RCXK'd XKRD,MR@ RE24\V.\44'dcV.UMu.uFOpM\VM\4'gKXMPRG4'gK4XMPRH4'gKMXMNKQ upMVn{MT\V.\4'd8V.PRG4'd!V.PRH4'd V..Vn{M.Vn{^Vn|RVn}VP'dVP^,MRVn~VP'dVP'g\VP4^8Xd5VP^,pN\RIVNRH, RJVNRG, RK24MI\RL\VP4 RM2RNPROVP44,4E\V V VPRP7VnE\4VnVEP'dVEPUOu0uFpOVORQ,RR,kK upOVnE\ VEP4pPVP'g\RS\VEP4 RTRUPXP4 24V 'd\RVRUPV 4 24V 'd\RWRUPV 4 24MVP'g \RX4VEP'dcVP'gQE\ 4pQVQEP 4URUSu.uFwpRpSVS'dKXRNK pTpRpSVT'd\RYXT 24VP'dVP'g \RZ4VP'dbVP'gP\VP4^<8dVPR[,R ,M VPpU\R\VU R]24VP'd;VP'g)V7'dR^MR_pV\R`VV RUVP Ra24E\EP!4VnV'd VVnMRVEPEPRb4pWE\EP!4EPRc,pXVW RdVX 2VnE\4pYVYRe, VnVEP EP#RRRf7VEP RgVEP Rh2, Vn.VnRVn^RiIHpZVZ!V0V1Rj7VnV+VnV,Vn^VnVEP0'dVEP0EP7VEPVP;'g"\EP8PRkRl4VPRmVPRnV&RoV%/RVEP2Rp7^RrIHp[V[!4Vn^RsIHp\V\!4p]RVnRVnRVn^ Vn^Vn^Vn^VnV*'gX]PRt/4p^V^PRuR4VnV^PRvR4VnE\UV^PRw^ 44VnE\UV^PRx^44VnVEPH'gVEPJ'dR^RyIHp_V_!X^PRzR{4V^PR|R}4R~7VnVEPFEP[4RVnV*'EgX^'dX^PRGR4MRp`V`'g^RIHpaVaEPc4pbVbEPd'd}XbP'gXbP*'dYRp`^RIHpcHpdVc!4peRVeEPiRt/4RG&Vd!Ve4VP'g\R4\R4X`'Ed^RIHpf^RIHpgVf!4VnVg!X`4phVh'd5XhEPs4'dVEP\EPuXh4VEP\EPv'd^RIHpiRVEPRT(;'gRlR\Xi!44RR/pj^RIHpkVk!4plVlVjR&RVjR&VEP\EP~!R/XjB\PRX`4M\EPRX`4RVnVEP\'dVEPeVEP\EP4F_pnRRQRQVn/poVEPEPVo4VnPRRR4ppVp'gKBVEPEPXp4Ka ^ VnX]PR/4pqE\UVqPR^ 44VnX]PR/4pr\Vr\4'g/prXrPRR34VnX]PR/4ps\Vs\4'g/psE\XsPRR44pt\VsPRR44P/4R9puVsPR4;'gRpvE\XsPRR44pwE\UVsPR^44pxX]PRH/4py\Vy\4'dXyPR4pzMRpzXzeE\UXz4pzXzEfX]PR4p{\V{\44'dX{Fp|\V|\4'gKX|PR"4;'gRP=R 4p}V}'gKOX}VP*P=R 48XgKqX|PR/4p~\V~\4'dUX~PVP/4p\V\4'd#XPR4pVeE\UX4pzM E\VPXt^XxXwXvVPVP*E\VR!R4XzVP0R7 VnXuVnE\\P!R4;'gRR7Vn^Vn^Vn^Vn^Vn^Vn^Vn^Vn^Vn^Vn^VnRVnRVnR@VnVP'gXu'dV\RVEPEPR< RE\UXt^d,4 RVEPEPR< RK24M&\RVEPEPR< R24VEPpRHVPRGVP0R"VP*RVP8R!E\VR!R4R\VP4RVPRVPRVP*RE\VR!R4RVP0RVEPRVEP/ VnVP8R8XdDVEPEPRVPRVPRVP/4R#R# \dpL\RFTL 24hRpL?Lii;iuupMiuupOiuupSpRi \d#pL\EP;RqTL4RpL?LE LRpL?Lii;i \d/p]E L{i;i \dELZi;i \dELi;i \dELi;i \dELi;i \d*pm\EP;RTm4RTnRpm?mELRpm?mii;i \dELi;i E\E\3dRpzELi;i E\E\3dELi;i)ah Initialize the AI Agent. Args: base_url (str): Base URL for the model API (optional) api_key (str): API key for authentication (optional, uses env var if not provided) provider (str): Provider identifier (optional; used for telemetry/routing hints) api_mode (str): API mode override: "chat_completions" or "codex_responses" model (str): Model name to use (default: "anthropic/claude-opus-4.6") max_iterations (int): Maximum number of tool calling iterations (default: 90) tool_delay (float): Delay between tool calls in seconds (default: 1.0) enabled_toolsets (List[str]): Only enable tools from these toolsets (optional) disabled_toolsets (List[str]): Disable tools from these toolsets (optional) save_trajectories (bool): Whether to save conversation trajectories to JSONL files (default: False) verbose_logging (bool): Enable verbose logging for debugging (default: False) quiet_mode (bool): Suppress progress output for clean CLI experience (default: False) ephemeral_system_prompt (str): System prompt used during agent execution but NOT saved to trajectories (optional) log_prefix_chars (int): Number of characters to show in log previews for tool calls/responses (default: 100) log_prefix (str): Prefix to add to all log messages for identification in parallel processing (default: "") providers_allowed (List[str]): OpenRouter providers to allow (optional) providers_ignored (List[str]): OpenRouter providers to ignore (optional) providers_order (List[str]): OpenRouter providers to try in order (optional) provider_sort (str): Sort providers by price/throughput/latency (optional) session_id (str): Pre-generated session ID for logging (optional, auto-generated if not provided) tool_progress_callback (callable): Callback function(tool_name, args_preview) for progress notifications clarify_callback (callable): Callback function(question, choices) -> str for interactive user questions. Provided by the platform layer (CLI or gateway). If None, the clarify tool returns an error. max_tokens (int): Maximum tokens for model responses (optional, uses model default if not set) reasoning_config (Dict): OpenRouter reasoning configuration override (e.g. {"effort": "none"} to disable thinking). If None, defaults to {"enabled": True, "effort": "medium"} for OpenRouter. Set to disable/customize reasoning. prefill_messages (List[Dict]): Messages to prepend to conversation history as prefilled context. Useful for injecting a few-shot example or priming the model's response style. Example: [{"role": "user", "content": "Hi!"}, {"role": "assistant", "content": "Hello!"}] platform (str): The interface platform the user is on (e.g. "cli", "telegram", "discord", "whatsapp"). Used to inject platform-specific formatting hints into the system prompt. skip_context_files (bool): If True, skip auto-injection of SOUL.md, AGENTS.md, and .cursorrules into the system prompt. Use this for batch processing and data generation to avoid polluting trajectories with user-specific persona or project instructions. N rchat_completionscodex_responsesanthropic_messages openai-codexzchatgpt.com/backend-api/codex anthropicapi.anthropic.com/ /anthropic openrouterc\4#rU)rrdrHrE"AIAgent.__init__..s35rHTtargetdaemonFclaude5mffffff?g? initializing) setup_loggingsetup_verbose_logging)r z=Verbose logging enabled (third-party library logs suppressed))build_anthropic_clientresolve_anthropic_token_is_oauth_tokenu&🤖 AI Agent initialized with model: z (Anthropic native)u🔑 Using token: NN...r;r1 copilot-acpr@rAz HTTP-Refererz%https://hermes-agent.nousresearch.comzX-OpenRouter-Titlez Hermes AgentzX-OpenRouter-Categorieszproductivity,cli-agentdefault_headersapi.githubcopilot.comcopilot_default_headers api.kimi.com User-Agent KimiCLI/1.3resolve_provider_clientauto)rB raw_codex_default_headersz Provider 'z:' is set in config.yaml but no API key was found. Set the zU_API_KEY environment variable, or switch to a different provider with `hermes model`.OPENROUTER_API_KEYzx-anthropic-betaz&fine-grained-tool-streaming-2025-05-14r agent_initreasonsharedu🔗 Using custom base URL: nonez dummy-keyu🔑 Using API key: u;⚠️ Warning: API key appears invalid or missing (got: ':NNz...')z$Failed to initialize OpenAI client: r<rBu🔄 Fallback model:  ()u🔄 Fallback chain (z providers):  → c3L"TFqR, RVR, R2xK R#5i)rBrr<rNrd)rr's& rEr#AIAgent.__init__..s%"cNbj\AjM?!#DNbs"$)rErFrIrrau🛠️ Loaded z tools: , u ✅ Enabled toolsets: u ❌ Disabled toolsets: u@🛠️ No tools loaded (all tools filtered out or unavailable)u=⚠️ Some tools may not work due to missing requirements: u📝 Trajectory saving enabledN<Nu🔒 Ephemeral system prompt: 'z' (not saved to trajectories)znative AnthropiczClaude via OpenRouteru💾 Prompt caching: ENABLED (z TTL) %Y%m%d_%H%M%SNNrsessions)parentsr session_.json)CheckpointManager)enabled max_snapshotsHERMES_SESSION_SOURCEclirCr_r^)rSsourcerB model_configuser_idrdzESession DB create_session failed (session_search still available): %s) TodoStore) load_configmemorymemory_enableduser_profile_enablednudge_intervalflush_min_turns) MemoryStorememory_char_limitiuser_char_limiti_)rr)HonchoClientConfighoncho)r save_configu5 ✓ Auto-migrated Honcho to memory provider plugin.z( Your config and data are preserved. ) MemoryManager)load_memory_providerr rSrar agent_contextprimary)get_active_profile_nameagent_identityhermesagent_workspacezMemory provider '%s' activatedz/Memory provider '%s' not found or not availablez&Memory provider plugin init failed: %srskillscreation_nudge_intervalagenttool_use_enforcement compression threshold?r summary_model target_ratio皙?protect_last_ncontext_lengthcustom_providersmodels) rBthreshold_percentprotect_first_nrsummary_target_ratiosummary_model_overriderIr1r;config_context_lengthr< TERMINAL_CWD) working_dirunknownu📊 Context limit: z tokens (compress at z% = z# tokens (auto-compression disabled)r= client_kwargsuse_prompt_cachingcompressor_modelcompressor_base_urlcompressor_api_keycompressor_providercompressor_context_lengthcompressor_threshold_tokensanthropic_api_keyanthropic_base_urlis_anthropic_oauth>rprorq)tools run_agenttrajectory_compressorcron hermes_cli)rrwcustomrd)true1yes)r|rOrPrBrCr~rerDrGrHrIrJra _print_fnbackground_review_callbackrbrirj_credential_poolrKrLr1rr7r<r>rr?r=r8rstripendswith_is_direct_openai_url_is_openrouter_urlrThreadstartrTrUrVrWrX_reasoning_deltas_firedrYrZr[r]r\_last_reported_tool_executing_tools_interrupt_requested_interrupt_messageRLock _client_lock_delegate_depth_active_childrenr_active_children_lockrMrNrOrPrQrRrErFr^r_r`_use_prompt_caching _cache_ttl_budget_caution_threshold_budget_warning_threshold_budget_pressure_enabled_context_pressure_warnedtime_last_activity_ts_last_activity_desc _current_tool_api_call_counthermes_loggingrr _hermes_homerinfor getLoggersetLevelERROR_stream_callback_stream_needs_break_persist_user_message_idx_persist_user_message_override_anthropic_image_fallback_cache_anthropic_client_is_anthropic_oauthagent.anthropic_adapterrrr;_anthropic_api_key_anthropic_base_urlrclient_client_kwargsprintrQhermes_cli.modelsragent.auxiliary_clientrhasattrrr RuntimeErrorupperrgetenvrr_create_openai_clientr_fallback_chain_fallback_index_fallback_activated_fallback_modelrrrsetvalid_tool_namessortedritemsrr session_startrSruuiduuid4hexr logs_dirmkdirsession_log_file_session_messages_cached_system_prompttools.checkpoint_managerr_checkpoint_mgr _session_db_parent_session_id_last_flushed_db_idxcreate_sessionenvironr tools.todo_toolr _todo_storehermes_cli.configr _memory_store_memory_enabled_user_profile_enabled_memory_nudge_interval_memory_flush_min_turns_turns_since_memory_iters_since_skillrtools.memory_toolrload_from_disk_memory_managerplugins.memory.honcho.clientrfrom_global_configrr setdefaultagent.memory_managerrplugins.memoryr is_available add_provider providershermes_constantshermes_cli.profilesrinitialize_allrget_all_tool_schemasradd_skill_nudge_interval_tool_use_enforcementrkrrNr&r`context_compressorcompression_enabledr'_subdirectory_hints_user_turn_countsession_prompt_tokenssession_completion_tokenssession_total_tokenssession_api_callssession_input_tokenssession_output_tokenssession_cache_read_tokenssession_cache_write_tokenssession_reasoning_tokenssession_estimated_cost_usdsession_cost_statussession_cost_sourcerthreshold_tokens_primary_runtimeupdate)rCr1r;r<r=r>r?r@rArBrCrDrErFrGrHrIrJrKrLrMrNrOrPrQrRrSrTrUrVrWrXrYrZr[r\r]r^r_r`rarbrc session_dbrdrerfcredential_poolrgrhrirj provider_name is_openrouter is_claudeis_native_anthropicrr quiet_loggerrr_is_native_anthropic effective_key_is_oatreffective_baserr_routed_clientr _explicit_effective_baseheaders existing_beta _FINE_GRAINEDkey_useder'fbrr requirementsra available missing_reqsprompt_previewr timestamp_str short_uuidr rr_load_agent_config _agent_cfg mem_configr_mem_provider_name_HCC_hcfg_lc_sc_cfg_MemoryManager _load_mem_mp_ghh _init_kwargsr_profile_mpe_schema_wrapped_tname skills_config_agent_section_compression_cfgcompression_thresholdrdcompression_summary_modelcompression_target_ratiocompression_protect_last _model_cfg_config_context_length_custom_providers _cp_entry_cp_url _cp_models _cp_model_cfg_cp_ctx_ccs&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&& rErFAIAgent.__init__s z (44U#e* ,!1 S SON4S$!2.$'>$  *.'"4.. / 0.8ZL*b B 4>x4M4MRZR`R`RbRb(..0hl %++ &11'X33334 T T$M ]]n ,-DM#)HDL`L`)`-DM*DM ]]k )m.CH[_c_s_sHs0DM'DM  ! ! ( ( - 6 6| D D1DM.DM ==. .43M3M3O3O-DM ==L (D,C,C,E,E   5 eg&<##6 &<#!2"4',$ 0*%:".!2#' !&%*!"&%OO- ! "%.^^%5""3!2.*+F((@%!1!2% 0 0 6 6B //1  0 0 22 "mm/CC$1$?$?i#W#WDW  *-&),&(,% ).% )- (6 )-$% H,/     ! # KKW X %L%%l3<tzzlJ]^_ S%7"%<.}R/@.A]SUSVEWDXYZ8"+GZ J ==M1/3/?/?M),,0MMM&)!)>#7#7#99&(O,n13K8M"34 -0D0D0FFI7N7PM"34#~';';'==$m8M"34 K$;MM++V4::%O!!-!>#9#9"C(?(?$@%M ~/ABB~GfGfGf;?@_@_;` &78 "&!4!4" ; ; = C C EI Y6V%V*( 422;//2C1DE_`"299-A2#F"$7)*,S0.57O,%M#0D "-"3"3J"CDJJLO.8 @P@Pb?W?W?Y3Y'++,=>DD" ' ,> C H  5$9Fq6X 236C 237>M"34(,,Y;DL O"88|dh8i B4::,OP $D  - -.2D2DZ2P2PUcUgUghoUpUp$2#3D #%D  #( :>:N:N:Nt33A6TX    4''(A-))!,-bk]"R ^FvzwSwSN 3N3CC`a b  # # #DOOO+>'D[F 26("T__>BSUV3W/X,'''4+E+E+E=)4*4..9Ld*S(27H$(O*D&&&557 ${: ,GQZ^^J%CWY"*[ $ 7 7 9 ===emmmu~~~19.% d'*uLT" =j I #D $(??? %&] ^ %&Q R&%TP+9+;D(#$67Cs//11,,99#>++555L($//&(9(9E)3tv;+Y ( !S'>'@H=EL)9:>FL):;,,;;KlK $DFXY %VXjk/3,    DJJ$://DDF"J GD !!(+ VR06))--f5 G&(" &NN8R8M),]->->?XZ\-])^D & $4.$//N%3%7%78NPV%W" &>>-<*D11!  %&6&:&:;&M N!"2"6"6y$"GHNNPThh$4$8$8$I$Q$QT!#()9)=)=nd)S#T #&'7';';>BFFsKGw7dmm.B.B3.G#G%.]]8R%@ %j$77,6NN4::r,JM)->>*7*;*;"3"#4**33!9#<]]D)R0"8]] # $7 #: .199T$  !"&'")*&$%!!"$%!%&")*&*+'()%*-'#, #) ",T-D-D-S-STU,VVkloqFGJqJmKlLLPQUQhQhQyQyz{P||}~,T-D-D-S-STU,VVyz{ %% TZZ    wtY3 T$"5"56 $":":  !3<< '#y""= !3<< ');); )3+?+?!  ==0 0  ! ! ( (#T%<%<$d&>&>$d&>&>*  1U  O"%I!#MNN O$<%V _D []^ & J 2  :$-% $% %0 )! ! ,GN'+$$ ,$   >z* .)-& .(-6z+B%-(,%-s*AbAAb 2Ab Ab:Ab5Ab50Ab5 Ab51Ab: Ab?-Ab?$5AcAAc= Ac5B'Ad A,AAd CAeCAeC3)Ad-DAd-D/Ad-EAd-E-AdE1Ad-FAd-FAeF"'AeG AeG!:AeHAeH9AeIAd?I'4AeJAeM#3AfS AfW8 Af6b Ab2bAb-b-Ab2c Ac2cAc-c-Ac2c5 AddAdd AddAdd Ad*d&Ad-d)Ad*d*Ad-d- Ad<d8Aed;Ad<d<Aed? Aee Aee AeeAee AfeAffAff AffAffAf3f2Af3f6Ag g Ag c ^Vn^Vn^Vn^Vn^Vn^Vn^Vn^Vn^VnRVn RVn RVn ^Vn \VR4'dVP'dz^VPn^VPn^VPn^VPnRVPnRVPnRVPnR#R#R#)a3Reset all session-scoped token counters to 0 for a fresh session. This method encapsulates the reset logic for all session-level metrics including: - Token usage counters (input, output, total, prompt, completion) - Cache read/write tokens - API call count - Reasoning tokens - Estimated cost tracking - Context compressor internal counters The method safely handles optional attributes (e.g., context compressor) using ``hasattr`` checks. This keeps the counter reset logic DRY and maintainable in one place rather than scattering it across multiple methods. rrrrcFN)rirkrlrgrhrmrnrorjrprqrrrfr*rclast_prompt_tokenslast_completion_tokenslast_total_tokenscompression_count_context_probed_context_probe_persistable_previous_summaryrWs&rEreset_session_stateAIAgent.reset_session_states&%&!$%!%&"%&")*&)*&*+'()%!"*-'#, #) !" 4- . .43J3J3J9:D # # 6=>D # # :89D # # 589D # # 56;D # # 3AFD # # >8 %s (%s))%rhermes_cli.providersrrBr<r1r=r;r"rrrr#r`r$r r!r%r&r.rr7r r*rcagent.model_metadatarrrrrsr?rtrur1r0r)rC new_model new_providerr;r1r=rr old_model old_providerrrrr~rr{rnew_context_lengthrs&&&&&& rErAIAgent.switch_models ;),AHJJ }}  $  11DMM  "L + +   $VVt||VV7N7PVVTVM(L&3 #'/']']74AVX\3]D $%;77&D "(7}'ED $DK"$D #33t||M%66N=N#D 44T(()%5DK'*>> dmm11r88: : \ \x9??K\?\ # #"  4- . .43J3J3J E!9   "  -1JJD # # )/3}}D # # ,.2llD # # +/3}}D # # ,5GD # # 27:"T%<%<%N%NN8D # # 4 &*"*17K)L)LQUQhQhQhd%%nr TZZ    wtY3 T$"5"56 $":": S djj !33<S>S>S  $)&)rHc <V^8dQhRS[/#rr)rsrns"rErtr.sTrHc VPeR#\\RR4pVfR#\VP 44# \ \ \3dR#i;i)aZReturn True when quiet-mode spinner output has a safe sink. In headless/stdio-protocol environments, a raw spinner with no custom ``_print_fn`` falls back to ``sys.stdout`` and can corrupt protocol streams such as ACP JSON-RPC. Allow quiet spinners only when either: - output is explicitly rerouted via ``_print_fn``; or - stdout is a real TTY. NTrvF)rr`rxrr]AttributeErrorrNrM)rCr{s& rE_should_start_quiet_spinner#AIAgent._should_start_quiet_spinnersV >> %h- >  ( ( G4  sAAAc$<V^8dQhRS[RR/#rqmessagerrNr)rsrns"rErtr.sUUCUDUrHc VPVP V 2RR7VP'dVPRV4R#R# \dL6i;i \d\P RRR7R#i;i)uhEmit a lifecycle status message to both CLI and gateway channels. CLI users see the message via ``_vprint(force=True)`` so it is always visible regardless of verbose/quiet mode. Gateway consumers receive it through ``status_callback("lifecycle", ...)``. This helper never raises — exceptions are swallowed so it cannot interrupt the retry/fallback logic. Tr lifecyclez%status_callback error in _emit_statusexc_infoN)rrLrr]rr)rCrs&&rE _emit_statusAIAgent._emit_statuss  LLDOO,WI6dL C     U$$[':      U Dt T Us"!A A AA"BBc&<V^8dQhRS[RS[/#)rqr1rrr)rsrns"rErtr.sCCcCTCrHc nT;'g VPP4pRV9;'dRV9#)z8Return True when a base URL targets OpenAI's native API.zapi.openai.comrw)r8r7)rCr1urls&& rErAIAgent._is_direct_openai_urls6//4//6683&BBR>R>Y>YZ]>^>g>ght>uurHc&<V^8dQhRS[RS[/#)rqr4rr)rr)rsrns"rErtr.s % %s %t %rHc >VP4'dRV/#RV/#)zReturn the correct max tokens kwarg for the current provider. OpenAI's newer models (gpt-4o, o-series, gpt-5+) require 'max_completion_tokens'. OpenRouter, local models, and older OpenAI models use 'max_tokens'. max_completion_tokensr^)rr9s&&rE_max_tokens_paramAIAgent._max_tokens_params)  % % ' '+U3 3e$$rHc&<V^8dQhRS[RS[/#rqrrrr)rsrns"rErtr.s%%c%d%rHc jV'gR#VPV4p\VP44#)a Check if content has actual text after any reasoning/thinking blocks. This detects cases where the model only outputs reasoning but no actual response, which indicates an incomplete generation that should be retried. Must stay in sync with _strip_think_blocks() tag variants. Args: content: The assistant message content to check Returns: True if there's meaningful content after think blocks, False otherwise F)_strip_think_blocksrr)rCrrs&& rE_has_content_after_think_block&AIAgent._has_content_after_think_blocks/**73GMMO$$rHc&<V^8dQhRS[RS[/#rr)rsrns"rErtr.s  3 3 rHc V'gR#\P!RRV\PR7p\P!RRV\P\P,R7p\P!RRV\PR7p\P!RRV\PR7p\P!RRV\PR7pV#)zKRemove reasoning/thinking blocks from content, returning only visible text.rz.*?flagsz.*?z.*?z0.*?z8\s*)rrDOTALL IGNORECASE)rCrs&&rErAIAgent._strip_think_blockss&&.G299M&&4b'UWUbUbIbc&&6G299U&&LbRYacajajk&&TVXZaikivivwrHc X<V^8dQhRS[RS[RS[S[S[S[3,,RS[/#)rq user_messageassistant_contentrrr)rPrrrr)rsrns"rErtr.sLEeEeEeEetCH~& Ee  EerHc a a \;QJdRV4F 'gK RM RM !RV44'dR#TPT;'gR4P4P4o S 'gR#\ S 4R8dR#\ \ P!RS 44pV'gR#R pR pT;'gRP4P4o \;QJdV 3RlV4F 'gK RM RM!V 3RlV44;'gRS 9;'gR S 9p\;QJdV 3R lV4F 'gK RM RM!V 3R lV44p\;QJdV 3R lV4F 'gK RM RM!V 3R lV44p T;'g T ;'dT#)zNDetect a planning/ack message that should continue instead of ending the turn.c3z"TF1p\V\4;'dVPR4R8HxK3 R#5i)rrN)rOrrrrs& rEr=AIAgent._looks_like_codex_intermediate_ack..s/Whsz#t$BBF)BBhs;;TFriu@\b(i['’]ll|i will|let me|i can do that|i can help with that)\bc3,<"TF qS9xK R#5irUrd)rmarker user_texts& rErr QsD2C)#2Cz~/ruc3,<"TF qS9xK R#5irUrdrr assistant_texts& rErr Us'^~V.(@~rc3,<"TF qS9xK R#5irUrdrs& rErr Vs* 3Dn $3Dr)z look intozlook atinspectscancheckanalyzreviewexplorereadrruntestfixrrfind walkthroughz report back summarize) directoryzcurrent directoryz current dirrrepo repositorycodebaseprojectfolder filesystemz file treefilesr)rrrr7rQrrr) rCrrrhas_future_ackaction_markersworkspace_markersuser_targets_workspaceassistant_mentions_actionassistant_targets_workspacerrs &&&& @@rE"_looks_like_codex_intermediate_ack*AIAgent._looks_like_codex_intermediate_ackso 3WhW333WhW W W112C2I2IrJPPRXXZ ~  % IIY[i j  *  "''R..0668 CD2CDCCCD2CD D  y   i  %(C'^~'^CCC'^~'^$^!&)c* 3D* ccc* 3D* ' #'EE*EddKddrHc0<V^8dQhRS[S[,/#rrrP)rsrns"rErtr.\s@@x}@rHc `.p\VR4'd.VP'dVPVP4\VR4'd?VP'd-VPV9dVPVP4\VR4'dVP'dVPFp\ V\ 4'gKVPR4;'gDVPR4;'g+VPR4;'gVPR4pV'gKWB9gKVPV4K \VRR4pV'g\ V\4'dV'dR pVFzp\P\P,p\P!WuVR 7F6p V P4p V 'gKW9gK%VPV 4K8 K| V'dR PV4#R#) a Extract reasoning/thinking content from an assistant message. OpenRouter and various providers can return reasoning in multiple formats: 1. message.reasoning - Direct reasoning field (DeepSeek, Qwen, etc.) 2. message.reasoning_content - Alternative field (Moonshot AI, Novita, etc.) 3. message.reasoning_details - Array of {type, summary, ...} objects (OpenRouter unified) Args: assistant_message: The assistant message object from the API response Returns: Combined reasoning text, or None if no reasoning found reasoningreasoning_contentreasoning_detailssummarythinkingrrNr )(.*?)z(.*?)z(.*?)z2(.*?))r*r4rr5r6rOrrr`rPrrrfindallrr) rCassistant_messagereasoning_partsdetailr7rinline_patternspatternrblockrs && rE_extract_reasoningAIAgent._extract_reasoning\s $k 2 27H7R7R7R  " "#4#>#> ? $&9 : :?P?b?b?b 22/I&&'8'J'JK $&9 : :?P?b?b?b+==fd++ 9-..!::j1..!::i0.."::f-  w7#A'..w7>+Y=:gs#;#;O + BMM1ZZFE#kkmGw7#A'..w7G+ ;;/ /rHc <V^8dQhRS[S[,RS[RS[S[S[S[3,,RS[S[S[S[S[3,,,RS[S[S[3,/#)rq finish_reason approx_tokens api_messagesconversation_historyrr)rrPrrrr)rsrns"rErtr.sqB B  } B  B 4S>* B 'tDcN';<B  c3hB rHc VPV4p\\VRR4;'g#\VRR4;'g\VRR44p\VRR4;'gRpVPV4P 4p TT;'gR\V4T;'gR3p V \VRR48Hp \VRR4p \V R ^4;'g^p \V R ^4;'g^p\T ;'d(V\ \ V R ,4V48;'g\V4^P84p\\VR R4;'gR4p\V4p\VR 8H\V RR4VV.4p\VP;'dT;'dT;'dV '*4pWn RVRVRV RVRVRVRV/#)aClassify think-only/empty responses so we can retry, compress, or salvage. We intentionally do NOT short-circuit all structured-reasoning responses. Prior discussion/PR history shows some models recover on retry. Instead we: - compress immediately when the pattern looks like implicit context pressure - salvage reasoning early when the same reasoning-only payload repeats - otherwise preserve the normal retry path r4Nr5r6rr_last_empty_content_signaturercrrs皙?r1lengthrFreasoning_texthas_structured_reasoningrepeated_signatureshould_compressis_local_customis_large_session is_resumed) rBrr`rrrrrQr%rrdrJ)rCr<rErFrGrHrMrNrstripped_content signaturerO compressorctx_lenrsrRrQrScontext_pressure_signalsrPs&&$$$$ rE _classify_empty_content_response(AIAgent._classify_empty_content_responses""001BC#' %{D 9 E E(*=tD E E(*=tD$  +Y=CC33G<BBD   b ) *   R  ''$8WY]*^^T#7> *&6:??a":/A1EJJ  S S#c'C-.@BR*SS & &< 2% ,GD*b,I,O,ORP./ #&) $5u=   $    $ $ % % % %( % %%$  .7* n &(@ "4    0 *  rHc$<V^8dQhRS[RR/#)rqtask_idrrNr)rsrns"rErtr.s V Vs Vt VrHc \\V4\ V4R# \d9pTP'd\P!RT RT 24Rp?LLRp?ii;i \d@pTP'd#\P!RT RT 24Rp?R#Rp?R#Rp?ii;i)z3Clean up VM and browser resources for a given task.zFailed to cleanup VM for task : Nz#Failed to cleanup browser for task )rrrHrr r)rCr\rs&& rE_cleanup_task_resourcesAIAgent._cleanup_task_resourcess Q w  V G $  Q###"@ A3 OP Q  V###"EgYbQRPS TUU$ Vs+  A! A.AA! B+,.B&&B+uReview the conversation above and consider saving to memory if appropriate. Focus on: 1. Has the user revealed things about themselves — their persona, desires, preferences, or personal details worth remembering? 2. Has the user expressed expectations about how you should behave, their work style, or ways they want you to operate? If something stands out, save it using the memory tool. If nothing is worth saving, just say 'Nothing to save.' and stop.aReview the conversation above and consider saving or updating a skill if appropriate. Focus on: was a non-trivial approach used to complete a task that required trial and error, or changing course due to experiential findings along the way, or did the user expect or desire a different method or outcome? If a relevant skill already exists, update it with what you learned. Otherwise, create a new skill if the approach is reusable. If nothing is worth saving, just say 'Nothing to save.' and stop.uReview the conversation above and consider two things: **Memory**: Has the user revealed things about themselves — their persona, desires, preferences, or personal details? Has the user expressed expectations about how you should behave, their work style, or ways they want you to operate? If so, save using the memory tool. **Skills**: Was a non-trivial approach used to complete a task that required trial and error, or changing course due to experiential findings along the way, or did the user expect or desire a different method or outcome? If a relevant skill already exists, update it. Otherwise, create a new one if the approach is reusable. Only act if there's something genuinely worth saving. If nothing stands out, just say 'Nothing to save.' and stop.c@<V^8dQhRS[S[,RS[RS[RR/#)rqmessages_snapshot review_memory review_skillsrrN)rrr)rsrns"rErtr.s=hh:hh h  hrHc aaa^RIpV'dV'dSPoM!V'dSPoM SPoVVV3RlpVP!VRRR7pVP 4R#)axSpawn a background thread to review the conversation for memory/skill saves. Creates a full AIAgent fork with the same model, tools, and context as the main session. The review prompt is appended as the next user turn in the forked conversation. Writes directly to the shared memory/skill stores. Never modifies the main conversation history or produces user-visible output. Nc<^RIp^RIpRp\VPR4;_uu_4pVP V4;_uu_4VP V4;_uu_4\ SP^RSPSPR7pSPVn SPVn SPVn ^Vn ^VnVPSSR7RRR4RRR4RRR4.p\!VR.4EFp\#V\$4'dVP'R4R8wdK2\(P*!VP'R R 44pTP'R 4'gKrTP'R R 4pTP'RR 4pRTP149dTP3T4KRTP149dTP3T4KRTP149gT'dARTP149d,TR8XdRM TR8XdRMTp TP3T R24EKCRT9d,TR8XdRM TR8XdRMTp TP3T R24EKuRTP149gRTP149gEKTR8XdRM TR8XdRMTp TP3T R24EK V'dYRP5\$P7V44p SP9RV 24SP:p V 'd V !RV 24Te2\!TRR4p T eTPCT R RR!7RTn"R#R#R# +'giEL;i +'giEL;i +'giEL;i \(P,\.3dEKi;i \<dLi;i \<d!p \>PART 4Rp ? LRp ? ii;i \<dR#i;i TeA\!TRR4p T e/TPCT R RR!7RTn"i \<dii;iii;i)"rKNrT)rBrCrIrar<)rrHr>rrr{}successrrr|createdupdatedaddedr`rMemoryuserz User profilez updatedz Entry addedremovedreplacedu · u 💾 u💾 z)Background memory/skill review failed: %sr%bg_review_doner)# contextlibrrdevnullredirect_stdoutredirect_stderrr,rBrar<rJrKrLrMrarun_conversationr`rOrrrrrrr7rrfromkeysrrrrr_close_openai_clientr%)rq_os review_agent_devnullactionsrrRrr|labelr7_bg_cbrr%rbpromptrCs rE _run_review5AIAgent._spawn_background_review.._run_review-s (LK !#++s++x//99//99#*"jj'(#'!%!% $L261C1CL.373G3GL09=9S9SL6:;L79:L6 11%+->2::,."<1DbIC%c400CGGFOv4M !#zz#'')T*BC 88I.. "hhy"5G!XXh3F GMMO3w/"gmmo5w/ GMMO35GMMOC[,2h,>V\`fVfNlr%'9:&'1,2h,>V\`fVfNlr%'9:"gmmo5w}}9V,2h,>V\`fVfNlr%'9:/J2$kk$--*@AG$$wwi%89!<37L/ *,:99:99,++:!00)<! !6 )! ! M H!LL M )! ! +$\8TBF)!(== &/?>37L/(! ! *,s ONN BM/ "N *N2A O<&N+"O9BO BO+4O A O- OP / N: N  N  N N( " O+O O O  O OOPOO P *PPP  P PPQ%6QQ% Q Q%Q  Q%Tz bg-review)r|r}ra)r_COMBINED_REVIEW_PROMPT_MEMORY_REVIEW_PROMPT_SKILL_REVIEW_PROMPTrr)rCrbrcrdrrtr~sff&& @rE_spawn_background_review AIAgent._spawn_background_reviewsY  ]11F //F..FN !`   K; O  rHc4<V^8dQhRS[S[,RR/#rrr)rsrns"rErtr.s**T$Z*D*rHc \VRR4p\VRR4pVeVfR#^Tu;8:d\V48dCMR#W,p\V\4'dVP R4R8XdW4R&R#R#R#R#)amRewrite the current-turn user message before persistence/return. Some call paths need an API-only user-message variant without letting that synthetic text leak into persisted transcripts or resumed session history. When an override is configured for the active turn, mutate the in-memory messages list in place so both persistence and returned history stay clean. rNrrrmr)r`rQrOrr)rCridxoverriders&& rE$_apply_persist_user_message_override,AIAgent._apply_persist_user_message_overrides{d7>4!A4H  s{   #c(m # #-C#t$$F)B!)I*C$ $rHcF<V^8dQhRS[S[,RS[S[,/#rqrrHr)rsrns"rErtr.s( K Kd K4PT: KrHc VP'gR#VPV4WnVPV4VP W4R#)zSave session state to both JSON log and SQLite on any exit path. Ensures conversations are never lost, even on errors or early returns. Skipped when ``persist_session=False`` (ephemeral helper flows). N)rjrr>_save_session_log_flush_messages_to_session_db)rCrrHs&&&rE_persist_sessionAIAgent._persist_sessionsC ###  11(;!) x( **8JrHcF<V^8dQhRS[S[,RS[S[,/#rr)rsrns"rErtr.s*.F.Fd4j.FX\]aXb.FrHc VP'gR#VPV4VPPVPVP;'gRVP R7V'd \ V4M^p\W0P4pWREFgpVPRR4pVPR4pRp\VR4'd[VP'dIVPU u.uF1p RV PPR V PP/NK3 pp M.\VPR4\ 4'd VR,pVPP#VPTTVPR 4TVPR 4VPR 4VR 8XdVPR4MRVR 8XdVPR4MRVR 8XdVPR4MRR7 EKj \ V4VnR#uup i \$d"p \&P)RT 4Rp ? R#Rp ? ii;i)uPersist any un-flushed messages to the SQLite session store. Uses _last_flushed_db_idx to track which messages have already been written, so repeated calls (from multiple exit paths) only write truly new messages — preventing the duplicate-write bug (#860). Nr)rrBrrrrrarr tool_call_idrE assistantr4r6codex_reasoning_items) rSrrrrrrEr4r6rz$Session DB append_message failed: %s)rBrensure_sessionrSrarBrQrrDrr*rrrarrOrappend_messagerrr ) rCrrH start_idx flush_fromrrrtool_calls_datarrs &&& rEr%AIAgent._flush_messages_to_session_dbs  11(;$ F    + +}}--jj ,  6J01qIY(A(ABJ ,wwvy1''),"&3 --#...#&..'"0B !1!1; @U@UV"0$'O  5t<<&),&7O  //##!ggk2.!$!8"%''/":6:k6Icggk2tFJkFYcgg.A&B_cNRVaNa#''2I*Jgk0 -.),H D %%'& F NNA1 E E Fs=2HH5A2H(H67H-C*HH I )II cF<V^8dQhRS[S[,RS[S[,/#rr)rsrns"rErtr.s#--4:-$t*-rHc V'g.#Rp\\V4^, RR4F#pW,PR4R8XgK!TpM VfVP4#VRV#)am Get messages up to (but not including) the last assistant turn. This is used when we need to "roll back" to the last successful point in the conversation, typically when the final assistant message is incomplete or malformed. Args: messages: Full message list Returns: Messages up to the last complete assistant turn (ending with user/tool message) Nrr)rangerQrcopy)rCrlast_assistant_idxis&& rE"_get_messages_up_to_last_assistant*AIAgent._get_messages_up_to_last_assistantsqI"s8}q("b1A{v&+5%&"2  %==? "++,,rHc <V^8dQhRS[/#rr)rsrns"rErtr.s??#?rHc  VP'gR#.pVPFNpVR,pRVR,RVPRR4RVPR/4RR/pVPV4KP \P!VR R 7#) z Format tool definitions for the system message in the trajectory format. Returns: str: JSON string representation of tool definitions z[]rra descriptionr parametersrequiredNFr)rrrrr)rCformatted_toolsrfuncformatted_tools& rE _format_tools_for_system_message(AIAgent._format_tools_for_system_messageszzzJJD #DV txx r:dhh|R8D N  " "> 2zz/>>rHc ~<V^8dQhRS[S[S[S[3,,RS[RS[RS[S[S[S[3,,/#)rqr user_query completedrrrrrPrr)rsrns"rErtr.saccd4S>6JcX[chlcquvz{~AD|DwErFcrHc  B .pRVP4 R2pVPRRRV/4VPRRRV/4^pV\V48EdW,pVR,R8XEdR V9EdVR ,'EdR pVPR 4'd+VR ,P 4'dR VR , R 2pVPR4'd>VR,P 4'd!V\ VR,4R,, pVR ,Fp V 'd\ V \4'gK#\ V R,R,\4'd%\P!V R,R,4MV R,R,p RV R,R,RV /p VR\P!V RR7 R2, pK RV9d RV,pVPRRRVP4/4.p V^,p V \V48EdW,R,R8XdW,pRpVR,pVP 4P!R"4'd\P!V4p\T 4pT\TR ,48dTR ,T,R,R,MRpT\P!RTPRR 4RTRT/RR7, pTR , pT PT4T ^, p EKV 'd.VPRRRRP%V 4/4V ^, pMR pVPR 4'd+VR ,P 4'dR VR , R 2pVR,;'gR pV\ V4, pRV9d RV,pVPRRRVP 4/4M*VR,R!8XdVPRRRVR,/4V^, pEKV# \Pd5\P!RT R,R,R, 24/p ELi;i \P\"3dELi;i)#a) Convert internal message format to trajectory format for saving. Args: messages (List[Dict]): Internal message history user_query (str): Original user query completed (bool): Whether the conversation completed successfully Returns: List[Dict]: Messages in trajectory format aYou are a function calling AI model. You are provided with function signatures within XML tags. You may call one or more functions to assist with the user query. If available tools are not relevant in assisting with user query, just respond in natural conversational language. Don't make assumptions about what values to plug into functions. After calling & executing the functions, you will be provided with function results within XML tags. Here are the available tools: a For each function call return a JSON object, with the following pydantic model json schema for each: {'title': 'FunctionCall', 'type': 'object', 'properties': {'name': {'title': 'Name', 'type': 'string'}, 'arguments': {'title': 'Arguments', 'type': 'object'}}, 'required': ['name', 'arguments']} Each function call should be enclosed within XML tags. Example: {'name': ,'arguments': } fromsystemr4humanrrrrr4z z r rrz2Unexpected invalid JSON in trajectory conversion: NdNraz Frz z gptrz rrz rm){[)rrrQrrr8rOrrPrrrrr rr startswithrr)rCrrr trajectory system_msgrrrrrtool_call_jsonr jtool_msg tool_response tool_content tool_indexr raw_contents&&&& rE_convert_to_trajectory_format%AIAgent._convert_to_trajectory_formats   ==?@Af f   H Z   G Z   #h-+C6{k)3&3|+<+<!Gww{++K0@0F0F0H0H$-c+.>-?|"Lwwy))c)n.B.B.D.D #>s9~#NQU#UU&)%6%6 ( 9d0K0KX+Zdenoyez|GfHJM[N[N 9Z3H3U(VT]^hTijuTvI#Ij$9&$A'* ]4::n[`3a2bbr#ss!&7(!/"7'"A%%!1' &(NAAc(m+ F0Cv0M#+;(; (0 ': !+113>>zJJ/3zz,/G &)%8  *CL0A,BB -j9*EfM!*" &*HLL,L"I%|5). *// &)== &--m<Q&"))"F#TYY~%>+E !Gww{++K0@0F0F0H0H$-c+.>-?|"L#&i."6"6BK:;GGG!/"7'"A%%' V&!!GS^# FAy $33+$OO.`ajkuavxCbDEIbJaK-LM(*I +F!% 4 4nE! !s&AP3;Q?3AQ<;Q<?RRcR<V^8dQhRS[S[S[S[3,,RS[RS[/#)rqrrrr)rsrns"rErtr.s5 D Dd38n)= D3 D[_ DrHc ~VP'gR#VPWV4p\W@PV4R#)z Save conversation trajectory to JSONL file. Args: messages (List[Dict]): Complete message history user_query (str): Original user query completed (bool): Whether the conversation completed successfully N)rGr_save_trajectory_to_filerB)rCrrrrs&&&& rE_save_trajectoryAIAgent._save_trajectorys3%%% 77iX  ZZCrHc&<V^8dQhRS[RS[/#rqerrorrr)rrP)rsrns"rErtr.s&&&&I&&#&&rHc ^RIp\V4pRV9gRV9dVPRW!P4pV'd VP ^4P 4MRpVPRV4pV'd VP ^4P 4MRp\ VRR4p.pV'dVPRV 24VPV4V'dVPR V 24R PV4#\ VR R4p \V \4'd\V PR 4\4'd"V PR /4PR 4MV PR 4p V 'd+\ VRR4pV'dRV R2MRp V V R, 2#\ VRR4pV'dRV R2MRp V VR, 2#)zExtract a human-readable one-liner from an API error. Handles Cloudflare HTML error pages (502, 503, etc.) by pulling the tag instead of dumping raw HTML. Falls back to a truncated str(error) for everything else. Nz <!DOCTYPE<htmlz<title[^>]*>([^<]+)z!HTML error page (title not found)z2Cloudflare Ray ID:\s*]*>([^<]+) status_codezHTTP zRay u — bodyrrr^rNi,NNiN) rrPrrgrouprr`rrrOrr) r_rerawmtitlerayray_idrrrrprefixs & rE_summarize_api_errorAIAgent._summarize_api_errors %j # C 93OA*+AGGAJ$$&1TE**RTWXC-0SYYq\'')dF!%=KE u[M23 LL  tF8_-<<& &ufd+ dD ! !:DTXXgEVX\:]:]$((7B'++I6cgckcklucvC%e]DA 4?5 R0R #d)--e]D9 ,75 R(R#d)%%rHcF<V^8dQhRS[S[,RS[S[,/#)rqkeyrrr2)rsrns"rErtr.s#))(3-)HSM)rHc\V'gR#\V4^ 8:dR#VR, RVRR 2#)Nz***rrrrQ)rCrs&&rE_mask_api_key_for_logsAIAgent._mask_api_key_for_logss1 s8r>b'#c"#hZ((rHc&<V^8dQhRS[RS[/#)rq error_msgrrr)rsrns"rErtr.sccrHc V'gR#VP4PR4'gRV9dR#RPVP44p\ V4^8dVR,R,pV#)z Clean up error messages for user display, removing HTML content and truncating. Args: error_msg: Raw error message from API or exception Returns: Clean, user-friendly error message z Unknown errorz>)>S#X>rHc /p\VRR4pRp\V\4'd9\VPR4\4'dVPR4MTp\V\4'EdBVPR4;'gVPR4p\V\4'd*VP 4'dVP 4VR&VPR4;'gVPR4p\V\4'd*VP 4'dVP 4VR&RF!pVPV4pVR9gKWqR&M VPR 4pVR9d1RV9d*\ P !4\V4,VR&\VR R4p \V R R4p V 'dV PR 4;'gV PR4pV'd1RV9d*\ P !4\V4,VR&V PR4p V 'd RV9dWR&RV9d.\ V4P 4p V 'd V R,VR&RV9Ed/VPR4;'gR p\V\4'd\P!RV\P4p V 'dk\V P^44pV P^4P4R8Xd VR, MTp\ P !4V,VR&V#\P!RV\P4pV'd8\ P !4\VP^44,VR&V# \\3dEL(i;i \\3dELi;i)z;Extract structured rate-limit details from provider errors.rNrcoderrerror_descriptionreset_atr retry_afterresponser retry-after Retry-Afterzx-ratelimit-resetrz/quotaResetDelay[:\s\"]+(\\d+(?:\\.\\d+)?)(ms|s)msg@@z?retry\s+(?:after\s+)?(\d+(?:\.\d+)?)\s*(?:sec|secs|seconds|s\b)) resets_atr)Nr)r`rOrrrPrrrkrrNrrrrr7)rcontextrpayloadrrrr4rrrratelimit_reset raw_message delay_matchseconds sec_matchs& rE_extract_api_error_context"AIAgent._extract_api_error_context s)#%ufd+ dD ! !+5dhhw6G+N+Ndhhw'TXG gt $ $[[(@@GKK,@F&#&&6<<>>$*LLN!kk),PP O:W#<&5 # G #e***,K%0%6 " W $kk),22G'3'' ii(Z\cegerers !+"3"3A"67E0;0A0A!0D0J0J0LPT0TefnZ_G*.))+*?GJ'!# Z !I !.2iikE)//RSBTP@!R(T 24Rp?R#Rp?ii;i)*z Dump a debug-friendly HTTP request record for the active inference API. Captures the request body from api_kwargs (excluding transport-only keys like timeout). Intended for debugging provider-side 4xx failures where retries are not useful. timeoutNr;z,Could not extract API key for debug dump: %sr#rSrrequestmethodPOSTrrurpz /responsesz/chat/completionsr AuthorizationzBearer z Content-Typezapplication/jsonrrrrrresponse_status response_textz,Could not extract error response details: %srr  request_dump_rrF)rindentdefaultrru$🧾 Request debug dump written to: HERMES_DUMP_REQUEST_STDOUTz*Failed to dump API request debug payload: )r request_idrparamr)!rdeepcopyrr6r`r%rrrrr isoformatrSr1rr=rrrerPrrr; write_textrrrrLr<r'rHrr )rCrrrrkvr;r dump_payload error_info attr_name attr_value body_attr response_objr# dump_file dump_errors&&$$ rE_dump_api_request_debugAIAgent._dump_api_request_debugU sB ==,D HHY %%)ZZ\C\TQQDAD\DCG P!$++y$? X\\^557doo&fdmm22378ZkIkrE9FG'743N3Nw3W2X)Y&(: D ,L DK00s5z. "XI!(4!@J!-0:9-"X $E648 ()2v&&uj$? +X8? m]a8b #456B6G6G ?3)3W% //0BCI -7H)TY(ZZI   )z\n\1z ()\n+z\1\n)r8rrr)rs&rE_clean_session_contentAIAgent._clean_session_content sGN-g6&&'7;&&)7G<}}rHcF<V^8dQhRS[S[S[S[3,,/#)rqrrrrPr)rsrns"rErtr. s'@D@D$tCH~*>@DrHc T;'g VPpV'gR#.pVFgpVPR4R8Xd>VPR4'd'\V4pVPVR,4VR&VP V4Ki VP P 4'd\P!VP PRR74pVPR\VPR.444pV\V48d$\P!R V\V44R#R VPR VPR VP R VP"RVP$P'4R\(P*!4P'4RVP,;'gRRVP.;'g.R\V4RV/ p\1VP V^\2R7R# \dLi;i \d=pTP4'd \P6!RT 24Rp?R#Rp?R#Rp?ii;i)a Save the full raw session to a JSON file. Stores every message exactly as the agent sees it: user messages, assistant messages (with reasoning, finish_reason, tool_calls), tool responses (with tool_call_id, tool_name), and injected system messages (compression summaries, todo snapshots, etc.). REASONING_SCRATCHPAD tags are converted to blocks for consistency. Overwritten after each turn so it always reflects the latest state. Nrrrrr message_countrzHSkipping session log overwrite: existing has %d messages, current has %drSrBr1rar7 last_updated system_promptrr)r r!zFailed to save session log: )r>rrr6rr=existsrr read_textrQrrrrSrBr1rar7r&rrr?rr;rPrHr )rCrrrrexisting_countentryrs&& rErAIAgent._save_session_log s55t55 0 DG776?k1cggi6H6Hs)C%)%@%@Y%PC Ns#  $$++-- #zz$*?*?*I*ISZ*I*[\H%-\\/3x||T^`bGcCd%eN%G 4 f*CL 5dooDMMDMM!3!3!=!=!?  8 8 :!;!;!A!Ar))rWG E %%  !!. D###">qc BCC$ DsP3HAH2B HBHH.H HHHH I $+II c$<V^8dQhRS[RR/#rr)rsrns"rErtr. s%V%V%V%VrHc RVnWn\R4VP;_uu_4\ VP 4pRRR4XFpVP V4K VP'gH\RV'd\V4^(8dRVR, R2MV'dRV R2MR ,4R#R# +'giL;i \d"p\PRT4Rp?KRp?ii;i) a Request the agent to interrupt its current tool-calling loop. Call this from another thread (e.g., input handler, message receiver) to gracefully stop the agent and process a new message. Also signals long-running tool executions (e.g. terminal commands) to terminate early, so the agent can respond immediately. Args: message: Optional new message that triggered the interrupt. If provided, the agent will include this in its response context. Example (CLI): # In a separate input thread: if user_typed_something: agent.interrupt(user_input) Example (Messaging): # When new message arrives for active session: if session_has_running_agent: running_agent.interrupt(new_message.text) TNz0Failed to propagate interrupt to child agent: %su ⚡ Interrupt requestedz: 'rz...''r) rr_set_interruptr rr interruptrrrrIr'rQ)rCr children_copychildrs&& rErGAIAgent.interrupt s0%)!")t  ' ' ' !6!67M("E T(#  -WY\]dYehjYj3ws|nD1IELruv}u~~qARTU V( '  T OQRSS Ts#CC C  DC;;Dc<V^8dQhRR/#rprd)rsrns"rErtr. srHc 8RVnRVn\R4R#)zIClear any pending interrupt request and the global tool interrupt signal.FN)rrrFrWs&rEclear_interruptAIAgent.clear_interrupt s$)!"&urHc$<V^8dQhRS[RR/#)rqdescrrNr)rsrns"rErtr. s((C(D(rHc F\P!4VnWnR#)zAUpdate the last-activity timestamp and description (thread-safe).N)rrr)rCrPs&&rE_touch_activityAIAgent._touch_activity s!%#' rHc <V^8dQhRS[/#rr)rsrns"rErtr.% s  d rHc :\P!4VP, pRVPRVPR\V^4RVPRVP RVP RVPPRVPP/#) zReturn a snapshot of the agent's current activity for diagnostics. Called by the gateway timeout handler to report what the agent was doing when it was killed, and by the periodic "still working" notifications. last_activity_tslast_activity_descseconds_since_activity current_toolapi_call_countrC budget_used budget_max) rrrroundrrrCrerr)rCelapseds& rEget_activity_summaryAIAgent.get_activity_summary% s ))+ 6 66  6 6 $":": $eGQ&7 D.. d22 d11 40055 $//99  rHc$<V^8dQhRS[RR/#rr)rsrns"rErtr.7 srHc VP'dDVPPT;'g.4VPP4R#R# \dL,i;i \dR#i;i)uShut down the memory provider — call at actual session boundaries. This calls on_session_end() then shutdown_all() on the memory manager. NOT called per-turn — only at CLI exit, /reset, gateway session expiry, etc. N)rSon_session_endr shutdown_all)rCrs&&rEshutdown_memory_provider AIAgent.shutdown_memory_provider7 sr     $$33HNNC $$113     s'AAA) A&%A&) A87A8cJ<V^8dQhRS[S[S[S[3,,RR/#)rqhistoryrrNr9)rsrns"rErtr.H s(4S#X+?DrHc BRp\V4F~pVPR4R8wdKVPRR4pRV9dK6\P!V4pRV9d+\ VR,\ 4'd VR,pMK~K V'dZVPPVRR 7VP'g+VPVP R \V4 R 24\R4R# \P \3dEKi;i) z Recover todo state from conversation history. The gateway creates a fresh AIAgent per message, so the in-memory TodoStore is empty. We scan the history for the most recent todo tool response and replay it to reconstruct the state. Nrrrrz"todos"todosF)mergeu📋 Restored z todo item(s) from history)reversedrrrrOrrrrHrLrIrrLrQrF)rCrilast_todo_responserrrRs&& rE_hydrate_todo_storeAIAgent._hydrate_todo_storeH s"G$Cwwv&(ggi,G' zz'*d?z$w-'F'F)-g&(G?%     " "#5U " C??? 0sCU?V>WWqrsu(()4  sAC>>DDc <V^8dQhRS[/#rr)rsrns"rErtr.i s)))rHc VP#)z)Check if an interrupt has been requested.)rrWs&rEis_interruptedAIAgent.is_interruptedh s(((rHc&<V^8dQhRS[RS[/#)rqsystem_messagerrr)rsrns"rErtr.v sl)l)3l)#l)rHc z aaRpSP'g\4pV'dV.pRpV'g1RpT'd\P!RRT 2^4pM\pT.p.pRSP9dVP \ 4RSP9dVP \4RSP9dVP \4V'd!XP R PV44\SP4pV'dXP V4SP'EdSPp Rp V RJg,\V \4'dV P4R#9dRp EMV RJg,\V \4'dV P4R$9dRp M\V \4'd`SP ;'gR P4o\";QJdV3R lV 4F 'gK RM RM!V3R lV 44p MfSP ;'gR P4o\";QJd#V3R l\$4F 'gK RM RM!V3R l\$44p V 'dXP \&4SP ;'gR P4p R V 9gRV 9dVP \(4RV 9gRV 9dVP \*4VeXP V4SP,'dSP.'d5SP,P1R4p V 'dXP V 4SP2'd5SP,P1R4p V 'dXP V 4SP4'd5SP4P74pV'dXP V4\";QJdV3RlR%4F 'gK RM RM!V3RlR%44pV'dERSP4Uu0uFpV'gK VkK pp\;SPVR7pMR pV'dXP V4SP'gG\<P>!R4;'gRp\AVVR7pV'dXP V4^RI!H"pV!4pRVPGR4 2pSPH'd)SPJ'dVRSPJ 2, pSP 'dVRSP 2, pSPL'dVRSPL 2, pXP V4SPLR8XdbRSP 9d#SP POR4R&,M SP pVP RV R SP R!24SPP;'gR P4PS4pV\T9dVP \TV,4R"PV4# \8dELi;iuupi)'a  Assemble the full system prompt from all layers. Called once per session (cached on self._cached_system_prompt) and only rebuilt after context compression events. This ensures the system prompt is stable across all turns in a session, maximizing prefix cache hits. FTNzYou are Hermes AgentzYou are rsession_search skill_managernrc3z<"TF0p\V\4'gKVP4S9xK2 R#5irU)rOrPr7rp model_lowers& rEr/AIAgent._build_system_prompt.. s*_1JWXZ]L^6aggi;6s;;c3,<"TF qS9xK R#5irUrdr{s& rErr~ sT8S1;.8Srgeminigemmarcodexrmc3@<"TFqSP9xK R#5irU)r4)rrarCs& rErr~ swIvt'<'<  ++224::< > )   | < ={{<((w   s$"!Z&Z&, Z8;Z8& Z54Z5c <V^8dQhRS[/#rr)rsrns"rErtr.) s+++rHc \V\4'dVPRR4;'gR#\VRR4;'gR#)z8Extract call ID from a tool_call entry (dict or object).idr)rOrrr`)rs&rE_get_tool_call_id_static AIAgent._get_tool_call_id_static( sA b$  66$#))r )r4$***rHcr<V^8dQhRS[S[S[S[3,,RS[S[S[S[3,,/#rr9)rsrns"rErtr.2 s:CCd38n)=C$tCQTH~BVCrHc  .pVFRpVPR4pV\P9d\P RV4KAVP V4KT Tp\ 4pVFmpVPR4R8XgKVPR4;'g.F3p\PV4pV'gK"VPV4K5 Ko \ 4pVFGpVPR4R8XgKVPR4pV'gK6VPV4KI Wt, pV'd_VU u.uF3p V PR4R8XdV PR4V9dK1V NK5 pp \P R\V44WG, p V 'd.p VFpV P V4VPR4R8XgK,VPR4;'g.F7p\PV4pWj9gK V P RRRR RV/4K9 K T p\P R \V 44V#uup i) uFix orphaned tool_call / tool_result pairs before every LLM call. Runs unconditionally — not gated on whether the context compressor is present — so orphans from session loading or manual message manipulation are always caught. rz9Pre-call sanitizer: dropping message with invalid role %rrrrrz6Pre-call sanitizer: removed %d orphaned tool result(s)ru2[Result unavailable — see context summary above]z0Pre-call sanitizer: added %d stub tool result(s)) rr,_VALID_API_ROLESrrrr3rr`rQ) rfilteredrrsurviving_call_idsrcidresult_call_idsorphaned_resultsrmissing_resultspatcheds & rE_sanitize_api_messagesAIAgent._sanitize_api_messages1 s C776?D7333 O OOC "%%Cwwv+-'',/5525B!::2>Cs*..s36 #uCwwv&(ggn-3#'', +? ##af /AEE.4IM]4]8  LLH$%  -> ,.Gs#776?k1!ggl399r9%>>rB1#NN & )+_ .,: H LLBO$ ;s .I8Ic&<V^8dQhRS[RS[/#rqrrrr)rsrns"rErtr.x sTdrHc :^RIHp\RV44pW!8:dV#^p.pVFSpVPPR8Xd%W18dVP V4V^, pK@KBVP V4KU \ PRW!, V4V#)aBTruncate excess delegate_task calls to MAX_CONCURRENT_CHILDREN. The delegate_tool caps the task list inside a single call, but the model can emit multiple separate delegate_task tool_calls in one turn. This truncates the excess, preserving all non-delegate calls. Returns the original list if no truncation was needed. )MAX_CONCURRENT_CHILDRENc3^"TF#qPPR8XgK^xK% R#5i) delegate_taskNrra)rrs& rEr3AIAgent._cap_delegate_task_calls.. s![2{{7G7G?7ZQQs- -rzUTruncated %d excess delegate_task call(s) to enforce MAX_CONCURRENT_CHILDREN=%d limit)tools.delegate_toolrsumrrarrr )rrdelegate_countkept_delegates truncatedrs& rE_cap_delegate_task_calls AIAgent._cap_delegate_task_callsw s @[[[  4  B{{?2!;$$R("a'N<  $   /  46M rHc&<V^8dQhRS[RS[/#rr)rsrns"rErtr. sGGDGTGrHc f\4p.pVFpVPPVPP3pWA9d%VP V4VP V4KY\ PRVPP4K \V4\V48dV#T#)zRemove duplicate (tool_name, arguments) pairs within a single turn. Only the first occurrence of each unique pair is kept. Returns the original list if no duplicates were found. zRemoved duplicate tool call: %s) r3rrarr`rrr rQ)rseenuniquerrs& rE_deduplicate_tool_callsAIAgent._deduplicate_tool_calls sEB;;##R[[%:%:;C  b!@"++BRBRS Vs:6vFJFrHc4<V^8dQhRS[RS[R,/#rqrrrNr)rsrns"rErtr. s33:rHc ^RIHpVP4pW0P9dV#VP RR4P RR4pW@P9dV#V!W0P^RR7pV'd V^,#R#)zAttempt to repair a mismatched tool name before aborting. 1. Try lowercase 2. Try normalized (lowercase + hyphens/spaces -> underscores) 3. Try fuzzy match (difflib, cutoff=0.7) Returns the repaired name if found in valid_tool_names, else None. )get_close_matches-rrnr)ncutoffN)difflibrr7r4r)rCrrlowered normalizedmatchess&& rE_repair_tool_callAIAgent._repair_tool_call s~ .//# ++ +N__S#.66sC@ .. . $G-B-BaPST 1: rHc pRVnVP'dVPP4R#R#)z Invalidate the cached system prompt, forcing a rebuild on the next turn. Called after context compression events. Also reloads memory from disk so the rebuilt prompt captures any writes from this session. N)r?rJrRrWs&rE_invalidate_system_prompt!AIAgent._invalidate_system_prompt s/&*"        - - / rHc<V^8dQhRS[S[S[S[S[3,,,RS[S[S[S[S[3,,,/#)rqrrr)rrrrPr)rsrns"rErtr. sF!!htDcN/C&D!PXY]^bcfhkck^lYmPn!rHc VeTM VPpV'gR#.pVFp\V\4'dVPR/4M/pVPR4p\V\4'dVP 4'gKlVP RRRVRVPRR4RRR VPR RR R //4/4K T;'gR#) zIConvert chat-completions tool schemas to Responses function-tool schemas.NrrarrrstrictFrrA properties)rrOrrrPrr)rCr source_tools converteditemrras&& rE_responses_toolsAIAgent._responses_tools s % 1utzz *,  D-7d-C-C*b)B66&>DdC((     rvvmR8%bff\FHlTV3WX   !  D rHc2<V^8dQhRS[RS[RS[RS[/#)rqfn_namerindexrr)rPr)rsrns"rErtr. s*       C  PS  rHc ^RIpV RV RV 2pVP!VPRRR74P4R,pRV 2#)uGenerate a deterministic call_id from tool call content. Used as a fallback when the API doesn't provide a call_id. Deterministic IDs prevent cache invalidation — random UUIDs would make every API call's prefix unique, breaking OpenAI's prompt cache. N:rr)errorsN Ncall_)hashlibsha256encode hexdigest)rrrrseeddigests&&& rE_deterministic_call_idAIAgent._deterministic_call_id sT !I;aw/ GI FGQQSTWXvhrHc\<V^8dQhRS[RS[S[S[,S[S[,3,/#)rqraw_idrr)rtuplerrP)rsrns"rErtr. s-x}hsm7S1TrHc H\V\4'gR#VP4pV'gR#RV9dLVPR^4wr#VP4;'gRpVP4;'gRpW#3#VP R4'dRV3#VR3#)z8Split a stored tool id into (call_id, response_item_id).N|fc_NN)rOrPrrr)rr4call_idresponse_item_ids& rE_split_responses_tool_id AIAgent._split_responses_tool_id s&#&&    %<(- C(; %Gmmo--G/557??4 , ,   E " "; d{rHc<<V^8dQhRS[RS[S[,RS[/#)rqrrrr)rPr)rsrns"rErtr. s-#3- rHc ~\V\4'd*VP4pVPR4'dV#T;'gRP4pVPR4'dV#VPR4'd+\ V4\ R48dRV\ R4R 2#\ P !RRV4pVPR4'dV#VPR4'd+\ V4\ R48dRV\ R4R 2#V'd RVR, 2#T;'g=\T;'gR4;'g \P!4Pp\P!VPR44P4R,pRV 2#) zCBuild a valid Responses `function_call.id` (must start with `fc_`).rrrNz[^A-Za-z0-9_-]:N0Nr:NN)rOrPrrrQrrr8r9r:rsha1rr)rCrr candidater sanitizedrrs&&& rE"_derive_responses_function_call_id*AIAgent._derive_responses_function_call_id sr & , ,(..0I##E**  --R&&(   U # #M   W % %#f+G *DG ./0 0FF,b&9    & &     ( (S^c'l-J3w<=123 3 3() )HH-334HH 8H8Hdkk'23==?DVH~rHcr<V^8dQhRS[S[S[S[3,,RS[S[S[S[3,,/#rr9)rsrns"rErtr. s?ww$tCH~:NwSWX\]`be]eXfSgwrHc | .pVEFp\V\4'gKVPR4pVR8XdK6VR!9EduVPRR4pVR8XEd \V\4'd.pVFp\V\4'gKVPR4R8Xd(VP RR RVPRR4/4KXVPR4R 8XgKpVPR /4p\V\4'dVPR R4MRp V 'gKVP RR R V /4K V'dVP RRRV/4EKaVe \ V4MRp VR8XEd!VPR4p Rp \V \4'dNV FGp \V \4'gKV PR4'gK4VP V 4Rp KI V P 4'dVP RRRV /4MV 'dVP RRRR/4VPR4p\V\4'Ed7VEF/p\V\4'gKVPR/4pVPR4p\V\ 4'dVP 4'gKmVPVPR44wppVPR4p\V\ 4'dVP 4'gTp\V\ 4'dVP 4'g\V\ 4'dCVPR4'd,\V4\R48dRV\R4R  2pM7\ VPRR44pVPVV\V44pVP 4pVPRR4p\V\4'd\P!VRR7pM!\V\ 4'g \ V4pVP 4;'gRpVP RRRVRVRV/4EK2 EKVP RVRV /4EKVR8XgEKVPR4pVPV4wpp\V\ 4'dVP 4'g=\V\ 4'd'VP 4'dVP 4p\V\ 4'dVP 4'gEKxTP RRRTR \ VPRR4;'gR4/4EK V#)"z>Convert internal chat-style messages to Responses input items.rrrmrrrrr input_text image_urlr input_imageNrFencrypted_contentTrrrarrrrrrgr function_callrrfunction_call_outputoutput>rmr) rOrrrrrPrrrrQrrr)rCrr6rrrresponses_contentrrr content_textcodex_reasoninghas_codex_reasoningrirrrrembedded_call_idembedded_response_item_idr _raw_argsrraw_tool_call_idrs&& rE!_chat_messages_to_responses_input)AIAgent._chat_messages_to_responses_input s&(Cc4((776?Dx,,'')R06>j$&?&?>@% ')$55$88F+v5-44 & &(<6"XXf-<(,b(AI>HTX>Y>Y)--r":_aC"s 1 8 8$*M$/:"!#!( ) ffiAR%ST /6/Bs7| ;&'*gg.E&FO*/'!/488"1B)"d33?R8S8S % R 06: 3#2 $))++ fk9l%ST,  fk9b%IJ!$!6J!*d33",B#-b$#7#7 (!# B!7B&(ffVnG#-gs#;#;7==?? (JNJgJg "t KG,.G')ffY&7G#-gs#;#;7==??*:#-gs#;#;7==??$./H#$N$N(A(L(LU(S(S(+,E(FU(S056OPSTYPZP[6\5].^G03BFF;4M0NI.2.I.I'S\^abg^h.iG&-mmoG(*{D(AI))T::,0JJyu,U %/ 3%?%?,/ N (1(9(A(ATI!LL & )7 & +Y *C#-N fdI|DEv~#&77>#: !::;KL !'3//w}}!"2C88=M=S=S=U=U"2"8"8":!'3//w}} 2wc#'')R"8">">B?[f rHcL<V^8dQhRS[RS[S[S[S[3,,/#)rq raw_itemsrr)rrrrP)rsrns"rErtr. s,WWcWd4S>>RWrHc \V\4'g \R4h.p\V4EFwr4\V\4'g\RV R24hVP R4pVR8XEdMVP R4pVP R4p\V\ 4'dVP4'g\RV R24h\V\ 4'dVP4'g\RV R24hVP R R 4p\V\4'd\P!VR R 7pM!\V\ 4'g \ V4pVP4;'gR pVPRRRVP4RVP4R V/4EKVR 8XdVP R4p\V\ 4'dVP4'g\RV R24hVP RR4p V fRp \V \ 4'g \ V 4p VPRR RVP4RV /4EKDVR8XdVP R4p \V \ 4'dV 'd|RRRV /p VP R4p \V \ 4'd V 'dWR&VP R4p \V \4'dWR&M.V R&VPV 4EKVP R4pVR9d~VP RR4pVfRp\V\4'dVPRVRV/4M6\V\ 4'g \ V4pVPRVRV/4EK\RV RV: RV: R24h V#)z4Codex Responses input must be a list of input items.zCodex Responses input[] must be an object.rrrraz#] function_call is missing call_id.z ] function_call is missing name.rrgFrrz*] function_call_output is missing call_id.rrr4rrr7rrz#] has unsupported item shape (type=z, role=).>rmr) rOrrN enumeraterrrPrrrr)rCr(rrr item_typerrarr encryptedreasoning_itemitem_idr7rrs&& rE_preflight_codex_input_items$AIAgent._preflight_codex_input_items sd)T**ST T+- "9-ICdD)) #9#>R!STT(IO+((9-xx'!'3//w}}$'=cUBe%fgg!$,,DJJLL$'=cUBb%cdd HH[$7 i.. $ 95 II#Is33 #II%OO-55 !!!7==? #Y 22((9-!'3//w}}$'=cUBl%mnn(B/>F!&#.. [F!! 6!7==? &K' HH%89 i--)&,k;NPY%ZN"hhtnG!'3//G/6t,"hhy1G!'4004;y146y1%%n588F#D,,((9b1? Ggt,,%%vtY&HI%gs33"%g,%%vtY&HI(-PQZP]]deidllno ].drH allow_streamcB<V^8dQhRS[RS[RS[S[S[3,/#)rqrr3rr)rrrrP)rsrns"rErtr. s6{{{ { c3h {rHc  a\V\4'g \R4h0R$mpVUu.uF qDV9gK VNK ppV'd(\RRP\ V44 R24hVP R4p\V\ 4'dVP4'g \R4hVP4pVP R4pVfR p\V\ 4'g \ V4pVP4;'g\pVPVP R44pVP R 4p Rp V Ee\V \4'g \R 4h.p \V 4EFzwr\V \4'g\R V R 24hV P R4R8wd#\R V RV P R4: R24hV P R4p V P R4p\V \ 4'dV P4'g\R V R24h\V\4'g\R V R24hV P RR 4pVfR p\V\ 4'g \ V4pV P RR4p\V\4'g \V4pV PRRRV P4RVRVRV/4EK} VP RR4pVRJd \R4h0R%moRVRVRVRR/pV eV VR &VP R4p\V\4'dVVR&VP R4p\V\4'dVVR&VP R4p\V\\34'dV^8d\V4VR&VP R4p\V\\34'd\V4VR&R&FpVP V4pVfKVVV&K! V'dDVP R4pVeVRJd \R 4hVRJdRVR&SP!R4MRV9d \R!4h\ V3R"lVP#444pV'd\R#RPV4 R24hV#uupi)'z'Codex Responses request must be a dict.rB instructionsinputz3Codex Responses request missing required field(s): r.z;Codex Responses request 'model' must be a non-empty string.Nrrz=Codex Responses request 'tools' must be a list when provided.zCodex Responses tools[r*rrz] has unsupported type rarz] is missing a valid name.z] is missing valid parameters.rrFstorez6Codex Responses contract requires 'store' to be false.r4includemax_output_tokens temperaturer{Tz/Codex Responses 'stream' must be true when set.zKCodex Responses stream flag is only allowed in fallback streaming requests.c38<"TFqS9gK VxK R#5irUrd)rr allowed_keyss& rEr6AIAgent._preflight_codex_api_kwargs..e sX+r7rBr6> r7rBr9rr:r4r< tool_choicer6prompt_cache_keyr;parallel_tool_calls)r@rBrA)rOrrNrr5rrPrrr1rr,rrrrkr`keys)rCrr3rrmissingrBr6normalized_inputrnormalized_toolsrrrarrrr9rr4r:r;r<passthrough_keyvalr{ unexpectedr>s&&$ @rE_preflight_codex_api_kwargs#AIAgent._preflight_codex_api_kwargs s *d++FG G5"*D(3.C33(D RSWS\S\]cdk]lSmRnnopq qw'%%%U[[]]Z[ [ !~~n5  L,,,|,L#))+EE/E <? '#u 6 6;Lq;P.12C.DJ* + nn]3 kC< 0 0(-k(:J} % ZO..1C.1 ?+ Z ^^H-F!fD&8 !RSS~'+ 8$   X &  #jk kX:??+<XX DTYYzEZD[[\] cEs SSc&<V^8dQhRS[RS[/#rqrrrrrP)rsrns"rErtr.m s''C'C'rHc L\VRR4p\V\4'gR#.pVFYp\VRR4pVR9dK\VRR4p\V\4'gK>V'gKHVP V4K[ RP V4P 4#)zr output_textr`rOrrPrrr)rCrrchunksrptypers&& rE_extract_responses_message_text'AIAgent._extract_responses_message_textm s$ 40'4((DD&$/E334.D$$$ d# wwv$$&&rHc&<V^8dQhRS[RS[/#rMrN)rsrns"rErtr.} sccrHc \VRR4p\V\4'ds.pVFCp\VRR4p\V\4'gK(V'gK2VP V4KE V'd RP V4P 4#\VRR4p\V\4'dV'dVP 4#R#)zAExtract a compact reasoning text from a Responses reasoning item.r7NrrrrQ)rCrr7rRrrs&& rE!_extract_responses_reasoning_text)AIAgent._extract_responses_reasoning_text} s$ 40 gt $ $ "FtVT2dC((TTMM$' yy(..00tVT* dC T::< rHc<<V^8dQhRS[RS[S[S[3,/#r)rrrP)rsrns"rErtr. s'b0b0#b0%S/b0rHc \VRR4p\V\4'd V'g\VRR4p\V\4'duVP 4'd_\ P R\VP 444\RRR\RVP 4R7.R 7.pW!n M \R 4h\VR R4p\V\4'd VP 4P4pMRpVR+9dm\VR R4p\V\4'd&VPR4;'g \V4pMV'd \V4MR V R2p\V4h.p.p.p .p VR,9p Rp Rp VEFp\VRR4p\VR R4p\V\4'd VP 4P4pMRpVR,9dRp VR8Xd\VRR4p\V\4'd2VP 4P4pVR-9dRp M VR.9dRp VPV4pV'dVPV4KKVR8XEdVP!V4pV'dVPV4\VRR4p\V\4'dV'dRRRV/p\VRR4p\V\4'dV'dVVR&\VRR4p\V\4'dK.pVF=p\VRR4p\V\4'gK(VPRRRV/4K? VVR&V PV4EKEKEKVR8XEdlVR,9dEK\VRR4;'gRp\VRR4p\V\4'g\"P$!VRR7p\VR R4p\VRR4pVP'V4wp p!\V\4'dVP 4'dTMT p"\V"\4'dV"P 4'gVP)VV\V 44p"V"P 4p"\V\4'dTMRp#VP+V"V#4p#V P\V"V"V#R!\VVR"7R#74EKtVR$8XgEK~\VRR4;'gRp\VR%R4p\V\4'g\"P$!VRR7p\VR R4p\VRR4pVP'V4wp p!\V\4'dVP 4'dTMT p"\V"\4'dV"P 4'gVP)VV\V 44p"V"P 4p"\V\4'dTMRp#VP+V"V#4p#V P\V"V"V#R!\VVR"7R#74EK R&P-VU$u.uFp$V$'gK V$NK up$4P 4p%V%'gF\/VR4'd4\VRR4p\V\4'dVP 4p%\T%T V'd R'P-V4P 4MRRRT ;'gRR(7p&V 'dR)p'V&V'3#V 'gV 'dV 'gRp'V&V'3#V 'dV%'gRp'V&V'3#R*p'V&V'3#uup$i)/zENormalize a Responses API object to an assistant_message-like object.rNrPz`Codex response has empty output but output_text is present (%d chars); synthesizing output item.rrrrrrrstatusrz&Responses API returned no output itemsr^rzResponses API returned status 'rE incompleteFrTphaser4rrr7r summary_textrrarrrgrrrrar)rrrrrcustom_tool_callr7rr9)rrr4r5r6rrstop>failed cancelled>queuedr_ in_progress>analysis commentary>final final_answer)r`rOrrPrrrrQrrr+r7rrrTrrXrrrrrrr*)(rCrrout_textr error_objr content_partsr=reasoning_items_rawrhas_incomplete_itemssaw_commentary_phasesaw_final_answer_phaserr- item_status item_phasenormalized_phase message_textrMr.raw_itemr0r7 raw_summaryrrrr raw_call_id raw_item_idr!rrrr| final_textr<rEs(&& rE_normalize_codex_response!AIAgent._normalize_codex_response s8T2&$''vx=H(C((X^^-=-= 014X^^5E1F*"[,-hnnFVWX#)"#KLL!(Hd; os + +-335;;=O"O 5 5'48I)T**%MM)4FFI .7C N?^_n^oop=q y) )#% %'46 " .2YY$!&Dfd3I!$$7K+s++)//1779 " EE'+$I%$T7D9 j#..'1'7'7'9'?'?'A$'+EE/3,)-FF15.#CCDI !((6 k)!%!G!G!M!#**>:$D*=tD i--) & 5H)TH%dD$7G!'3//G)0%dItD)$44 + 2 2FNFTX3Y Z%,/:+'..x83<-o-"II!$399r#D+t< !)S11 $ 95 II%dIt< %dD$7 &*&C&CK&P# !)3K)E)E+J[J[J]J]+cs!'3//w}}"99'9cR\o^G!--/2<[#2N2N;TX #'#J#J7Td#e !!/#%5#,'YO #00!$399r#D'48 !)S11 $ 95 II%dIt< %dD$7 &*&C&CK&P# !)3K)E)E+J[J[J]J]+cs!'3//w}}"99'9cR\o^G!--/2<[#2N2N;TX #'#J#J7Td#e !!/#%5#,'YO #etYY=>=aA=>?EEG gh >>x;H(C((%^^- +!>Mfkk/288:SW"""5"="=   (M!-//"&:CY(M!-//!)M!-//#M -//; ?s  ^ ^ c <V^8dQhRS[/#rr)rsrns"rErtr.1s//#/rHcb\P!4pVP RVP 2#)r)rcurrent_threadraident)rCthreads& rE_thread_identityAIAgent._thread_identity1s)))+++a ~..rHc <V^8dQhRS[/#rr)rsrns"rErtr.5s  S rHc\VRR4p\VRR4p\VRR4pRVP4 RV RV RV 2#)r<rr1rBzthread= provider=z base_url=z model=)r`r)rCr<r1rBs& rE_client_log_contextAIAgent._client_log_context5s^4Y74Y7gy1d++-.j C z 1 rHc4<V^8dQhRS[P/#r)rr)rsrns"rErtr.>sY__rHc^\VRR4pVf\P!4pWnV#)rN)r`rrr)rClocks& rE_openai_client_lockAIAgent._openai_client_lock>s,t^T2 <??$D $  rHc&<V^8dQhRS[RS[/#rqr%rrrr)rsrns"rErtr.FsrHc ^RIHp\W4'dR#\VRR4pVe5\ V4'dV!4'dR#M\ V4'dR#\VRR4pVe\ \VRR44#R#)aTCheck if an OpenAI client is closed. Handles both property and method forms of is_closed: - httpx.Client.is_closed is a bool property - openai.OpenAI.is_closed is a method returning bool Prior bug: getattr(client, "is_closed", False) returned the bound method, which is always truthy, causing unnecessary client recreation on every call. MockF is_closedNT_client) unittest.mockrrOr`rlr)r%ris_closed_attr http_clients& rE_is_openai_client_closed AIAgent._is_openai_client_closedEs~ ' f # # d;  %''!##$n%%fi6  " [%@A ArHc2<V^8dQhRS[RS[RS[RS[/#)rqrrrrr)rrPrr)rsrns"rErtr.cs+4CQUZ]rHcVVPR8Xg1\VPRR44PR4'd7^RIHpV!R/VBp\ PRVVVP44V#\R/VBp\ PRVVVP44V#)rr1rz acp://copilot)CopilotACPClientz-Copilot ACP client created (%s, shared=%s) %sz(OpenAI client created (%s, shared=%s) %srd) r<rPrragent.copilot_acp_clientrrrrr)rCrrrrr%s&&$$ rEr.AIAgent._create_openai_clientcs ==M )S1B1B:r1R-S-^-^_n-o-o A%6 6F KK?((*   M(-( 6    $ $ &   rHc&<V^8dQhRS[RS[/#r)rr)rsrns"rErtr.ys8888rHc ^RIp^p\VRR4pVf^#\VRR4pVf^#\VRR4pVf^#\VRR4;'g\VRR4;'g.p\V4Fp\VRR4;'g\VRR4pVfK+\VRR4p V f\VR R4p V e\V RR4p V fK`V PVP4V P 4V^, pK V# \ dL-i;i \ dL-i;i \d"p \PR T 4Rp ? T#Rp ? ii;i) aForce-close underlying TCP sockets to prevent CLOSE-WAIT accumulation. When a provider drops a connection mid-stream, httpx's ``client.close()`` performs a graceful shutdown which leaves sockets in CLOSE-WAIT until the OS times them out (often minutes). This method walks the httpx transport pool and issues ``socket.shutdown(SHUT_RDWR)`` + ``socket.close()`` to force an immediate TCP RST, freeing the file descriptors. Returns the number of sockets force-closed. Nr _transport_pool _connections_network_stream_stream_sockr{z'Force-close TCP sockets sweep error: %s) socketr`rshutdown SHUT_RDWRrMcloserrr) r%_socketclosedr transportpool connectionsconnr{sockr)s & rE_force_close_tcp_sockets AIAgent._force_close_tcp_socketsxs !) I!&)T:K" \4@I 9gt4D|nd34$/  [)D"3T:66tY5>vw5<"68T:D'&tWd;<MM'"3"34JJL! -*2  I LLBC H H  Is|D6D6D6D6D6*$D6A D6D5D% D6 D"D6!D""D6% D30D62D33D66 E"EE"c0<V^8dQhRS[RS[RS[RR/#)rqr%rrrrN)rrPr)rsrns"rErtr.s*33QUrHc$VfR#VPV4pVP4\PRVVVVP 44R# \ d3p\P RTTTP 4T4Rp?R#Rp?ii;i)Nz 44V<   LLN KKN((*    LLH((*    s7A B'B  Bc&<V^8dQhRS[RS[/#rqrrrr)rsrns"rErtr.srHc VP4;_uu_4\VRR4pVPVPVRR7pY0nRRR4TPXRT 2RR7R# \d:p\ P RTTP4T4Rp?RRR4R#Rp?ii;i +'giLp;i)r%NTrz7Failed to rebuild shared OpenAI client (%s) %s error=%sFzreplace:) rr`r.r&rrr rr%rw)rCr old_client new_clientr)s&$ rE_replace_primary_openai_client&AIAgent._replace_primary_openai_clients  % % ' ' x6J !778K8KTZcg7h %K( !!*xx5HQU!V M,,.  ( '  ( 's4B4A-B4- B18&B,B4,B11B44 C c&<V^8dQhRS[RS[/#rrPr)rsrns"rErtr.sssrHcVP4;_uu_4\VRR4pVe$VPV4'g VuuRRR4#RRR4\P RVVP 44VP RV 2R7'g \R4hVP4;_uu_4VPuuRRR4# +'giL;i +'giR#;i)r%NzCDetected closed shared OpenAI client; recreating before use (%s) %szrecreate_closed:rz'Failed to recreate closed OpenAI client) rr`rrr rrr+r%)rCrr%s&$ rE_ensure_primary_openai_client%AIAgent._ensure_primary_openai_clients  % % ' 'T8T2F!$*G*G*O*O( ' '  Q   $ $ & 227 A!&)T:K" \4@I 9gt4D|nd34$/  J[)D"3T:66tY5>vw5<"68T:D'&tWd;<( $$U+99Q(8(87;O;O(OPDs{"a ((.9*>A~V33;T3U %'$!OJ$ #((." A LL:C @ @ AsG%G%G%G%"G%7&G%A G%,AF;F* 3G% F'F=F' F'$F=&F''F=* F:5G%9F::G%=G"?GG" G G"G G""G%% H0H  Hc&<V^8dQhRS[RS[/#rr)rsrns"rErtr.2sWWsWsWrHc^RIHpVPVR7p\W24'dV#VP 4;_uu_4\ VP 4pRRR4VPXVRR7# +'giL$;i)rKrrNFr)rrrrOrrr&r.)rCrrprimary_clientrequest_kwargss&$ rE_create_request_openai_client%AIAgent._create_request_openai_client2so&;;6;J n + +! !  % % ' '!$"5"56N()).PU)VV( 's A66 B c*<V^8dQhRS[RS[RR/#)rqr%rrrNrN)rsrns"rErtr.<s'GG3G3G4GrHc,VPWRR7R#)FrN)rw)rCr%rs&&$rE_close_request_openai_client$AIAgent._close_request_openai_client<s !!&!FrHc,<V^8dQhRS[RS[RS[/#)rqrr%on_first_delta)rrrl)rsrns"rErtr.?s(yyDy#yV^yrHc ^ ^RIpT;'gVPRR7p^pRpRpRVn.Vn\ V^,4EFp .p VP P !R#/VB;_uu_4p V EFp VP'dEM\V RR4p RV 9gV R8Xdr\V R R4pV'dVPPV4V'd8V'g.V'gR pV'd V!4VPV4KKKR V 9dR pKR V 9d2R V 9d+\V R R4pV'dVPV4KKV R 8Xd)\V RR4pVeV PV4EKEKV R$9gEK!\V RR4pV'd\VRR4MRpV'd\VRR4MRp\PRV VV\RVP44VP!44EK V P#4p\VRR4p\%V\&4'dV'gV 'd1\'V 4Vn\P+R\-V 44MVP'dxV'gpRP/VP4p\1RRR\1RVR7.R7.Vn\P+R\-VP4\-V44VuuRRR4u# R# \dEL1i;i +'giEK;i TP2TP4TP6\83dpY8d=\P+RT ^,T^,TP!4T4Rp?EKu\P+RTP!4T4TP;YR7uRp?u#Rp?i\<dp\?T4pR T9pT'dBY8d<\P+R!T ^,T^,TP!44Rp?EKT'd>\P+R"TP!44TP;YR7uRp?u#hRp?ii;i)%zJExecute one streaming Responses API request and return the final response.Ncodex_stream_directrFrrzoutput_text.deltaresponse.output_text.deltadeltaTrr4response.output_item.donerrr^incomplete_detailszkCodex Responses stream received terminal event %s (status=%s, incomplete_details=%s, streamed_chars=%d). %sc38"TFp\V4xK R#5irUr)rr|s& rEr,AIAgent._run_codex_stream..{s#T4SqCFF4Srrz;Codex stream: backfilled %d output items from stream eventsrrrrPr\r]z?Codex stream: synthesized output from %d text deltas (%d chars)zNCodex Responses stream transport failed (attempt %s/%s); retrying. %s error=%szYCodex Responses stream transport failed; falling back to create(stream=True). %s error=%s)r%response.completedzGResponses stream closed before completion (attempt %s/%s); retrying. %szYResponses stream did not emit response.completed; falling back to create(stream=True). %srd)response.incompleteresponse.failed) httpxrr_codex_streamed_text_partsr responsesr{rr`rr_fire_stream_delta_fire_reasoning_deltarr rrget_final_responserOrrrrQrrRemoteProtocolError ReadTimeout ConnectErrorConnectionError!_run_codex_create_stream_fallbackr+rP)rCrr%r_httpx active_clientmax_stream_retrieshas_tool_callsfirst_delta_firedattemptcollected_output_itemsr{event event_type delta_textrM done_itemresp_objr^rfinal_response_out assembledr)err_textmissing_completeds&&&& rE_run_codex_streamAIAgent._run_codex_stream?s#bb$"D"DLa"D"b !',$13'/!34G+- "j ",,33AjAAV!'444!%,UFB%? .*< Nj@j)0)DJ) $ ? ? F Fz R).'88<$5'5)1,:,<!% 7 7 C3Az- :-1N(J67j;P-4UGR-HN- $ : :> J . (+FF(/vt(DI(4 6 = =i H 5(+UU'.uj$'GHJRWXx%FX\FbjCWY]1^pt."NN!\ *F4F ##TD4S4S#T T $ 8 8 : O"(\&,%>%>%@N#>8TBD!$--d1489O4PN1"LL ] #$: ;"<<<^(*0O0O(PI5D%.%0'2)8mR[)\(] 65N1 #LL a #D$C$C Dc)n*OBA5&09)1,0)1!BAAP..0B0BFDWDWYhi `/LLh! *Q.002  o,,. ==j=__ s8$8H$D!$)ELLa! *Q.002  $LLs002 AA*Acc# s$M 2A.L8!L8)L81 L8<L&B L8+L8BL8L8AL8L8%A0L8 M & L5 1L84L5 5L88 M M  M  -R,:;O:<6O:2R,: R,R,AR'!R')5R'R,&R''R,c&<V^8dQhRS[RS[/#)rqrr%)rr)rsrns"rErtr.s#KgKgDKg#KgrHc  T;'gVPRR7p\V4pRVR&VPVRR7pVPP!R/VBp\ VR4'dV#\ VR4'gV#Rp.p.pVEF(p \ V R R4p V 'g(\V \4'dV PR 4p V R 8XdO\ V R R4p V f(\V \4'dV PR 4p V eVPV 4M]V R9dW\ V R R 4p V 'g)\V \4'dV PR R 4p V 'dVPV 4V R9dK\ V RR4pVf(\V \4'dV PR4pVfEK:\ VRR4p \V \4'dV 'gV'd1\V4Vn \PR\V44McV'd\R PV4p\!RRR\!RVR7.R7.Vn \PR\V4\V44Tu\ VRR4p\#V4'd V!4## \ VRR4p\#V4'd V!4MVeV#\'R4h \$d#i;i \$dL/i;i \ TRR4p\#T4'dT!4i \$dii;ii;i)zQFallback path for stream completion edge cases on Codex-style Responses backends.codex_create_stream_fallbackrTr{r3r__iter__Nrrrrrrz1Codex fallback stream: backfilled %d output itemsrrrrPr\r]zrrr)rrrJrcreater*r`rOrrrrrrrQrrrlrr+)rCrr%rfallback_kwargsstream_or_responseterminal_responsercollected_text_deltasrrrrrrclose_fns&&& rEr)AIAgent._run_codex_create_stream_fallbacks.kk$"D"DLj"D"k z*$(!::?Y]:^*44;;NoN %x 0 0% %):66% % ')&(6 +$UFD9 !j&=&=!&6!2J!<< 'vt  D sD:: E&E!!E&c&<V^8dQhRS[RS[/#rr)rsrns"rErtr.$s!!T!T!rHc VPR8wgVPR8wdR#^RIHpV!\ ^<\ \ P!RR444\\ P!RR44VR7pTPR 4pTPR 4p\T\4'dTP4'gR#\T\4'dTP4'gR#TP4TnTP4P#R 4TnTP TP&R &TP$TP&R &TP&P)RR 4TP+RR7'gR#R# \d"p\PR T4R p?R#R p?ii;i)ronousF) resolve_nous_runtime_credentialsHERMES_NOUS_MIN_KEY_TTL_SECONDS1800HERMES_NOUS_TIMEOUT_SECONDS15)min_key_ttl_secondstimeout_seconds force_mintz"Nous credential refresh failed: %sNr;r1rurnous_credential_refreshrT)r=r<rr!rrrr-rkrrrrrOrPrr;rr1r&rr)rCrr!rr)r;r1s&$ rE$_try_refresh_nous_client_credentials,AIAgent._try_refresh_nous_client_credentials$sZ ==. .$--62I  H4$'C :[]c0d,e$f %bii0Mt&T U E))I&99Z('3''w}}(C((0@0@}}  (//4 )-I&*.--J'  14822:S2TT+  LL=s C sAF G )GG c <V^8dQhRS[/#rr)rsrns"rErtr.Gs%%4%rHcVPR8wg\VR4'gR#VPR8wdR#^RIHpHpV!4p\T\4'dTP4'gR#TP4pY0P8XdR#TPP4T!T\TRR44Tn Y0n ^R IHpT!T4TnR # \ d"p\PRT4Rp?R#Rp?ii;i \ dLqi;i \ d"p\P!RT4Rp?R#Rp?ii;i) rqr#Frs)rrz'Anthropic credential refresh failed: %sNr$z?Failed to rebuild Anthropic client after credential refresh: %srT)r=r*r<r"rrrrrrOrPrr#r rr`r rr!)rCrr new_tokenr)rs& rE)_try_refresh_anthropic_client_credentials1AIAgent._try_refresh_anthropic_client_credentialsGs% ==0 0FZ8[8[ ==K '  _/1I )S))1B1BOO% // /   " " ( ( * %;IwtUjlpGq%rD " #,;#29#= 3  LLBC H       NN\^a b sAC)D5D)) D4DD D&%D&) E4EEc$<V^8dQhRS[RR/#)rqr1rrNr)rsrns"rErtr.ns = =3 =4 =rHc:^RIHpT;'gRP4pRV9d\V4VPR&R #RV9d^RIHpV!4VPR&R #RV9dRR /VPR&R #VPPRR 4R #) rK) _OR_HEADERSrrwrrrrrrN)r)r3r7rr&r(rr)rCr1r3rrs&& rE"_apply_client_headers_for_base_url*AIAgent._apply_client_headers_for_base_urlns6nn"++- : %59+5FD   1 2 $ 2 A5L5ND   1 2 z )6BM5RD   1 2    # #$5t |S4Q4Q ++C0Wc )-I&*.--J' // > ++3H+I!  s3E)) E76E7 error_contextc ~<V^8dQhRS[S[,RS[RS[S[S[S[3,,RS[S[S[3,/#)rqrhas_retried_429r@rr)rrrrrPrr)rsrns"rErtr.sO3&3&c]3& 3&  S#X/ 3& tTz  3&rHc VPpVeVfRV3#VR8XdRVPRVR7pVe7\PR\ VRR4 24VP V4R #RV3#VR8XdZV'gR#VPRVR7pVe7\PR \ VRR4 24VP V4R #R#VR 8XdVP 4pVe9\PR \ VRR4 24VP V4RV3#VPR VR7pVe7\PR \ VRR4 24VP V4R #RV3#)a]Attempt credential recovery via pool rotation. Returns (recovered, has_retried_429). On 429: first occurrence retries same credential (sets flag True). second consecutive 429 rotates to next credential (resets flag). On 402: immediately rotates (billing exhaustion won't resolve with retry). On 401: attempts token refresh before rotating. Fi)rr@u3Credential 402 (billing) — rotated to pool entry r?Tu6Credential 429 (rate limit) — rotated to pool entry u(Credential 401 — refreshed pool entry u:Credential 401 (refresh failed) — rotated to pool entry )TF)FT)rmark_exhausted_and_rotaterrr`r>try_refresh_current)rCrrBr@r next_entry refresheds&$$$ rE_recover_with_credential_pool%AIAgent._recover_with_credential_pools$$ <;./) ) # 77CWd7eJ% QRYZdfjloRpQqrs%%j1""/) ) # """77CWd7eJ% TU\]gimorUsTtuv%%j1""  # 002I$ FwyZ^`cGdFefg%%i0_,,77CWd7eJ% XY`akmqsvYwXxyz%%j1""o%%rHc <V^8dQhRS[/#rqrrU)rsrns"rErtr.sDDTDrHcVPR8XdVP4VPPP!R/VB#)rqrd)r=r/r rr )rCrs&&rE_anthropic_messages_create"AIAgent._anthropic_messages_creates; ==0 0  : : <%%..55C CCrHc <V^8dQhRS[/#rNrU)rsrns"rErtr.s;";"$;"rHc faaaaRRRR/oRR/oVVVV3Rlp\P!VRR7pVP4VP4'dVP RR 7SP 'gK<SP R 8XdE^R IHpSPP4V!SP\SR R44Sn M(SPR4pVeSPVR R7\!R4hSR,e SR,hSR,# \dL5i;i)a4 Run the API call in a background thread so the main conversation loop can detect interrupts without waiting for the full HTTP round-trip. Each worker thread gets its own OpenAI client instance. Interrupts only close that worker-local client, so retries and other requests never inherit a closed transport. rNrr%c l<SPR8Xd@SPRR7SR&SPSSR,\SRR4R7SR&MlSPR8XdSP S4SR&MFSPR R7SR&SR,P P P!R /SBSR&SPR4pVeSPVR R7R#R# \dpTSR &Rp?LARp?ii;i SPR4pTeSPTR R7ii;i) rpcodex_stream_requestrr%_codex_on_first_deltaN)r%rrrqchat_completion_requestrrequest_completerd) r=rrr`rPchat completionsr rrr)rrequest_clientrrequest_client_holderresultrCs rE_call.AIAgent._interruptible_api_call.._callsI a==$556:6X6X`v6X6w)(3)-)?)?"4X>'.t5Ld'S*@*F:& ]]&::)-)H)H)TF:&6:6X6X`y6X6z)(3)>x)H)M)M)Y)Y)`)`)ncm)nF:&"7!:!:8!D!-55nM_5`.  $"#w $"7!:!:8!D!-55nM_5`.sIAC+D%C+8D9AC+>D+ D6D;DDD+D3Tr{333333?rrqrr$interrupt_abortrz!Agent interrupted during API call)rrris_aliverrr=r"rr rr#r`rrrInterruptedError)rCrr^rrr[r\r]sff @@rE_interruptible_api_callAIAgent._interruptible_api_calls#dGT2!)4 0 a a*   E$ 7  jjll FF3F (((}}(<<R..4461G 33#D*?F2. *?)B)B8)L)5 ==nUf=g''JKK '? &/ !j!! !s=AD"(D"" D0/D0c$<V^8dQhRS[RR/#rqrrrNr)rsrns"rErtr.sstrHc \VRR4'd/V'd'VP4'dRVnRV,pVPVP3FpVfK V!V4K R# \ dK&i;i)z;Fire all registered stream delta callbacks (display + TTS).rFr9N)r`rrr[rrrCrcbs&& rErAIAgent._fire_stream_deltasr 4. 6 64DJJLL',D $D=D--t/D/DEB~tHF!s$A22 BBc$<V^8dQhRS[RR/#rir)rsrns"rErtr.!s#$rHc nRVnVPpVe V!V4R#R# \dR#i;i)z&Fire reasoning callback if registered.TN)rrXrrks&& rErAIAgent._fire_reasoning_delta!s?'+$  $ $ > 4   s % 44c$<V^8dQhRS[RR/#rr)rsrns"rErtr.+s    rHc `VPpVe V!V4R#R# \dR#i;i)aZNotify display layer that the model is generating tool call arguments. Fires once per tool name when the streaming response begins producing tool_call / tool_use tokens. Gives the TUI a chance to show a spinner or status line so the user isn't staring at a frozen screen while a large tool payload (e.g. a 45 KB write_file) is being generated. N)r\r)rCrrls&& rE_fire_tool_gen_startedAIAgent._fire_tool_gen_started+s9 # # > 9    s  --c <V^8dQhRS[/#rr)rsrns"rErtr.:s  t rHc LVPRJ;'g\VRR4RJ#)z4Return True if any streaming consumer is registered.Nr)r[r`rWs&rErAIAgent._has_stream_consumers:s5  & &d 2 C Ct/6dB rHrc&<V^8dQhRS[RS[/#)rqrr)rrl)rsrns"rErtr.As!F"F"F"3;F"rHc  jaaaaaaaaaaaSPR8Xd!SSnSPS4RSn#RRRR/oRR/oRR/oRR/oR \P!4/oVV3R loVVVVVV3R loVVVV3R loVVVVVVVV3R lp\ \ P !RR44p\RSPR.444^,pVR8d\VR4pMVR8d\VR4pMTp\P!VRR7pVP4VP4'EdVPRR7\P!4SR ,, pW8d\RSPR.444^,p \P!RWSPRR4V R 4SP#R\%V4 R SPRR4 R!V R R"24SPR4p V eSP'V R#R$7SP+R%R$7\P!4SR &SP,'gEKCSPR&8XdE^R'IHp SP2P54V !SP6\9SR(R44SnM(SPR4p V eSP'V R)R$7\;R*4hSR,elSR,'dT\P!R+SR,4\=R,RRRR-7p \=R.\9SRR4\=^V R/R07.RR17#SR,hSR,# RSni;i \(dELbi;i \(dELai;i \(dLi;i)2uStreaming variant of _interruptible_api_call for real-time token delivery. Handles all three api_modes: - chat_completions: stream=True on OpenAI-compatible endpoints - anthropic_messages: client.messages.stream() via Anthropic SDK - codex_responses: delegates to _run_codex_stream (already streaming) Fires stream_delta_callback and _stream_callback for each text token. Tool-call turns suppress the callback — only text-only final responses stream to the consumer. Returns a SimpleNamespace that mimics the non-streaming response shape so the rest of the agent loop is unchanged. Falls back to _interruptible_api_call on provider errors indicating streaming is not supported. rpNrrr%doneFrrc|<SR,'gS'dRSR&S!4R#R#R# \dR#i;i)rzTN)r)rrsrE_fire_first_deltaDAIAgent._interruptible_streaming_api_call.._fire_first_deltagsC$V,,,0!&)"$2@,!s , ;;c <^RIp\\P!RR44p\\P!RR44p/S"CRRRR R/R VP R VVR R 7/CpS&P R R7S%R&\ P !4S$R&S&PR4S%R,PPP!R+/VBp.p/p\4p/p/p Rp Rp Rp .p RpRS&n RpVEFp\ P !4S$R&V'gRpS&PR4S&P'dEMVP'gc\VR4'dVP 'd VP p \VR4'dVP"'d VP"pKVP^,P$p\VR4'dVP 'd VP p \'VRR4;'g\'VRR4pV'd*V P)V4S!!4S&P+V4V'dVP,'dzVP)VP,4V'g)S!!4S&P/VP,4RS#R&M.S&P0'dS&P1VP,4V'EdtVP4'EdaVP4EFOpVP6e VP6M^pVP8;'gRpVV 9dVV V&V'd/VV9d(VVV,8wd\;VR,R7^,pVV V&V'dVVV&V V,pVV9d&RVP8;'gRRRRRRR R/R!R/VV&VV,pVP8'dVP8VR&VP<'dVP<P>'d1VR,R;;,VP<P>, uu&VP<P@'d1VR,R ;;,VP<P@, uu&\'VR!R4pVf8\VR"4'd&VPB;'g/PER!4pVe(\VR#4'dVPG4pVVR!&VR,R,pV'gEKVV9gEK&VPIV4S!!4S&PKV4EKR VP^,PL'dVP^,PLp \VR4'gEKVP"'gEKVP"pEK RPOV4;'gRpRpV'd.p\QV4FnpVV,pVP)\SVR,VR,VPER!4\SVR,R,VR,R ,R$7R%74Kp RPOV 4;'gRp\SV VVVR&7p\S^TT ;'gR'R(7p \SR)\U\VPX!44,V V .VR*7# \2dELi;i)-z#Stream a chat completions response.NHERMES_API_TIMEOUT @HERMES_STREAM_READ_TIMEOUTgN@r{Tstream_options include_usager>@)connectrrLrchat_completion_stream_requestrr%rz)waiting for provider response (streaming)rFzreceiving stream responserBr r5r4rr)r!rrrrar extra_content model_extra model_dumprb)rrrrrrrr5rdrrrEzstream-rrBchoicesr rdr)-rrkrr-TimeoutrrrRrYrZr r3rrrr*rBr rr`rrrrr[rrrrrrrarrrrr`rsrErr5rrPr8r9)'r _base_timeout_stream_read_timeout stream_kwargsr{rotool_calls_acctool_gen_notified_last_id_at_idx_active_slot_by_idxrE model_namerr= usage_obj_first_chunk_seenchunkrrMtc_deltaraw_idxdelta_idnew_slotrrAextrara full_contentmock_tool_callsrfull_reasoning mock_message mock_choicer|rdeltas_were_sentlast_chunk_timer\rCs' rE_call_chat_completionsIAIAgent._interruptible_streaming_api_call.._call_chat_completionsos "!")),@&"IJM#(3OQU)V#W   $ ?D"96>> -' * M/3.P.P7/Q/ !( + $(99;OC  !L M*8499EELL]}]F"$M#%N%(U  %'O(*  MJD$&OI,1D ( % '+yy{$((,%(()DE,,,}}}ug..5;;;%*[[ ug..5;;;$)KK  a(..5'**u{{{!&J")0CT!J!o!ogV[]hjnNo!#**>:%'..~>U]]]!((7))+// >26(/ 555% $ : :5== I 5U---$)$4$442'F'JH;C/8#7?OG41':n4 $hkk&7&7R & *VRb,I / 3N3/ !/s 3#;;;*2++E$K#,,,'00555 %j 1& 9X=N=N=S=S S 9'00::: %j 1+ >(BSBSB]B] ] > '/4 H =WX}-M-M%-%9%9%?%?R$D$D_$UE ,&ul;;(-(8(8(:5:E/2$Z084C/@$@-11#6-/ 77=]%5`==#111$)MM!$4$B$BM5'**u{{{ % IY ^77=199TL"O"$!.1C',B#**?d8Z&(ff_&=!0!#J!7&(n[&A" ,2 WW_5==N*$*"0 L *$+55vK #s4::<00 $   s$-% $%s[<< \  \ cv<RpRS n\P!4S R&S PPP!R/S B;_uu_4pVEF4pS P 'dEM \ VRR4pVR8Xd_\ VRR4pV'dH\ VRR4R8Xd4Rp\ VR R4pV'dS !4S PV4KKKKVR 8XgK\ VR R4pV'gK\ VRR4pVR 8Xd<\ VR R4pV'd%V'gS !4S PV4KKKVR8XgEK\ VRR4p V 'gEKS !4S PV 4EK7 VP4uuRRR4# +'giR#;i)zStream an Anthropic Messages API response. Fires delta callbacks for real-time token delivery, but returns the native Anthropic Message object from get_final_message() so the rest of the agent loop (validation, tool extraction, etc.) works unchanged. FrrNcontent_block_start content_blocktool_useTracontent_block_deltar text_deltarrthinking_deltar8rd) rrr rr{rr`rsrrget_final_message) has_tool_user{rrrArr delta_typer thinking_textr|rrrCs rE_call_anthropicBAIAgent._interruptible_streaming_api_call.._call_anthropic-s!L+0D ($(99;OC ''0077E*EE#E000!(!=J!%:: ' E WUFD%AZ%O+/L(/vt(DI( 1 3 $ ; ;I F )&P5$'<< 'w = 5)0)EJ)\9'.ufb'A#' $5$7$($;$;D$A1=4",/?!?07z20N #0=$5$7$($>$>}$M9$>//1AFEEEs+BF'(F'?0F'0"F'F'0,F'' F8 c <a^RIp\\P!R^44p\ V^,4FepSP R8XdSP 4S!4SR&M S!4SR&SPR4pVeSPVRR7R#R# SPR4pVeSPVRR7R#R# \EdCpSR,'dM\PR T4TSR &Rp?SPR4pTeSPTRR7R#R#\Y@PTPTP34p\Y@P TP"\$34pR pT'gT'g^R IHp\YH4'di\+TR R4'gV\-T4P/4oRp \0;QJdT3RlT 4F 'gK RM R M!T3RlT 44pT'gT'g T'EdY!8d\P3RT^,T^,\5T4P6T4SP9R\5T4P6 RT^, RT^, R24SPR4p T eSPT RR7RSR&SP;RR7M \dMi;iRp?EKSP9RT^, R24\PRT^,T4MZ\-T4P/4p RT 9;'dRT 9p T 'dSP=R4\P3RT4\>P>!4SR&SPAS4SR&M \dp T SR &Rp ? MRp ? ii;iRp?SPR4pTeSPTRR7R#R#Rp?ii;i SPR4pTeSPTRR7ii;i) rKNHERMES_STREAM_RETRIESrqrr%stream_request_completerrz9Streaming failed after partial delivery, not retrying: %srF)APIErrorrc3.<"TF pVS9xK R#5irUrd)rphrase_err_lower_sses& rErKAIAgent._interruptible_streaming_api_call.._call..s7"2C%+n$<2CsTzJStreaming attempt %s/%s failed (%s: %s), retrying with fresh connection...u'⚠️ Connection to provider dropped (u). Reconnecting… (attempt rurstream_retry_cleanupstream_retry_pool_cleanupu(❌ Connection to provider failed after uM attempts. The provider may be experiencing issues — try again in a moment.zTStreaming exhausted %s retries on transient error, falling back to non-streaming: %sr{z not supportedu ⚠ Streaming is not supported for this model/provider. Falling back to non-streaming. To avoid this delay, set display.streaming: false in config.yaml zCStreaming failed before delivery, falling back to non-streaming: %sr) connection lostconnection resetconnection closedzconnection terminated network errornetwork connection terminatedz peer closedz broken pipezupstream connect error)!rrrr-rr=r/rrrrr rOrConnectTimeout PoolTimeoutrrropenairr`rPr7rrrrerrrrrf)r_max_stream_retries_stream_attemptr[r _is_timeout _is_conn_err_is_sse_conn_err _APIError_SSE_CONN_PHRASESstale _err_lower_is_stream_unsupported fallback_errrrrrrrr\r]rCs @rEr^8AIAgent._interruptible_streaming_api_call.._call]s` ""%bii0G&K"L D h',-@1-D'EO~==,@@ JJL1@1BF:.1G1IF:.t"7!:!:8!D!-55nMf5g.E(FB"7!:!:8!D!-55nMf5g.u%w+E22#NN []^/0F7O"`"7!:!:8!D!-55nMf5g._'1 2 2F4I4I6K]K]^' (2 3 3V5O5OQ`a( ,1(*<D)!77=Z^@_@_14Q 5" 14737"2C7"3337"2C7"4" 0 ',:J:J /D & %H$3a$7$7!$;$(G$4$4$% !"!% 1 1'((,Q(8(8'9:00?!0C/DAFY\]F]E^^_%a!" )>(A(A((K#(#4$($E$E(-6L%F%&GK$9($C!)$($G$G/J%H%&(1!)$(!) ( -- J#6#:";<9!9 #NN!D 3a 7 ! *-QJ (J 6!B!B$3z$A3 6 $ 0 0%7!" #KK e ! ;4899;OC0151M1Mj1YF:.(;.:F7O;!6!:!:8!D!-55nMf5g.uwr"7!:!:8!D!-55nMf5g.sP 6C4P !P  P*PP 6A#PA$PP!P)P2B)PK/.P/ K=:P<K==PP AP' P5'P,O  P O$OPO$$P'P PP +Q HERMES_STREAM_STALE_TIMEOUTgf@c3J"TFp\\V44xK R#5irUrQrPrr)s& rEr.sN/M!#c!f++/M!#rrgr@Pgn@Tr{r`rac3J"TFp\\V44xK R#5irUrrs& rErrsS4Rqs3q6{{4RruqStream stale for %.0fs (threshold %.0fs) — no chunks received. model=%s context=~%s tokens. Killing connection.rBrru%⚠️ No response from provider for z s (model: z , context: ~z tokens). Reconnecting...stale_stream_killrstale_stream_pool_cleanuprqrbr$stream_interrupt_abortz+Agent interrupted during streaming API callz`Partial stream delivered before error; returning stub response to prevent duplicate messages: %srrzpartial-stream-stubrdrr)r=rVrfrrkrr-rrrrrrrdrrr rrrrrrr"rr rr#r`rer)rCrrr^_stream_stale_timeout_base _est_tokens_stream_stale_timeoutr_stale_elapsed_est_ctxrcrr[ _stub_msgrrr|rrrr\r]sffd @@@@@@@@rE!_interruptible_streaming_api_call)AIAgent._interruptible_streaming_api_callAs$ ==- - *8D & 233J?-1*dGT2!)4 0#UO!5> , | | |. 2. 2`I hI hV&+2995RTY+Z%[" Nz~~j"/MNNRSS  $'(BE$J ! 6 !$'(BE$J !$> !   E$ 7  jjll FF3F  "YY[?3+??N5SJNN:r4RSSWXXG"NN7I68A,  !!;CR VP 49d)V'g!\P!R 4;'gRpV!W#R VVR 7wrxVf(\P!R V4VP 4#Rp \VP4p VR8XdRp MWVR8Xg5V PR4P 4P!R4'dRp MVP#V 4'dRp VP$p \'V\4'dTM \V4VnW nWnWnR VnV R8Xd^RIHp Hp HpVR8Xd&VP6;'gV !4;'gRMVP6;'gRpWnWn\;VRR4VnV !WP<4VnV!V4Vn RVn!/Vn"M,VP6VnWpn!RVP6RV /Vn"V R8HpRV P 49;'dRVP 49;'gTVn#\IVR4'dVPJ'd^RI&H'pV!VP$VPVP6VP(R7pVP$VPJnVPVPJnVP6VPJnVP(VPJnVVPJn(\SVVPJPT,4VPJn+VPYRV RV 24\PZ!RWV4R # \\d3p\P^!RTT4TP 4uRp?#Rp?ii;i)uSwitch to the next fallback model/provider in the chain. Called when the current model is failing after retries. Swaps the OpenAI client, model slug, and provider in-place so the retry loop can continue with the new backend. Advances through the chain on each call; returns False when exhausted. Uses the centralized provider router (resolve_provider_client) for auth resolution and client construction — no duplicated provider→key mappings. Fr<rrBrr1Nr;z ollama.comOLLAMA_API_KEYT)rBrexplicit_base_urlexplicit_api_keyz.Fallback to %s failed: provider not configuredrorrrprsrurvrqrrwr~rcrru5🔄 Primary model failed — switching to fallback: z via u"Fallback activated: %s → %s (%s)z"Failed to activate fallback %s: %s)0r0rQr/rrr7_try_activate_fallbackr)rrr-rr rPr1rrrrBrOr<r=r1r"rrrr;r#r`r$r r!r%r&r r*rcrrrrrrsrrrr)rCr fb_providerfb_modelrfb_base_url_hintfb_api_key_hint fb_clientr fb_api_mode fb_base_urlrrrrr~r{rfb_context_lengthrs& rErAIAgent._try_activate_fallbackKse   3t';';#< <  ! !$"6"6 7 !vvj)//R668>>@ FF7O))r002(..0 0 _ 1 F!#z 2 8 8b??AIIT !vvi066B==?GG4O L4D4J4J4L$LUd"$)),<"="E"E2t"2!02LI D!2244-Ki001Kn,/  +{/A/A#/F/L/L/N/W/WXd/e/e2 ++K88/  I%/#%>%>CMDJ'M'M'M'+D $22ttZeitZt!2!2!U!U6M6O!U!USU|E|M|M|S|SQS , *7'+29j$+O()? OgOg)h&+:=+I(" &(# )00 ' y00 '# #.1E"E !2!2!44UUX^^EU9U''&  $t122t7N7N7NI$<JJ LL4==%!15 ''-37==''026,,''/37==''09J''6;>%(?(?(Q(QQ<''8   G*E+0  LL4[  1 MM>! L..0 0 1sS <S S /S  S S /S ;S AS $S >A9S 8S S BS <S +S DS T+'TTTc <V^8dQhRS[/#rr)rsrns"rErtr.s>>$>rHc VP'gR#VPpVR,VnVR,VnVR,VnVR,VnVR,Vn\VR,4VnVR,Vn VP R 8XdU^R I H pVR ,Vn VR ,Vn V!VR ,VR ,4VnVR ,VnRVnM)VP#\VR,4RRR7VnVP$pVR,VnVR,VnVR,VnVR,VnVR,VnVR,VnRVn^Vn\,P.!RVPVP4R# \0d#p\,P2!RT4Rp?R#Rp?ii;i)aRestore the primary runtime at the start of a new turn. In long-lived CLI sessions a single AIAgent instance spans multiple turns. Without restoration, one transient failure pins the session to the fallback provider for every subsequent turn. Calling this at the top of ``run_conversation()`` makes fallback turn-scoped. The gateway creates a fresh agent per message so this is a no-op there (``_fallback_activated`` is always False at turn start). FrBr<r1r=r;rrrqrbrrrNrestore_primaryTrrrrrrrz.Primary runtime restored for new turn: %s (%s)z%Failed to restore primary runtime: %s)r1rtrBr<r1r=r;rr&r r"rr#r$r r!r%r.rcrrsr0rrrr )rCrtrccrs& rE_restore_primary_runtime AIAgent._restore_primary_runtimes'''  " "/ GDJzNDMzNDMzNDMi=DL"&r/':";D ')*>'?D $}} 44J*,-@*A'+-.B+C()?*+R0D-E*&,..B+C(" "88O,-,9 ((B,-BH23BK01BJ23BK "#> ?B "$%B"CB (-D $#$D LL@ DMM   OOCQ G sFF77 G$GG$c2<V^8dQhRS[RS[RS[RS[/#)rq api_error retry_count max_retriesrr)rrr)rsrns"rErtr.s3KK"K47KFIK KrHc  VP'dR#\V4PpW@P9dR#VP 4'dR#VP ;'gRP 4P4pVR9dR#\VRR4e VPVPRRR7VPp\VR,4VnVR ,VnVR ,VnVR ,VnVR ,VnVR ,VnVP"R8XdU^RIHpVR,VnVR,VnV!VR,VR,4VnVR,VnRVn M)VP3\VR,4RRR7Vn \5^V,^4pVP7VP8 RV RVP RV R2RR7\:P<!V4R# \dELci;i \d#p \>P@!RT 4Rp ? R#Rp ? ii;i)uFAttempt one extra primary-provider recovery cycle for transient transport failures. After ``max_retries`` exhaust, rebuild the primary client (clearing stale connection pools) and give it one more attempt before falling back. This is most useful for direct endpoints (custom, Z.AI, Anthropic, OpenAI, local models) where a TCP-level hiccup does not mean the provider is down. Skipped for proxy/aggregator providers (OpenRouter, Nous) which already manage connection pools and retries server-side — if our retries through them are exhausted, one more rebuilt client won't help. Frr%Nprimary_recoveryTrrrBr<r1r=r;rqrbrrru🔁 Transient z on u — rebuilt client, waiting z"s before one last primary attempt.rz%Primary transport recovery failed: %s)r z nous-research)!r1rre_TRANSIENT_TRANSPORT_ERRORSrr<rr7r`rwr%rrtrr&rBr1r=r;r"rr#r$r r!r.rrrLrsleeprr ) rCrrr error_typeprovider_lowerrr wait_timers &&$$ rE_try_recover_primary_transport&AIAgent._try_recover_primary_transports-  # # #)_-- == =  " " $ $----2446<<> 6 6- tXt,8-- ,>t.&&B"&r/':";D GDJzNDMzNDMzNDMi=DL}} 44J*,-@*A'+-.B+C()?*+R0D-E*&,..B+C(" "88O,--9 A OQ/I LL??#?:,d4==/R++4+5WY   JJy !G!H  OOCQ G s=H% H>EH% H"H%!H""H%% I0I  Ic&<V^8dQhRS[RS[/#rr)rsrns"rErtr.^s#$rHc\V\4'gR#VF4p\V\4'gKVPR4R9gK3R# R#)FrT>rr)rOrrr)rrs& rE_content_has_image_parts AIAgent._content_has_image_parts]sB'4((D$%%$((6*:>Z*ZrHcL<V^8dQhRS[RS[S[S[S[,3,/#)rqrrr)rPrrr )rsrns"rErtr.gs*CE#xPT~BUDDFI##H--    ' &   #dF  ))1CF[`a S IIf&&t, -CHH~4y$Ss &D D, c,<V^8dQhRS[RS[RS[/#)rqrrrrr)rsrns"rErtr.{s#11131SV1rHc\P!\T;'gR4PR44P 4pVP P V4pV'dV#RRRR/P VR4pRp\T;'gR4pRpVPR4'dVPV4wrxRp ^R I H p \P!V !WvR 74p \V \4'd\P!V 4M/p V P R 4;'gRP!4p V'd(VP%4'dVP'4T 'gR p RT RT R2pT'd8\T;'gR4PR4'gTRT R2, pYP T&T# \"dp R T 2p Rp ? LRp ? ii;i \(dLi;i T'd;TP%4'd$TP'4i \(dii;iii;i)rrrrz tool resultrmzDescribe everything visible in this image in thorough detail. Include any text, code, UI, data, objects, people, layout, colors, and any other notable visual information.Nr)vision_analyze_tool)r user_promptrizImage analysis failed: zImage analysis failed.z[The z- attached an image. Here's what it contains: rz@ [If you need a closer look, use vision_analyze with image_url: )rrrPrrrrrrtools.vision_toolsr#asynciorrOrrrrr>unlinkrM)rCrr cache_keycached role_labelanalysis_prompt vision_source cleanup_pathrr# result_jsonr]rnotes&&& rE&_describe_image_for_anthropic_fallback.AIAgent._describe_image_for_anthropic_fallback{sNN3yB#7#>#>w#GHRRT 5599)D M  M  #dF    8  IOO, '+  # #G , ,*.*O*OP]*^ 'M   >!++#mYK1;;0L0LTZZ ,RTF!::j177R>>@K 3 3 5 5 '')2Kzl"PQ\P]]^_ Y__"!5!@!@!I!I STaSbbcd D;?,,Y7 ' 83A37K 8  3 3 5 5 '')!6|sgA(G1G!G0 G-G(#H(G--H0 G>=G>I!H21I2 I=I?IIc,<V^8dQhRS[RS[RS[/#)rqrrrrrN)rsrns"rErtr.s'*[*[S*[*[*[rHcVPV4'gV#.p.pVEFp\V\4'd8VP4'd VP VP44KQ\V\ 4'gKiVP R4pVR 9dO\VP RR4;'gR4P4pV'dVP V4KVR 9dVP R/4p\V\ 4'dVP RR4M\T;'gR4p V 'd"VP VPW44MVP R4EKb\VP RR4;'gR4P4pV'gEKVP V4EK RPRV44P4p RPR V44P4p V 'dV 'dV RV 2#V 'dV #V 'dV #R #) rrrrrz:[An image was attached but no image source was available.]r9c38"TFq'gK VxK R#5irUrd)rr/s& rEr8AIAgent._preprocess_anthropic_content..sBkdTTTk  rc38"TFq'gK VxK R#5irUrd)rrs& rErr5s?JD$44Jr6zI[A multimodal message was converted to text for Anthropic compatibility.]>rr>rr) r rOrPrrrrr0r) rCrr text_parts image_notesrrSr image_datarrrs &&& rE_preprocess_anthropic_content%AIAgent._preprocess_anthropic_contents,,W55N " !# D$$$::<<%%djjl3dD))HHV$E..488FB/5526<<>%%d+44!XXk26 9CJPT9U9UJNN5"5[^_i_o_omo[p &&t'R'RS\'cd&&'cdtxx+11r288:Dt!!$'58BkBBHHJ?J??EEG fXT&* * M MZrHc&<V^8dQhRS[RS[/#rqrGrrr)rsrns"rErtr.srHc a\;QJdV3RlV4F 'gK RM RM!V3RlV44'gV#\P!V4pVFbp\V\4'gKSP VP R4\VP RR4;'gR44VR&Kd V#)c3<"TF=p\V\4;'d!SPVPR44xK? R#5i)rN)rOrr r)rrrCs& rEr>AIAgent._prepare_anthropic_messages_for_api..s> # sD ! W Wd&C&CCGGIDV&W W#s A)ATFrrrm)rrr%rOrr;rrP)rCrG transformedrsf& rE#_prepare_anthropic_messages_for_api+AIAgent._prepare_anthropic_messages_for_apiss # sss #    mmL1 Cc4((!?? "CGGFF+55v6C NrHc <V^8dQhRS[/#rr)rsrns"rErtr.sYY$YrHc \VRR4;'gRP4R9dR#\VRR4;'gRP4pRV9;'gRV9;'gRV9#) zTrue when using an anthropic-compatible endpoint that preserves dots in model names. Alibaba/DashScope keeps dots (e.g. qwen3.5-plus). OpenCode Go keeps dots (e.g. minimax-m2.7).r<rTr1 dashscopealiyuncszopencode.ai/zen/go>r opencode-go)r`r7)rCbases& rE_anthropic_preserve_dots AIAgent._anthropic_preserve_dotssp D*b ) / /R 6 6 8)rr)rsrns"rErtr.sTTdTtTrHc TaVPR8Xd^RIHpVPV4p\ VRR4pV'd VP MRpV!VP VVPVPVPVPVP4VR7#VPR8XEdRpTpV'd`V^,PR4R 8XdC\V^,PR 4;'gR4P4pVR ,pV'g\pR VP P#49;'gR VP P#49pRpRp VP'dw\%VP\&4'dWVPPR4RJdRp M4VPPR4'dVPR,pRVP RVRVP)V4RVP+4RRRRRR/p V'gVP,V R&V 'd2V'dVP/4p V eWR&MRVRR/V R&R.V R&M V'g.V R&VPeVPV R &V #Tp Rp VFp\%V\&4'gKR!V9dRp MjVPR"4p\%V\04'gKOVF-p\%V\&4'gKR#V9g R$V9gK+Rp M V 'gKM V 'd\2P4!V4p V Fp\%V\&4'gKVP7R!R4VPR"4p\%V\04'gKVVF?p\%V\&4'gKVP7R#R4VP7R$R4KA K VP ;'gRP#4oV 'dV ^,PR4R 8Xdf\8;QJd#V3R%l\:4F 'gK RM RM!V3R%l\:44'd\1V 4p /V ^,CRR&/CV ^&/pVP<'dVP<VR'&VP>'dVP>VR(&VP@'dVP@VR)&VPB'dVPBVR*&VPD'dRVR+&VPF'dVPFVR,&RVP R-V R.\I\JPL!R/R044/pVP'dVPVR&VPe,VPOVPQVP44M]VPS4'dHR1VP ;'gRP#49d^R2IH*pV!VP 4pVVR3&/pVPS4pR VPX9;'gR VPX9pV'dV'dVVR4&R5VPX9pVP[4'dsV'dVP/4p V eV VR&MPVPe:\'VP4pV'dVPR4RJdMVVR&M RRRR/VR&V'dR6.VR7&V'dVVR8&R9VPX9d6\]VR:4'd$VP,'dR;VP,/VR<&V# \VdELUi;i)=z9Build the keyword arguments dict for the active API mode.rqbuild_anthropic_kwargsrcN)rBrrr^r_is_oauth preserve_dotsrrprrrr:NNmodels.github.airmediumTrFeffortrBr6r7rr@rrBr9rAr4r7zreasoning.encrypted_contentr:r;rrrrc3,<"TF qS9xK R#5irUrd)rr|rs& rEr,AIAgent._build_api_kwargs..jsE/D!%/Dr developeronlyignoreordersortrequire_parametersdata_collectionrrrrr~)_get_anthropic_max_outputr^r< nousresearchproduct=hermes-agenttags extra_bodyzx.airSzx-grok-conv-id extra_headers)/r=r"rPrCr`rrBrr^r_r!rKrrPrrr1r7rOrr%rrS#_github_models_reasoning_extra_bodyrrr%rrr.rMrNrOrPrQrRrkrr-rurrr`rr8_supports_reasoning_extra_bodyr*)rCrGrPrqrWr6payload_messagesis_github_responsesreasoning_effortreasoning_enabledrgithub_reasoningsanitized_messagesneeds_sanitizationrrrprovider_preferencesrr`_model_output_limitrd_is_openrouter_is_github_models_is_nousrrs&& @rE_build_api_kwargsAIAgent._build_api_kwargss ==0 0 F!%!I!I,!W d$8$?G07g,,TG)jj+jj??!%!6!611";;=&   ==- -L+  Q 3 3F ;x G"<?#6#6y#A#G#GRHNNP #/#3 5 #dmm&9&9&;;DD*dmm.A.A.CC (  $ $$$D4I4I4)P)P((,,Y75@(-%**..x88'+'<'{++35EyRX*YF;')F(GF9%($&y!*.2oo*+M)"Cc4((&#-%)".J*d++!+I%i66  I-1Cy1P-1* ", &%! $ !%|!< )!#t,,/6 WW\2 j$//%/ %i66%MM)T:%MM* <( 002 $"6"6 6 ? ?&$*>*>>  N%9Jz "!T%9%99  . . 0 0 #'#K#K#M #/.>J{+((4d334B BFF9$5$>24 ;/"4 (/J{+ "8!9Jv  '1J| $ T)) )gdL.I.Idooo+;T__*MJ 'i  s4^ ^'&^'c <V^8dQhRS[/#rr)rsrns"rErtr.s T T TrHc aRVP9dR#RVP9dR#RVP9gRVP9d#^RIHp\V!VP44#RVP9dR#R VP9dR#VP;'gR P 4oR p\;QJdV3R lV4F 'gK R# R#!V3R lV44# \ dR#i;i) aReturn True when reasoning extra_body is safe to send for this route/model. OpenRouter forwards unknown extra_body fields to upstream providers. Some providers/routes reject `reasoning` with 400s, so gate it to known reasoning-capable model families and direct Nous Portal. raTzai-gateway.vercel.shrTrgithub_model_reasoning_effortsFrwzapi.mistral.airc3F<"TFpSPV4xK R#5irU)r)rrrBs& rEr9AIAgent._supports_reasoning_extra_body..s!S:R5##F++:Rs!)z deepseek/z anthropic/zopenai/zx-ai/zgoogle/gemini-2z qwen/qwen3)r8r(ryrrBrr7r)rCryreasoning_model_prefixesrBs& @rErg&AIAgent._supports_reasoning_extra_bodys T11 1 !T%9%9 9 !5!5 59PTXThTh9h L:4::FGG t33 3 t33 3!!r((*$  sS:RSssSsSsS:RSSS!  s C22 DDc.<V^8dQhRS[R,/#rprU)rsrns"rErtr.s,,TD[,rHc *^RIHpT!TP4pT'gR#TP'd\ TP\ 4'ddTPPR4RJdR#\TPPRR44P4P4pMRpTR8XdRT9dRpRT/#Y29d+TR 8XdR T9dR pRT/#RT9dRpRT/#T^,pRT/# \dR#i;i) zDFormat reasoning payload for GitHub Models/OpenAI-compatible routes.rxNrFrVrUxhighhighminimallow) r(ryrrBr_rOrrrPrr7)rCrysupported_effortsrequested_efforts& rErf+AIAgent._github_models_reasoning_extra_bodys/  H;4::F   Z0E0Et%L%L$$((3u<"%%))(H= egeeg  (  w &65F+F% *++ 69,:K1K#( *++ ..#+ *++$5Q#7 *++5  sD DDc&<V^8dQhRS[RS[/#)rqrErr)rPr)rsrns"rErtr. s tttQUtrHc VPV4p\V4pV'gjVP;'gRp\P!RV\P R7pV'd%RP RV44pT;'gRpV'd8VP'd&\P!R\V4 RV 24V'd7VP'd%VP'gVPV4R R R VP;'gRR VR V/p\VR4'dVP'dVPp .p V Fp \!V \"4'dV P%V 4K,\V R4'dV P%V P&4K[\V R4'gKoV P%V P)44K V 'dWR&\+VRR4p V 'dWR&VP,'EdL.p VP,EF4p\+VRR4p\+VRR4p\!V\.4'dVP14'gVP3V4wppTp\!V\.4'dVP14'g\!V\.4'd(VP14'dVP14pMW\+VRR4pV'd\+VRR4MRpV'd\+VRR4MRpVP5VV\V 44pVP14p\+VRR4p\!V\.4'dVP14'gVP3V4wppTpTP7T\!V\.4'dTMR4pRVRVRVRVP8RRVP:P<RVP:P>//p\+VRR4pVe(\VR4'dVP)4pVVR&V P%V4EK7 WR&V# \dELwi;i)zBuild a normalized assistant message dict from an API response message. Handles reasoning extraction, reasoning_details, and optional tool_calls so both the tool-call path and the final-response path share one builder. rr:rr9c3p"TF,qP4'gKVP4xK. R#5irU)r)rbs& rEr3AIAgent._build_assistant_message..s &T,Q'')yqwwyy,s66NzCaptured reasoning ( chars): rrrr4rEr6__dict__rrrrrrarrgrrrr) rBrrrr;rrrHrrrQrXr[rr*r6rOrrrrr`rrPrrrrrrrar)rCr<rErM_from_structuredr think_blockscombinedr raw_details preservedd codex_itemsrrrrr!r_fn_fn_name_fn_argsrr"tc_dictrs&&& rE_build_assistant_message AIAgent._build_assistant_message s 001BC/ '//552G::&=wbiiXL!;;&T,&TT!)!1!1T d222 MM0^1D0EY~N^_ ` d555---++N; K (0066B  ]   $&9 : :?P?b?b?b ,==KI a&&$$Q'Q ++$$QZZ0Q --$$Q\\^4 !+4'(/1H$O +6' (  ' ' 'J.99  D$7!)Y=!'3//w}}*.*G*G*O'$a.G!'3//w}}!&#..6<<>>"(,,.%iTB?B73#;FI73 T#Bt"&"="=hRUV`Ra"b!--/#*96H$#O !"2C88@P@V@V@X@X373P3PQW3X0A0'@$#'#J#J(23CS(I(I$t$ 'w&(8INN 2 2 7 7#Y%7%7%A%A!  ?DA$ul33 % 0 0 2/4GO,!!'*Y:Z!+  e!s:Q44 RRc&<V^8dQhRS[RS[/#)rqapi_msgrrrU)rsrns"rErtr.sTdrHc  0VPR4p\V\4'gV#RR0pVUUUu.uFGp\V\4'd-VP 4UUu/uFwrEWB9gK WEbK uppMTNKI upppVR&V#uuppiuupppi)uStrip Codex Responses API fields from tool_calls for strict providers. Providers like Mistral, Fireworks, and other strict OpenAI-compatible APIs validate the Chat Completions schema and reject unknown fields (call_id, response_item_id) with 400 or 422 errors. These fields are preserved in the internal message history — this method only modifies the outgoing API copy. Creates new tool_call dicts rather than mutating in-place, so the original messages list retains call_id/response_item_id for Codex Responses API compatibility (e.g. if the session falls back to a Codex provider later). Fields stripped: call_id, response_item_id rrr)rrOrrr6)rr _STRIP_KEYSrr(r)s& rE#_sanitize_tool_calls_for_strict_api+AIAgent._sanitize_tool_calls_for_strict_apis"[[. *d++N "45 !! !"d##!hhj AjdaA,@TQTj A)+ , !    B! s.B" B 1B 7 B Bc <V^8dQhRS[/#rr)rsrns"rErtr.s 2 2T 2rHc VPR8g#)auDetermine if tool_calls need sanitization for strict APIs. Codex Responses API uses fields like call_id and response_item_id that are not part of the standard Chat Completions schema. These fields must be stripped when calling any other API to avoid validation errors (400 Bad Request). Returns: bool: True if sanitization is needed (non-Codex API), False otherwise. rp)r=rWs&rE_should_sanitize_tool_calls#AIAgent._should_sanitize_tool_callss}} 111rHc&<V^8dQhRS[RS[/#)rqr min_turns)rr)rsrns"rErtr.s[[t[s[rHc  PVP^8XdVfR#RVP9gVP'gR#VeTM VPpVPV8dR#Vf\ VRR4pV'd\ V4^8dR#RpR\ V4 R\P!4 2pRRR VR V/pVPV4VP4p.pVFp V P4p V PR4R 8XdV PR 4p V 'dWR &V PR R4V PRR4V PR R4V'dVPV 4VPV 4K VP'dRRR VP/.V,pRp VP ;'g.F-p V PR/4PR4R8XgK+T p M V 'gVP4V'd9VR0,PR 4V8wdVP4V'dK?V'd2VR0,PR 4V8XdVP4R#R#R#^RIHpRpV!RVV .RRRR7pV'g[VP(R8XdJVP+V4pVP-V .4VR&RVR&RV9dRVR&VP/V4pMV'gQVP(R8Xd@^RIHpV!VP4VV .RRVP74R 7pVP9V4pMhV'gaR!VP4R"VRV .RR/VP;R4CpVP=RR#7P>P@PB!R1/VBR$R/Bp.pVP(R8XdDV'g<VPEV4wppV'dVPF'd VPFpMVP(R8XdMV'gE^R%IH$pV!VVPJR&7wppV'dVPF'd VPFpM_\MVR'4'dNVPN'd<VPN^,PPpVPF'd VPFpVFpVPRPTR8XgK \VPX!VPRPZ4pVPR(R4p^R)I.H/pV!VPR*4VVPR 4VPR+4VPR,7pVP`'g!\cR-VPR(R4 24KK T'd9TR0,PR 4T8wdTP4T'dK?T'd2TR0,PR 4T8XdTP4R#R#R# \&d RpRpELi;i \dd#p \fPiR.T 4Rp ? EKRp ? ii;i \dd!p \fPiR/T 4Rp ? LRp ? ii;i T'd9TR0,PR 4T8wdTP4T'dK?T'd0TR0,PR 4T8XdTP4iii;i)2a=Give the model one turn to persist memories before context is lost. Called before compression, session reset, or CLI exit. Injects a flush message, makes one API call, executes any memory tool calls, then strips all flush artifacts from the message list. Args: messages: The current conversation messages. If None, uses self._session_messages (last run_conversation state). min_turns: Minimum user turns required to trigger the flush. None = use config value (flush_min_turns). 0 = always flush (used for compression). Nrr>u[System: The session is being compressed. Save anything worth remembering — prioritize user preferences, corrections, and recurring patterns over task-specific details.]__flush_rrrmr_flush_sentinelrr4r5rErrra)call_llmTflush_memoriesr`ir)taskrrr<r^rFrprr<r;rqrO)rBrrr^r_rRrBrrrnormalize_anthropic_responsestrip_tool_prefixrr| memory_toolactionold_textrr|rrr9u 🧠 Memory flush: saved to z!Memory flush tool call failed: %sz Memory flush API call failed: %srrd)5rNr4rJrfr`rQrr monotonicrrrrrrr?rr)rr+r=rtrrr"rPrBrKrPrrrYrZr r}rrr!r*rrrrarrrrQrrIr'rrr)!rCrr effective_min flush_content _sentinel flush_msg_needs_sanitizerGrrr4memory_tool_defr _call_llm_aux_availabler codex_kwargs_build_ant_kwargs ant_kwargsrr assistant_msgr _nar_flush _flush_msgr<rrA flush_target _memory_toolr]rs!&&& rErAIAgent.flush_memoriess@  ' '1 ,1B  400 08J8J8J %.%: @\@\  = 0   t%8$?H3x=1,  O  r$xj$..*:);< VY ?PR[\  "w ">>@OL((*776?k1 # 4I 7@ 34 K. OT2 -t4"<X>X YZ]ii #Ojj&&B&55R(,,V4@&'O' # jx|//0ABiO xHRL,,->?9L Mxk E!N $))*+ ## "dmm7H&H#55lC (,(=(=>O(P W%.1 ]+&,68?9L MxU  !& ~%M %H!LLM @ LL;Q ? ? @ x|//0ABiO xHRL,,->?9L Mxs AY>#AY>%7Y>,Y> )Y>8 Y>Y>Y>X8*Y>2A!Y>AY>,A:Y>'Y>Y>%Y>;$Y> Y>20Y>#.Y>)Y>BYY7Y>8Y Y> Y  Y> Y;Y6/Y>6Y;;Y>> Z) Z$Z,$Z))Z,,\%52\%,\%50\%rFr\r!c 8<V^8dQhRS[RS[RS[RS[RS[/#)rqrrvrFr\rr)rrPrr)rsrns"rErtr.Hs>]-]-$]-]-WZ]-lo]-AF]-rHc 6\V4p\PRVP;'gRTV'dVR MRVP4VP V^R7VP 'dVP PV4VPPWR7pVPP4pV'dVPRRR V/4VP4VPV4pWnVP"'EdVP"P%VP4p VP"P'VPR 4VPp \(P*!4P-R 4 R \.P0!4P2R , 2VnVP4RVP R2, VnVP"P9VPVP:;'g!\<P>PARR4VPV R7V 'dCVP"PCV 4p VP"PEVPV 4VP"PKVPV4^Vn&\QV4\SV4,p WPn*^VPn+VPPX^8d+WPPX, pVR8dRVn-^RI.H/pV!V4\PRVP;'gRV\V4V R 4Wh3# \dELi;i \F\3d"p \PIRT 4Rp ? EL7Rp ? ii;i \d"p \PORT 4Rp ? EL9Rp ? ii;i \dLi;i)z|Compress conversation context and split the session in SQLite. Returns: (compressed_messages, new_system_prompt) tuple zGcontext compression started: session=%s messages=%d tokens=~%s model=%srrr)r)current_tokensrrmrrrrrrrrr)rSrrBrdz,Could not propagate title on compression: %sNuKSession DB compression split failed — new session will NOT be indexed: %s333333?F)reset_file_dedupz?context compression done: session=%s messages=%d->%d tokens=~%s)0rQrrrSrBrrSon_pre_compressrrccompressrHformat_for_injectionrrrr?rBget_session_title end_sessionrrrr8r9r:r;r=rErarrFrget_next_title_in_lineageset_session_titlerNrupdate_system_promptrDr rr rrrsrtools.file_toolsr)rCrrvrFr\_pre_msg_count compressed todo_snapshotnew_system_prompt old_titleold_session_id new_titler_compressed_est_post_progressrs&&&$$ rE_compress_contextAIAgent._compress_contextHst X U OO % %v~$1}Qy$** H2     $$44X>,,55h5] ((==?    vvy-H I &&( 55nE%6"     q ,,>>tO   ,,T__mL!%%-\\^%<%<_%M$NaPTPZPZP\P`P`acPdOe"f(, (4??BSSX8Y(Y%  //#==ZZBJJNN;RTY,Z**&4 0X$($4$4$N$Ny$Y ((::4??IV  55dooGXY,-) ""3 4,Z8 9 6E29:6  " " 3 3a 7,/F/F/W/WWN$05-   9 W %  M OO % %v~s:q! ,,U  B' 2X %SUVWWX  qlnopp q8   sn5NDO 9OAN&-O P  N#"N#&O7O OOO P&PP PPc0<V^8dQhRS[RS[RS[RR/#rqreffective_task_idr[rrNrrPr)rsrns"rErtr.s,**t*X[*mp*y}*rHc VPpRVn\V4'gVPWW44RVn#VP WW44RVn# RTni;i)aExecute tool calls from the assistant message and append results to messages. Dispatches to concurrent execution only for batches that look independent: read-only tools may always share the parallel path, while file reads/writes may do so only when their target paths do not overlap. TF)rrr_execute_tool_calls_sequential_execute_tool_calls_concurrent)rCr<rrr[rs&&&&& rE_execute_tool_callsAIAgent._execute_tool_callssp'11 !% *1*==::%1B%*D ! 66!->%*D !ED !s"AA A!c H<V^8dQhRS[RS[RS[RS[S[,RS[/#)rqrrrrrr)rPrr)rsrns"rErtr.s>HH#HdHWZH#+C=H_"`aa S"#''4)--m<#''3###'??  h &"&&x:F E!$((2%)))4&**:6(( F### (9(9((CGY(Y((88%))(B7%)))R8M6M  ! ! !d&:&:&C&CM&R&R''88V V i ' H &**:r:%)))4..  o - K!"&&v.%)))4&**:6#''0,001AB!  (.?)??00b=A=R=R=Rd4#8#89  Y]  /!Ms=K K,+K,c0<V^8dQhRS[RS[RS[RR/#rr)rsrns"rErtr.s<VTVT$VTcfVTx{VTEIVTrHc  Raaa/VPp\V4pSP'd`\SP RV R24VF<pVP RRRRVP P R2RVP/4K> R #.pVEFp V P Pp V R 8Xd ^Sn MV R 8Xd^Sn \P!V P P4p \V \ 4'g/p V RN9drSP"P$'dVV P'R R 4p V 'd;SP"P)V 4p SP"P+V RV 24V R8XdSP"P$'dV P'RR 4p\/V4'djV P'R4;'g+\0P2!R\0P4!44pSP"P+VRVR, 24VP WV 34EK RP7RV44pSP8'g\RV RV 24\;V^4Fwpwppp\P<!VRR7pSP>'d=\RV RV R\AVPC44 R24\RV 24Kp\V4SPD8dVR SPDR ,MTp\RV RV R\AVPC44 R!V 24K VF<wpppSPF'gK\IVV4pSPGR"VVV4K> VF9wpppSPN'gKSPOVPVV4K; R .V,o/VV/V3R%lpR pSP8'd{SPF'giSPQ4'dS\RPT!\VPX4p\WV R&V R'2R(SPZR)7pVP]4\_V\`4p\bPdPgVR*7;_uu_4p.p\;V4F0wpwpppVPiVVVVV4pVP V4K2 \bPdPkV4R R R 4V'dA\mR+S/44p\mR,S/44p VPoR-V R.V R/V R0 R124\;T4EF`wpwpppS/T,p!T!f R2T R32p"R4p#MT!wrp"p#p$T$'d4\T"4^8d T"R5,MT"p%\pPsR6T T#T%4SPF'dSPGR7T R R T#T$R87SP>'dD\JPL!R9T R:T#R; R<24\JPL!R=\T"4 R>T" 24SP8'd%\uTTT#T"R?7p&SPwR@T& 24MSP8'gSP>'d*\RAT^, R:T#R; R<24\RBT" 24MN\T"4SPD8dT"R SPDR ,MT"p'\RAT^, R:T#R; RCT' 24R Sn<SP{RDT RET#R0 RF24SP|'d SP}TPTTT"4\TT"4p"SPPTT4p(T('d T"T(, p"RRRT"RTP/p)TP T)4EKc SPT4p*T*'EdT'dTRO,P'R4R8XdTRO,R,p+\P!T+4p,\T,\ 4'd)T*T,RH&\P<!T,RR7TRO,R&MT+RIT* 2,TRO,R&SP8'gOSPT, p-T-SPRJ,8:dRKMRLp.\SP T. RT- RM24R #R #R #R #R # \Pd/p EL+i;i \,dELi;i \,dELi;i \,d&p\JPL!R#T 24R p?EK R p?ii;i \,d&p\JPL!R$T 24R p?EKR p?ii;i +'giEL;i T'dB\mR+S/44p\mR,S/44p TPoR-T R.T R/T R0 R124ii;i \,d%p\JPL!R#T 24R p?EL/R p?ii;i \,d%p\JPL!RGT 24R p?ELR p?ii;i \P\3dT+RIT* 2,TRO,R&EL i;i)PzExecute multiple tool calls concurrently using a thread pool. Results are collected in the original tool-call order and appended to messages so the API sees them in the expected sequence. ⚡ Interrupt: skipping tool call(s)rrr[Tool execution cancelled — # was skipped due to user interrupt]rNrryrrbefore terminalr@workdirrbefore terminal: rrc3*"TF wrqxK R#5irUrd)rrras& rEr9AIAgent._execute_tool_calls_concurrent..Gs"G,JAQ4,su ⚡ Concurrent: u tool calls — Fr 📞 Tool r^(r Args: r) - tool.startedTool progress callback error: Tool start callback error: c<\P!4pS PW#S VP4p\P!4V, p\ W%4wrV'd \PRW'VR,4M \PR W'\V44W#WWV3S V&R# \d+pRT RT 2p\P RY&RR7Rp?LRp?ii;i) z%Worker function executed in a thread.Error executing tool '': z_invoke_tool raised for %s: %sTrNztool %s failed (%.2fs): %sr#tool %s completed (%.2fs, %d chars)) rrrrrrr6rrQ) rrrrrr] tool_errordurationis_errorrrresultsrCs &&&& rE _run_tool9AIAgent._execute_tool_calls_concurrent.._run_toolfsIIKE i**=IZ\e\h\hiyy{U*H.}EKH 8-SYZ^S_` A=\_`f\gh+FhWGEN i1-J<P =}cg hh isB// C$: CC$u ⚡ running z tools concurrentlydots spinner_typeprint_fn) max_workersc30"TF qfK^xK R#5irUrdrrs& rErrsD7a7s c3>"TFqfKV^,xK R#5irUrdr3s& rErrsGg!gsu⚡ ruz tools completed in .1fzs totalr$z!': thread did not return a resultrr"Tool %s returned error (%.2fs): %stool.completedr(r)Tool  completed in .2fs Tool result (rr] ✅ Tool Result: s - tool completed: rs)Tool complete callback error: rr9皙?⚠️ WARNING 💡 CAUTION iterations remaining write_filepatchr)ErrQrr'rLrrrarrOrPrrrrrOrrArrget_working_dir_for_pathensure_checkpointrrrr-getcwdrrIr,rrHrrCrKrT_build_tool_previewrrrUrrandomchoicer3KAWAII_WAITINGrrr_MAX_TOOL_WORKERS concurrentfuturesThreadPoolExecutorsubmitwaitrrdrr _get_cute_tool_message_implrrrRrVr*recheck_tool_call_get_budget_warningrrC)0rCr<rrr[r num_toolsr parsed_callsrrr file_pathwork_dirrrtool_names_strrrarAargs_str args_previewr(cb_errr+spinnerfacer1executorrWr'r total_durr4r tool_durationr)result_previewcute_msgresponse_preview subdir_hintsrbudget_warning last_contentrrtierr*s0f&&f& @rEr&AIAgent._execute_tool_calls_concurrents '11  O   $ $ $ T__%%=i[ V W F!? @P@P?QQtu"BEE!!  #I%..33M(+,(.0*+' # $ 9+=+=+G+G H mT22 "  77D>x7S`RaIbc  *t/C/C/K/K/K'++Ir:C.s33+// :ddbiiXZXaXaXc>d,,>>#4SXJ!?   = I JM$R"G,"GG &yk1A.AQR S'0q'A##Bd::d?'''L2dV1T$))+5F4GqIJKz23ORS[}_c_t_tOt8,BT-B-B#Ce#K{CLL2dV1T$))+5F4GtL>Z[(B+NBd***M1$=G//gtT ++NBd'''J,,RUUD$?+&9$ X" ???4#>#>#>4CcCcCeCe==!=!=>D#tfM)DW$Xgmx|yGyGHG MMO gi):;K##66;6OOS[+4\+B'A'D$  1b$EANN1%,C ""''0PD7DD GgGG  tI;a {:NyY\o]def$-\#: AD$ Ay$:4&@a"b # YZV o}h>A/>RUX>X_T%:^mNNN#GXeguv...Q33,mT4%2X4'''MME-}UXFYYZ"[\MMM#o2F1GyQ`Pa"bc6tT=Yhi  2hZ1___'''K!uN=:MQOPM/):;h8B<+;+;F+Cv+M#B< 2L QL1fd++0>F,-.2jje.THRL+.:tNCS=T.THRL+??? //.@ ,59L9Ls9R,R(Xf)$r)O'' # "  #!!.!MMM$B6("KLLM!JMM$?x"HIIJ@POOD7DD GgGG  tI;a {:NyY\o]def 4%Q (Fvh&OPPQ2!MMM$B6("KLLM<(()4 Q*64?O9P*P Y' Qs*d.d!:d!&:d3!Ad3 ee88f??A!f+ f?1h !h?0Ai1i1dd! d0/d03 ee e5e00e58 f(f##f(+ f< 6 f??A h  h<h77h<? i. i))i.11j&%j&c0<V^8dQhRS[RS[RS[RR/#rr)rsrns"rErtr.s<DTDT$DTcfDTx{DTEIDTrHc  &\VP^4EFwrVVP'dVPV^, RpV'd-VPVP R\ V4 R2RR7VF@pVP Pp RRRR V R 2R VP/p VPV 4KB E MVP Pp V R 8Xd ^Vn MV R 8Xd^Vn \P!VP P4p \%V \&4'g/p VP('g\P*!V RR7pVP,'d<\/RV RV R\1V P344 R24\/RV 24M`\ V4VP48dVRVP4R,MTp\/RV RV R\1V P344 RV 24WnVP9RV 24VP:'d!\=W4pVP;RV VV 4VPB'dVPCVPW4V Rs9drVPDPF'dVV PIRR4pV'd;VPDPKV4pVPDPMVRV 24V R8XdVPDPF'dV PIR R4p\OV4'djV PIR!4;'g+\PPR!R"\PPT!44pVPDPMVR#VR$, 24\VPV!4pV R%8Xd^R&I,H-pV!V PIR'4V PIR(R4VP\R)7p\VPV!4V, pVP('d"VPR*\_R%V VVR+7 24EMV R,8XdVP`'g\P*!R-RR.R//4pMV^R0I1H2pV!V PIR1R4V PIR24V PIR3^4VP`VPfR47p\VPV!4V, pVP('d"VPR*\_R,V VVR+7 24EM8V R 8XdT PIR5R 4p^R6I4H5pV!V PIR74VV PIR4V PIR84VPlR97p\VPV!4V, pVP('d"VPR*\_R V VVR+7 24EMV R:8Xd^R;I7H8pV!V PIR7p\VPV!4V, pVP('d"VPR*\_R:V VVR+7 24EMV R?8XEd^R@I:H;pV PIRA4pV'd'\%V\04'dRB\ V4 RC2p M1V PIRD4;'gRRE,p!V!'dRFV! 2MRGp Rp"VP('dzVP:'ghVPy4'dR\zP|!\~P4p#\V# RHV 2RIVPRJ7p"V"P4V"VnCRp$V!V PIRD4V PIRK4V PIRL4VV PIRM4VRN7pTp$RVnC\VPV!4V, p\_R?V VV$R+7p%V"'dV"PV%4EMDVP('dVPR*V% 24EMVP'EdJVPPV 4'Ed(Rp"VP('dVP:'gu\zP|!\~P4p#\V 4p&\=W4;'gT p\V# RHV& RHV 2RIVPRJ7p"V"P4Rp'VPPW4pTp'\VPV!4V, p\_WVV'R+7p%V"'dV"PV%4EMVP('dVPR*V% 24EMVP('Ed<Rp"VP:'gu\zP|!\~P4p#\V 4p&\=W4;'gT p\V# RHV& RHV 2RIVPRJ7p"V"P4Rp)\YTVPVPf;'gRVP'd\1VP4MRRS7pTp)\VPV!4V, p\_WVV)R+7p%V"'dV"PV%4MVPR*V% 24Mr\YTVPVPf;'gRVP'd\1VP4MRRS7p\VPV!4V, pVP,'dTM\ V4^8d VRW,MTp*\V V4wp+p,V+'d\P#RXV VV*4M!\PRYV V\ V44VP:'dVP;RZV RRVV+R[7RVnVP9R\V R]VR^ R_24VP,'dD\ P@!R`V RaVRb Rc24\ P@!Rd\ V4 ReV 24VP'dVPVPWV4\V V4pVPPW4p-V-'d VV-, pRRRVR VP/p.VPV.4VP('g|VP,'d#\/RgV RaVRb Rc24\/RhV 24MG\ V4VP48dVRVP4R,MTp/\/RgV RaVRb RiV/ 24VP'dV\ VP48d\ VP4V, p0VPVP RV0 Rj2RR7VPVRF@pVP Pp RRRRkV Rl2R VP/p VPV 4KB MVVP^8gEK`V\ VP48gEK}\VP!VP4EK VPV4p1V1'EdV'dVRt,PIR4R8XdVRt,R,p2\P!V24p3\%V3\&4'd)V1V3Rm&\P*!V3RR7VRt,R&MV2RnV1 2,VRt,R&VP('gOVPV, p0V0VPRo,8:dRpMRqp4\/VP V4 RV0 Rr24R#R#R#R#R# \Pd'p \ P"!RT 24/p Rp ? ELRp ? ii;i \>d%p\ P@!RT 24Rp?E LRp?ii;i \>d%p\ P@!RT 24Rp?E LRp?ii;i \>dE Li;i \>dE Li;i RTnC\VPV!4T, p\_R?T TT$R+7p%T"'dT"PT%4iTP('dTPR*T% 24ii;i \>dCp(\P*!R.ROT RPT( 2/4p\PRQT T(RRR7Rp(?(EL#Rp(?(ii;i \VPV!4T, p\_YTT'R+7p%T"'dT"PT%4iTP('dTPR*T% 24ii;i \>d-p(RTT RUT( 2p\PRVT T(RRR7Rp(?(ELkRp(?(ii;i \VPV!4T, p\_YTT)R+7p%T"'dT"PT%4iTPR*T% 24i;i \>d-p(RTT RUT( 2p\PRVT T(RRR7Rp(?(ELSRp(?(ii;i \>d%p\ P@!RT 24Rp?ELRp?ii;i \>d%p\ P@!RfT 24Rp?ELLRp?ii;i \P\3dT2RnT1 2,TRt,R&ELi;i)uz`Execute tool calls sequentially (original behavior). Used for single calls or interactive tools.NrrTrrrrrrrrryz(Unexpected JSON error after validation: Frrr^rrrrrzexecuting tool: r r!r"rrrrr@rrrrrrrkrlrr@r?rxrhrrrrrrrr|rrrrrrrrrrrru🔀 delegating z tasksr:NNu🔀 u🔀 delegatingrnr-r.rrrCrz Memory tool 'z ' failed: z1memory_manager.handle_tool_call raised for %s: %srrr$r%z&handle_function_call raised for %s: %srr7r&r8r9rDrr6rEr:r;r<r=r>rrFrArBrCz remaining tool call(s)u[Tool execution skipped — z* was not started. User sent a new message]rr9rGrHrIrJrKr)Xr,rrrrLrQrrarrrOrPrrrrrr rOrrIrrHr'rrCrKrrRrTrQrrrUrArrrNrOrrr-rPrrGrrHr[rBrrxrSrQrrJr rrYrrrrRrSr3rTrr_delegate_spinnerrdrSr_get_tool_emojirrrrr4r6rrVr*rer\rDrr]rrC)5rCr<rrr[rrremaining_calls skipped_tc skipped_nameskip_msgrrrrcrdr(rer`rarrtool_start_timer rrjr r|rr r  tasks_arg spinner_label goal_previewrfrg_delegate_resultrlemoji _mem_resultr'_spinner_resultrk_is_error_resultrrnrrmrrorprrqs5&&&&& rEr&AIAgent._execute_tool_calls_sequentials.%&7&B&BAFLA((("3">">qst"D"LLDOO#44LSQ`MaLbbo!px|L}"1J#-#6#6#;#;L!%CL>Qt#u&  H OOH-#2%..33M(+,(.0*+' # $ 9+=+=+G+G H mT22 " ???::m%H'''L2m_Ad=CUCUCW>X=YYZ[\Kz23ORS[}_c_t_tOt8,BT-B-B#Ce#K{CLL2m_Ad=CUCUCW>X=YY]^j]klm!.   #3M?!C D***M1-OG// wXef'''J,,Y\\=X  77D>$ &? *t/C/C/K/K/K'++Ir:C.s33+// :ddbiiXZXaXaXc>d,,>>#4SXJ!? #iikO&C",'++G4'++GU;**# !% o = ???LL2&A&-Yfo~&&A"BC"22'''&*jj)UGMn1o&pO[&5+//<$1$5$5m$D+//;+++/?? 'O!% o = ???LL2&ABRTacpzI'J&K"LM(*&**8X>I".(,,X6!)--i8*..z:,, #!% o = ???LL2&A(M[hrA'B&C"DE)+L"/*..z2>)--i8!22# !% o = ???LL2&A)]\isB'C&D"EF/1O)--g6 It!JeL>$:PaM???4+F+F+F4KkKkKmKm!==)E)EFD+tfAm_,ETZeiesestGMMO)0&#' 6&4*..v6 - 1 1) ''4'8'89I'J%) 'O(7$-1D*$(IIK/$AM:?M[hrB CH X. r(_5%%%$*>*>*G*G *V*V???4+F+F+F!==)E)EFD+M:E1-O``S`G+tfAeWAgY,GV\gkguguvGMMO"  6&*&:&:&K&KM&iO"1K %)IIK/$AM:=Yfoz{H X. r(_5222!==)E)EFD+M:E1-O``S`G+tfAeWAgY,GV\gkguguvGMMO"&6&:%6G%.\\#'??#8#8bEIEZEZEZd4+@+@&A`d 'O '6O %)IIK/$AM:=Yfo~H X. r(_5 u&:%6G%.\\#'??#8#8bEIEZEZEZd4+@+@&A`d 'O!% o = 040D0D0D_),_)=)C%  #7}o"V  aC]Tacqr A=R_adetauv***M//(-t!.9I0"&D   #3M?"]SVDWWY!Z [### m_N=QTBUUVWX c/.B-C9_L]^_***M// m\kl :-YO 33CCMaL</? H OOH %???'''Ks.s8K1MNM/):;">qr"BJ#-#6#6#;#;L!%A,Oy#z&  H OOH-#C"q3/@/K/K+L'L 4??+[ Gf 11.A >h8B<+;+;F+Cv+M#B< 2L QL1fd++0>F,-.2jje.THRL+.:tNCS=T.THRL+??? //.@ ,59L9Ls9R,R(Xf)$r)q'' #"J1# NO "  #,!MMM$B6("KLLM !JMM$?x"HIIJ!!^.2D*$(IIK/$AM:?M[hrB CH X. r(_5) !@&*jj']=/Ycdnco;p1q&rOLL!TVceoz~L@%)IIK/$AM:=Yfoz{H X. r(_5)&!u(>}oSQ[P\&]OLL!I=ZdosLttu%)IIK/$AM:=Yfo~H X. r(_5!u(>}oSQ[P\&]OLL!I=ZdosLttu.!MMM$B6("KLLM!MMM$B6("KLLMp(()4 Q*64?O9P*P Y' Qs6*<A@.AA .AA>:AA>&:AB!AABA AB""AD 8AGAG;$AI1 AI14AI1?AJ+AK AALALA@1A@@A@@ AA @%AAAAA A AA;AAA6A6AA;A> AB B AB B ABBABB"AADDADD AE'D%7AE"EAE*E"AE'E'AE*E*AAGGAGG AHG%!AH HAHH AHHAHHAAI.I1 AJ(IST!{#cc  55 5%n%5Qt7J7J6K2+NP rHc$<V^8dQhRS[RR/#)rqcompaction_progressrrN)rk)rsrns"rErtr.>s %Y%Y%%YPT%YrHc ^RIHpHpVP'dVPVP, MRpVP R 9d2V!VVPVVP R7pVPV4VP'd+V!VVVP R7pVPRV4R#R# \d\PRRR 7R#i;i) uNotify the user that context is approaching the compaction threshold. Args: compaction_progress: How close to compaction (0.0–1.0, where 1.0 = fires). compressor: The ContextCompressor instance (for threshold/context info). Purely user-facing — does NOT modify the message stream. For CLI: prints a formatted line with a progress bar. For gateway: fires status_callback so the platform can send a chat message. )format_context_pressureformat_context_pressure_gatewayrN)rrsrrd)rrrdcontext_pressurez)status_callback error in context pressureTr)Nr) agent.displayrrrrsrardrr]rrr)rCrrVrr threshold_pctliners&&& rE_emit_context_pressureAIAgent._emit_context_pressure>s [S]SlSlSl 33j6O6OOru ==M )*$7!+!.*?\s*rrz>I reached the iteration limit and couldn't generate a summary.)rBrrrQr^r_rRiteration_limit_summary_retryz Failed to get summary response: z"I reached the maximum iterations (z!) but couldn't summarize. Error: )r4rErd)0r'rCrrrrrr?rJrr`r,insertr8rgr_r=rtrr}rrBr^rurrMrNrOrPr"rPrr!rKrPrrYrZr rrrrrrrr rP)!rCrr[summary_requestrrGrrinternal_fieldeffective_system sys_offsetrpfmsummary_extra_bodyrsrsummary_responser<rrsummary_kwargsro_bak_nar_ant_kw_msgretry_response retry_msg_bak2_nar2_ant_kw2 _retry_msgrs!&&& rE_handle_max_iterationsAIAgent._handle_max_iterationses& 4T5H5H4IIabc .  ODEH A#>>@OL((*&DNKK5'E"<N OPS__ $$$"2Q )$*?*? @HC '' (8#((*E!A"$ %)=)==H2244((46:6K6K&{3"4 (7&{3.D-E"6*}} 11#55lC   $/#'#9#9,#G '+'E'EFV'W$!1N_"3";";"A"Ar!H!H!JegTZZ "??."))$*@*@*QR(*$)))373I3I(0)))595K5K(2'''484H4H(1%%%373E3E(0'5I&z2%3EN<0==$88|"lRV.2ooPTPePe,0,D,D151N1N1PRG(,'F'Fw'O$"#3tG_G_`GD!&*ll&8&8b%?%?%AN'+'I'IQj'I'k'p'p'|'|(D(D(VGU(V$'///4D4L4LQ4O4W4W4_4_4_)9)A)A!)D)L)L)T)T)+.%'VV,Db.`b`i`i%j%p%p%rN!OOV[)^$TUfc&fNb]==$55#'#9#9,#GL $$Wd3%)%;%;L%IN#'#A#A.#QLIqJSi&7&7&=&=2%D%D%FY[N]]&::~$4:: TX-1-E-E/3QUQfQf262O2O2Q SH&*%D%DX%NN$).DLdLd$eMJ&0&8&8&>&>B%E%E%GN "L&N2&--d.D.DT__.UV)7I|4'+'I'IQp'I'q'v'v(C(C(J(J(\M[(\$'///4D4L4LQ4O4W4W4_4_4_)9)A)A!)D)L)L)T)T)+! N2)+0H"ndfdmdm)n)t)t)v% i(XY*j &fN   A OO>qcB CA$BUBUAVVwx{|}x~wAN  AsA ^<8^5^ /^:^^"A.^.^A&^'^:A0^+ ^ ^- ^^% ^2B^A^*,^1^ A^^%^*A ^ ^B-^ A!^.A ^;,^(1^A^^6^;^ _  4__ c<V^8dQhRS[RS[RS[S[S[S[3,,RS[RS[S[,RS[S[,RS[S[S[3,/#)rqrrvrHr\stream_callbackpersist_user_messagerr)rPrrrrrl)rsrns"rErtr.sxE$E$E$E$#4S>2 E$  E$ "(+ E$'smE$ c3hE$rHc# aa+aaa߀\4SP4\V\4'd \ V4p\V\4'd \ V4pVSnRSnVSnT;'g\\P!44p^Sn ^Sn ^Sn ^Sn ^SnRSnRSnRSnSP$R8wd)SP'4'dSP)R4\-SP.4Sn\3V4^P8dVR,R,MTpVP5RR4p\6P9R SP:;'gR SP<SP>;'gR SP@;'gR \3T;'g.4V4V'd \CV4M.p V 'd \EV 4V'd2SPFPI4'gSPKV4S;PL^, un&VeTMTp Rp SPN^8daR SPP9dPSPR'd>S;PT^, un*SPTSPN8d R p ^Sn*RRRV/p V PWV 4\3V 4^, p V SnSPX'g1SP[RVR, \3V4^<8dRMR R24SP\Ef RpV'd\SP^'dJSP^PaSP:4pV'dVPcR4;'gRpV'd VSn.MSPeV4Sn.^RI3H4pT!RSP:SP<\kSRR4;'gRR7SP^'d2SP^PoSP:SP\4SP\pSPr'Ed\3V 4SPtPvSPtPx,^,8Edk\{T T;'gRSP|;'gRR7pVSPtP~8Ed#\6P9RVR SPtP~R SP<SPtPR 4SPX'g/SP[RVR R SPtP~R R!24\^4Fp\3V 4pSPWVVR"7wp p\3V 4V8dMORp\{T T;'gRSP|;'gRR7pVSPtP~8gKM Rp^RI3H4pT!R#SP:T \CV 4\V4'*SP<\kSRR4;'gRR$7p.pVFp\V\4'd;VPcR%4'd$VPW\VR%,44KS\V\4'gKkVP4'gKVPWV4K V'dR&PV4p^pRpRp^p^pRp ^p!SP4Rp"SP'dA\T \4'dT MRp#SPPT#4;'gRp"TSP.8E2dSP0P^8E1dSPP4SP'd(R pSPX'gSP[R(4E1MT^, pTSnNSPR)T 24SP0P4'gUSPX'gASP[R*SP0P R+SP0P R,24E0MSPEe-.p$\\T 44Fwp%p&T&PcR4R-8XgKT&PcR.4'gK7\3T 4T%, p'/p(T T'RFKp)T)PcR4R/8wdM4T)PcR04p*T*'gK6T)PcRR4T(T*&KM T&R.,U+u.uFMp+\T+\4'gKR1T+R2,R1,R3T(PcT+PcR444/NKO p$p+M SPTT$4SP^8d+R6SPP9dS;P^, unW.p-\T 4EFiwp.p/T/P4p0T.T 8XdT/PcR4R8Xd.p1T"'d%\T"4p2T2'dT1PWT24T'dT1PWT4T1'dKT0PcRR4p3\T3\4'd#T3R&,R&PT14,T0R&T/PcR4R-8XdT/PcR74p4T4'dT4T0R8&R7T09dT0PR74R9T09dT0PR94SP4'dSPT04T-PWT04EKl T;'gRp5SP'd)T5R&,SP,P4p5T5'dRR:RT5/.T-,p-SP'dST5'd^M^p6\SP4F-wp.p7T-PT6T.,T7P44K/ SP'd&\T-SPSP$R8HR;7p-SPT-4p-\R<T-44p8T8^,p9RoSPX'gSPRSP R=T R+SP. R24SPSP R>\3T-4 R?T9R R@T8R RA24SPSP RBSP|'d\3SP|4M^ 24M\P!\P4p:\P!\P4p;SP'dSPT: RT; R24MsSP4'g^SP4'dH\P!.ERO4p<\T: RT; R2T^p?Rp@^pARpBRpCRpDRpERpFRpGRJpHRpIT>T?8EdSPT-4pJSP$RK8XdSPXJRRL7pJ^RI3H4pT!RMTSP:;'gRSP@;'gRSP<SP>SPSP$T\3T-4\3SP|;'g.4T9T8SPRN7\RO4'dSPXJRPRQ7TT3RRlpKR pLSP4'g&^RSIzH{pM\\kSRTR4TM4'dRpLXL'dSPXJXKRU7pIMSPXJ4pI\P!4T=, pNS'dSPR4RoSP'dSPR4SPX'g#SPSP RVXNRW RX24SP'dSXI'd\kXIRYRZ4MRZpO\Pp!R[TO R\\XIR]4'dXIEPMRZ 24RpP.pQSP$RK8XdXIe\kXIR^R4MRpRXIfR pPXQPWR_4EM\XR\B4'gR pPXQPWR`4EM\3XR4^8Xdm\kXIRaR4pS\kTIRbR4pT\Pl!RcTSTT\kTIRYR4RdSP$ ReSP> 24R pPXQPWRf4EM8SP$R8XdzXIe\kXIRR4MRpUXIfR pPXQPWR_4M\XU\B4'gR pPXQPWRg4M\3XU4^8XdR pPXQPWRh4MXIe=\XIRi4'd+XIEPe\3XIEP4^8XdoR pPXIfXQPWR_4MV\XIRi4'gXQPWRj4M2XIEPfXQPWRk4MXQPWRl4XP'EdS'dSPRm4RoSP'dSPR4T>^, p>SEP\3SEP48dSP)Rn4SEP 4'd^p>EK'RooRopVXI'd\XIRp4'dXIEP 'd{\XIEP 4o\TIEP Rq4'dGXIEP EP 'd)XIEP EP PcRrRo4pVMCXI'd<\XIRs4'd*XIEP'd\XIEP4oXVRo8Xd<XI'd4\XIRY4'd"XIP<'dRtXIP< 2pVXVRo8XdXI'dE\XI4EP4UWUXu/uF3wpWpXTWEPRu4'dK XW\XX4Rv,bK5 pYpWpXSP'd\Pp!RwXY 24SPSP RxT> R+T? RyRzPXQ4 2R R{7SPSP R|XV 2R R{7SEPS4pZSPSP R}TZ 2R R{7SPSP R~XNRW R2R R{7T>T?8dSP)RT? R24SEP 4'd^p>EKSP)RT? R24\EP !SP RT? R24SEPY4RT RRRTRpRRR /#E\^^T>^, ,,^x4p[SPSP RT[ R2R R{7\Pl!RT> R+T? RyRzPXQ4 RXV 24\P!4T[,p\\P!4X\8dSP'dVSPSP R2R R{7SEPY4SP4RRT> R+T? R2RT RTRRRR /#\EP!R4KE K]SP$RK8Xdg\kXIRaR4p]\kTIRbR4p^Rp_\T^\4'dX^PcR4p_M \kX^RR4p_X]R8Xd X_ER9dRpHM[RJpHMXSP$R8Xd)RRJRR.RRRRJ/p`T`PcXIEPRJ4pHMXIEP^,EP pHXHR8XEdSPSP R2R R{7RpaSP$R8Xd_\XIRi4'd3XIEP'd XIEP^,EPMRpbTb'd\kXbRR4MRpaMrSP$R8Xdb.pc\kXIR.4F3pd\kTdRR4R8XgKXcPW\kXdRR44K5 Xc'dRPXc4MRpaXaRJ;'d SEP#Xa4'*;'gXaRJpeTe'dWRpfSPSP R2R R{7RpgSEP%T4SEPY4RTgRT RTRRRR RpTf/#SP$R8XEd@XIEP^,EPphThEP&'Eg T^, pSEP)XhXH4piT PWTi4ThEP*'dT XhEP*, p T^8dVSPSP RT R24RRRR/pjT PWTj4T SnSEP/T 4R pGEMDSEP1T 4P4pkSEP%T4SEPY4RTk;'gRRT RTRRRR RpR/#\3T 4^8dcSPSP R24SEP3T 4plSEP%T4SEPY4RRRTlRTRRRR RpR/#SPSP R2R R{7SEPY4RRRT RTRRRR RpR/#\XIR]4'Ed XIEP'EdE\5XIEPSP>SP$R7pmTmEP6pnTmEP8poTmEP:ppRTnRToRTp/pqSPtEP=Tq4SPtEP>'dSPtPpr\kSPtRR4'dQE\ASP<SPXr4SP[SP RTrR RSP< 24RSPtnRSPtnS;EPDXn, unS;EPFXo, unS;EPHXp, unS;EPJ^, unS;EPLXmEPN, unS;EPPTmEP8, unS;EPRTmEPT, unS;EPVTmEPX, unS;EPZTmEP\, unRpsTmEPT'd:Xn'd2RXmEPT R+Xn R^dTmEPT,Tn, R R2ps\6P9RSEPJSP<SP>;'gR XnXoXpXNXs4 E\_SP<XmSP>SP\kSRR4R7ptTtEP`e0S;EPbE\eXtEP`4, unXtEPfSnTtEPjSnSP^'dSP:'dSP^EPoSP:XmEPNTmEP8TmEPTTmEPXTmEP\XtEP`eE\eXtEP`4MRXtEPfTtEPjSP>SPTtEPfR8XdRMRSP<R7 SP'd8\Pp!RXqR,R RTqR,R RTqR,R 24SP'EdSP$R8XdF\kXIEPR^4;'g^pu\kXIEPR^4;'g^pvMZ\kXIEPRR4pwTw'd\kXwR^4;'g^M^puXw'd\kXwR^4;'g^M^pvXqR,pxTx^8dXuXx, ^d,M^pySPX'g/SPSP RXuR R+XxR RXyR RXvR R2 4RpESPRT R24T'dEMZXF'd3T^,pSP0EP4T>^, p>RpFEKXG'dEKXIf/E\SP ERo24SEPY4EMSP$RK8XdSEPXI4wphpHMQSP$R8Xd"^ERpIHpT!XISEPERq7wphpHMXIEP^,EPphXhEP*Ee\XhEP*\4'EgyXhEP*p\T\4'dTXPcRR4;'g3XPcRR4;'gE\EP!X4XhnEM\X\B4'd.pXFp\T\4'dXPWX4K,\X\4'd:XPcR4R8Xd$XPWXPcRR44K{\X\4'gKRX9gKXPW\XR,44K RPX4XhnM\X4Xhn^RI3H4p\kXhR.R4;'g.pXhEP*;'gRpT!ERERrTERsSP:;'gRRSP@;'gRRYSP<RSP>RSPERtSP$ERuTERvXNR9XHERw\3T-4ERx\kXIRYR4R]SEPTI4ERy\3X4ERz\3X4/XhEP*'dSPX'gSP'd.SPSP ER{XhEP* 24MRSPSP ER{XhEP*Rv, \3ThEP*4^d8dRMR 24XhEP*'dSEP'dXhEP*P4pE\EP!ER|RT4P4pT'd!XEPR4^,R,MRpT'd*\kSER}^4^8dSEPER~X4M(X'd!SEPERER~XER,R4E\XhEP*;'gR4'Ed\SER4'g^Sn S;P^, un SPSP ER24SP^8:d1SPSP ERSP ER24E!KSPSP ER2R R{7^Sn SEP3T 4plSEP%T4SEPY4RRRTlRTRRRR RpER/#\SER4'd^Sn SP$RK8XEdXHR8XEd\SER4'g^SnS;P^, unSEP)XhXH4pi\TiPcR4;'gRP44p\XiPcR74\4'd*\XiPcR7R4P44MRp\XiPcER44pX'gX'g X'Ed=T 'd T ER,MRp\T\4'dXPcER4MRpXiPcER4p\X\4;'dXPcR4R-8H;'dXPcR94R8H;'dXPcR4;'gRXiPcR4;'gR8H;'dEXPcR74;'gRXiPcR74;'gR8H;'dXX8HpT'gT PWXi4SP^8d\SPX'g.SPSP ERSP ER24T SnSEP/T 4E$K^SnSEPY4RRRT RTRRRR RpER/#\SER4'd^SnXhEP&'E d]SPX'g8SPSP ER\3XhEP&4 ER24SP'dhXhEP&FVo+\Pp!ERS+EPEP ERS+EPEPER, R24KX XhEP&Fo+S+EPEPSPP9gK,SEPS+EPEP4pT'gK^E\SP ERS+EPEP ERX R24TS+EPnK XhEP&U+u.uFDp+T+EPEPSPP9gK,T+EPEPNKF pp+T'Ed\SER4'g^Sn S;P^, un RzPE\SPP44pX^,p\3T4^P8dXR,R,MXpSPSP ERT ERSP ER24SP^8dMSPSP ER2R R{7^Sn SEPY4RRRT RTRRRR RpERX 2/#SEP)XhXH4pT PWT4ThEP&Fpo+S+EPEPSPP9d"ERS+EPEP ERX 2pMERpT PWRR/R0S+EPRX/4Kr E(K\SER4'd^Sn .pXhEP&Fo+S+EPEPp\T\\B34'd+E\EP!X4S+EPnKaXeJ\X\4'g4\X4S+EPnS+EPEPpX'dXP4'gERS+EPnKE\EP!X4K X'EddS;P^, un X^,wpoSPSP ERT ERS 24SP^8d0SPSP ERSP R24E*KSPSP ER24^Sn SEP)XhXH4pT PWT4XUUu0uFwppTkK pppXhEP&Feo+S+EPEPX9d!E\T+3ERlX44pERT ER2pMERpT PWRR/R0S+EPRX/4Kg E+Ka^Sn SEPXhEP&4ThnSEPThEP&4ThnSEP)ThXH4pThEP*;'gRpT'dSEP#X4'dXSnE\0ERm4oE\;QJd+T3ERlXhEP&4F 'dK RM R M!T3ERlXhEP&44pT'dSP4'd R SnMOSPX'd>SEP1X4P4pT'dSPERX 24T PWX4SEP'dSEPR4SEPXhYT4R SnThEP&U+u0uFp+T+EPEPkK pp+TER08XdSP0EP4SPtpTEP^8d!XEPTEP,pM E\T 4pXP~^8dIXXP~, pTER8d.SEP'gR SnSEPXX4SPr'dGXEPX4'd/SPYSPtEPTR"7wp pRpT SnSEP/T 4E.KXhEP*;'gRpSEP#T4'Eg\kSERR4pT'EdB\6PqER4RSn^Sn \\3T 4^, ERER4FpT T,p/T/PcR4R-8XgK$T/PcR.4'gK=.pT/R.,FVo+S+'d\S+\4'gK#S+PcR2/4pXPWTPcR1R 44KX ERRzPX4 ER\3T4^8dRXMR R2T/R&M SEP1X4P4pR SnEMSEPXh4p4SEP)ThXH4pERTR&T PWT4T4'dF\3T44R8dT4ER,R,MT4pSPSP ERT 24MSPSP ER24ERpEMM\SER4'd^Sn RSnSP$RK8XdSPP'dT^8d~SEPTTT ER7'dbT^, pSEP)XhR4piT PWTi4RRRER/pjT PWTj4T SnSEP/T 4E1K^pT 'dT T,pRp ^pSEP1T4P4pSEP)XhXH4pT PWT4SPX'gSP[ERT ER24TfTSP.8gSP0P^8:d|SP0P^8:dNSPX'g<E\R*SP0P R+SP0P R,24SEPT T4pTRJ;'dTSP.8pSEPYT4SEP%T4SEPY4T'dST'gK^RI3H4pT!ERSP:T T\CT 4SP<\kSRR4;'gRER7Rp\T 4F=p/T/PcR4R-8XgKT/PcR74'gK4T/R7,pM /RTbERXbRT bRTbRXbRRbRTbER\kSERR4bRYSP<bRSP>bRSPbERSEPLbERSEPPbERSEPRbRSEPVbERSEPZbRSEPDbRSEPFRSEPHER\kSPtER^4;'g^ERSEPbERSEPhERSEPl/CpRSnT'd%SEP'dSEPXER&SP4RSnRpSP^8d6SPSP8dR6SPP9d R p^SnWSP'dKT'dCT 'd;SPEPT T4SPEPT 4T'd9T'g1T 'g X'd!SEP\CT 4T XER7^RI3H4pT!ERSP:XTSP<\kSRR4;'gRER7X# \*dER8XdPX|R8XdIXB'gAR pBSEP{R R{7'd&SPSP R24Rp{?{E1KSP$R8Xd\SP>R8XdKX|R8XdDXD'g<R pDSEP}R R{7'd!E\SP R24Rp{?{E2K#SP$R8XEdX|R8XEd\SR4'EdXC'EgR pC^RIHpSEP4'd!E\SP R24Rp{?{E2KSEPpX!T4'dRMRpE\SP R24E\SP RT 24E\X'd*\3X4^ 8dSP RXR, R2MSP R24E\SP R24^RIHpT!4pE\SP RT R24E\SP RT R24E\SP R24E\SP R24E\SP R24E\SP R24T>^, p>\P!4T=, pE\X{4EPp\T{4EP4oSEPT{4p\6PmRT>T?TSEP4T4\kSRR 4p\kSRR 4p3\kSRYR 4pX|'dRX| R2MRpSPSP RT> R+T? RyX T 2R R{7SPSP RX RX 2R R{7SPSP RT3 2R R{7SPSP RX 2R R{7X|'d[X|R8dT\kX{RR4pT'd\X4R,MRpT'd#SPSP RX 2R R{7SPSP RXRW R\3T-4 RT9R RI24SP'duSPSP R2R R{7SEPY4SP4RRX ERSEP\X{44 R2RT RTRRRR /uRp{?{#\kX{RR4p|T|ER8H;'d<ERS9;'d.ERS9;'d ERSP<EP49pT'Ed ERpSPtpTPpTT8dcXXn@E\TTEP,4Tn?R TnRTnSPSP ERXR ERTR RI2R R{7T!^, p!T!XA8:dw\3T 4pSPYT9TR"7wp p\3T 4T8gXX8d>SP)ERXR ER XR ER 24\EP!^4R pFRp{?{E#KX|ER8H;'g?ER S9;'g1ER S9;'g#ER S9;'gERS9;'gERS9pT'dSEP\3SEP48deSEPpTRJ;'dXEP4pT'g3SP)ER4SEP 4'd ^p>Rp{?{E8KX|ER8H;'g#ERS9;'gERS9;'gERS9pT'EdT!^, p!T!XA8dSPSP ERXA ER2R R{7SPSP ER2R R{7\EP !SP ERTA ER24SEPY4RT RRRTRpERTA ER2RR /uRp{?{#SP)ERT! R+XA R24\3T 4pSPYT9TR"7wp p\3T 4T8dESP)ERX ER\3T 4 ER24\EP!^4R pFRp{?{E&K&SPSP ER2R R{7SPSP ER2R R{7\EP !SP ER 24SEPY4RT RRRTRpER!RR /uRp{?{#E\;QJd!T3ER"lER4F 'gK R M RM!T3ER"lER44pT'gX|ER#8Xd\k\kSER$R4ER%ER4pT9TER&,8;'g\3T-4^P8p\3SP44^8pT'd>X'd6R pSPSP ER'T9R ER(\3T-4 ER)2R R{7X'gX|'gER*S9;'gER+S9;'gXER9pT'd|\k\kSER$R4ER%ER4pT9TER,,8;'g\3T-4^8pT'd6R pSPSP ER-T9R ER(\3T-4 ER.2R R{7X'Ed SPtpTPpE\S4pT'd6XX8d/XpSPSP ER/TR ER XR ER02R R{7M E\X4pX'dXX8dzXXn@E\TTEP,4Tn?R Tn\X;'dXX8H4XnSPSP ER1XR ERXR RI2R R{7M!SPSP ER22R R{7T!^, p!T!XA8dSPSP ERXA ER2R R{7SPSP ER2R R{7\EP !SP ER3TA ER24SEPY4RT RRRTRpER4TA ER2RR /uRp{?{#SP)ER5T9R ER6T! R+XA ER724\3T 4pSPYT9TR"7wp p\3T 4T8gX'd\XX8dU\3T 4X8d%SP)ERX ER\3T 4 ER24\EP!^4R pFRp{?{E*KSPSP ER82R R{7SPSP ER92R R{7\EP !SP ER:T9R ER;24SEPY4RT RRRTRpERlER4F 'gK R M RM!T3ER>lER44;'dX'*pT'EdSP)ERAX| ERB24SEP 4'd ^p>Rp{?{EAK SPXJERCX{ERD7SP)EREX| RySEPT{4 24SPSP ERFT| ERG2R R{7SPSP RX RX 2R R{7SPSP RT3 2R R{7T|ER9gER?S9gER@S9g ERHS9Ed=XR8XdX|R8XdSPSP ERI2R R{7SPSP ERJ2R R{7SPSP ERK2R R{7SPSP ERL2R R{7MSPSP ERM2R R{7SPSP ERN2R R{7SPSP EROX ERP2R R{7ERQ\T34EP49d"SPSP ERR2R R{7M!SPSP ERS2R R{7\EP !SP ERTX{ 24X|ER#8Xd;T9ERU8g\3T-4^P8d#SPSP ERV2R R{7MSEPY4RRRT RTRRRR Rp\X{4/uRp{?{#T>T?8EdX@'g(SEPX{T>T?ERW7'd R p@^p>Rp{?{EDKSP)RT? ERX24SEP 4'd ^p>Rp{?{EDK9SEPX{4pX'dSP)ERYT? ERZX 24MSP)ER[T? ERZX 24SPSP ER\X 2R R{7\kX{RR4'*;'d@E\;QJd!T3ER]lER4F 'gK R M RM!T3ER]lER44pT'dCSPSP ER^2R R{7SPSP ER_2R R{7\EP !ER`SPT?XXX\3T-4T9R 4SPXJERaX{ERD7SEPY4ERbT? ERcT 2pX'd XERd, pRXRT RTRRRR RpX/uRp{?{#RpX'd\k\kX{EReR4ERfR4pT'dz\XERg4'dgXPcERh4;'gXPcERi4pT'd3E\E\X4^x4pM E\E\3dMi;iX'dXME\^T>,^<4p[X'd'SP)ERjX[ ERkT>^, R+T? ER724MSP)RX[ ERlT> R+T? ER724\6PmERmX[T>T?SEP4X{4\P!4T[,p\\P!4X\8dSP'd\SPSP R2R R{7SEPY4SP4RERnT> R+T? R2RT RTRRRR /uRp{?{#\EP!R4KRp{?{EGKRp{?{ii;i \*dE0L^i;i \*dE.Li;i \*dE.Li;iuup+i E\EPd?pXPWS+EPEP\T434Rp?E'K"Rp?ii;iuuppi \*dE#L*i;iuup+i \*EdpERT ER\T4 2oE\ERS 24M/ E\E\3d\6EP S4Mi;iSP'd\EP!ER4Rp\\3T 4^, ERER4EF(p.T T.,p/\T/\4'gEMT/PcR4R/8XdK>T/PcR4R-8XdT/PcR.4'dT T.^,RUu0uF<p\T\4'gKXPcR4R/8XgK3XR0,kK> MuupippT/R.,FWo+S+'d\S+\4'gK#S+R4,X9gK3RR/R0S+R4,RERS 2/pT PWT4KY R pM TSP.^, 8d#ERS 2pT PWRR-RT/4Rp?E K;Rp?ERKWRp?ii;i \*d#p\6PmERT4Rp?ELRp?ii;i \*dELi;i \*dELi;i \*d#p\6PmERT4Rp?X#Rp?ii;i(a Run a complete conversation with tool calling until completion. Args: user_message (str): The user's message/question system_message (str): Custom system message (optional, overrides ephemeral_system_prompt if provided) conversation_history (List[Dict]): Previous conversation messages (optional) task_id (str): Unique identifier for this task to isolate VMs between concurrent tasks (optional, auto-generated if not provided) stream_callback: Optional callback invoked with each text delta during streaming. Used by the TTS pipeline to start audio generation before the full response. When None (default), API calls use the standard non-streaming path. persist_user_message: Optional clean user message to store in transcripts/history when user_message contains API-only synthetic prefixes. or queuing follow-up prefetch work. Returns: Dict: Complete conversation result with final response and message history NFrqu~🔌 Detected stale connections from a previous provider issue — cleaned up automatically. Proceeding with fresh connection.:NPNrrrnzPconversation turn: session=%s model=%s provider=%s platform=%s history=%d msg=%rrrrTrrmru💬 Starting conversation: 'rrrEr=) invoke_hookon_session_startra)rSrBraz on_session_start hook failed: %sz*Session DB update_system_prompt failed: %s)r=rzDPreflight compression: ~%s tokens >= %s threshold (model %s, ctx %s)ru📦 Preflight compression: ~z tokens >= z threshold)rFr\ pre_llm_call)rSrrH is_first_turnrBrarr9zpre_llm_call hook failed: %su2 ⚡ Breaking out of tool loop due to interrupt...zstarting API call #u% ⚠️ Iteration budget exhausted (ruz iterations used)rrrrrarr]rz&step_callback error (iteration %s): %sryr4r5rEr) cache_ttlnative_anthropicc3J"TFp\\V44xK R#5irUrr s& rEr+AIAgent.run_conversation..sD|c#c(mm|ru🔄 Making API call #u 📊 Request size: z messages, ~z tokens (~z chars)u 🔧 Available tools: r.zAPI Request - Model: z , Messages: z , Tools: zLast message role: zTotal message size: ~z tokensrdrpr pre_api_request) r\rSrarBr<r1r=r[r; tool_countapprox_input_tokensrequest_char_countr^HERMES_DUMP_REQUESTS preflightrc<S'dSPR4RoSP'dSPR4R#R#r6)rdrW)rCthinking_spinnersrE _stop_spinner/AIAgent.run_conversation.._stop_spinners9+,11"5/3,111 22262rHrr%)ru⏱️ API call completed in r<r=rBzN/AzAPI Response received - Model: z , Usage: r rzresponse is Nonezresponse.output is not a listr^rzeCodex response.output is empty after stream backfill (status=%s, incomplete_details=%s, model=%s). %sz api_mode=rzresponse.output is emptyzresponse.content is not a listzresponse.content is emptyrz#response has no 'choices' attributezresponse.choices is Nonezresponse.choices is emptyu(´;ω;`) oops, retrying...u<⚠️ Empty/malformed response — switching to fallback...Unknownrmetadatarxrzmodel=rrz*Response attributes for invalid response: u&⚠️ Invalid API response (attempt z): rru 🏢 Provider: u 📝 Provider message: u ⏱️ Response time: z/s (fast response often indicates rate limiting)u⚠️ Max retries (u.) for invalid responses — trying fallback...u❌ Max retries (z,) exceeded for invalid responses. Giving up.zInvalid API response after z retries.rr api_callszOInvalid API response shape. Likely rate limited or malformed provider response.reu⏳ Retrying in z/s (extended backoff for possible rate limit)...zInvalid API response (retry z | Provider: u3⚡ Interrupt detected during retry wait, aborting.rzAOperation interrupted: retrying API call after rate limit (retry r+ interruptedrrr_rLend_turnrr^ stop_sequenceuQ⚠️ Response truncated (finish_reason='length') - model hit max output tokensrorrzModel used all output tokens on reasoning with none left for the response. Try lowering reasoning effort or increasing max_tokens.uV💭 Reasoning exhausted the output token budget — no visible response was produced.u⚠️ **Thinking Budget Exhausted** The model used all its output tokens on reasoning and had none left for the actual response. To fix this: → Lower reasoning effort: `/thinkon low` or `/thinkon minimal` → Increase the output token limit: set `model.max_tokens` in config.yamlpartialu↻ Requesting continuation (z/3)...z[System: Your previous response was truncated by the output length limit. Continue exactly where you left off. Do not restart or repeat prior text. Finish the answer directly.]z9Response remained truncated after 3 continuation attemptsu3 ⏪ Rolling back to last complete assistant turnz-Response truncated due to output length limitu-❌ First response truncated - cannot recoverz3First response truncated due to output length limitr rcompletion_tokensrru💾 Cached context length: z tokens for z cache=rz.0fz%)zHAPI call #%d: model=%s provider=%s in=%d out=%d total=%d latency=%.1fs%sr;)r<r1r;includedsubscription_included) input_tokens output_tokenscache_read_tokenscache_write_tokensreasoning_tokensestimated_cost_usd cost_status cost_sourcebilling_providerbilling_base_url billing_moderBzToken usage: prompt=z , completion=z, total=cache_read_input_tokenscache_creation_input_tokensprompt_tokens_details cached_tokensru 💾 Cache: z tokens (z% hit, z written)z API call #z completedu ⚡ Interrupted during API call.z3Operation interrupted: waiting for model response (r6z s elapsed).u(╥_╥) error, retrying..._surrogate_sanitizeduH⚠️ Stripped invalid surrogate characters from messages. Retrying...r)rrBr@rrrFu8🔐 Codex auth refreshed after 401. Retrying request...r u<🔐 Nous agent key refreshed after 401. Retrying request...r#ruC🔐 Anthropic credentials refreshed after 401. Retrying request...zBearer (OAuth/setup-token)zx-api-key (API key)u-🔐 Anthropic 401 — authentication failed.z Auth method: z Token prefix: rz Token: (empty or short)z Troubleshooting:)display_hermes_homeu" • Check ANTHROPIC_TOKEN in z+/.env for Hermes-managed OAuth/setup tokensu$ • Check ANTHROPIC_API_KEY in z)/.env for API keys or legacy token valuesuL • For API keys: verify at https://console.anthropic.com/settings/keysuD • For Claude Code: run 'claude /login' to refresh, then retryu? • Clear stale keys: hermes config set ANTHROPIC_TOKEN ""u? • Legacy cleanup: hermes config set ANTHROPIC_API_KEY ""z;API call failed (attempt %s/%s) error_type=%s %s summary=%sr<r1z [HTTP ru!⚠️ API call failed (attempt u 🔌 Provider: z Model: u 🌐 Endpoint: u 📝 Error: irru 📋 Details: u ⏱️ Elapsed: z s Context: z msgs, ~u?⚡ Interrupt detected during error handling, aborting retries.z+Operation interrupted: handling API error (r^rEz extra usagez long contextsonneti@ uO⚠️ Anthropic long-context tier requires extra usage — reducing context: ru🗜️ Context reduced to z tokens (was z), retrying...z rate limitztoo many requests rate_limitz usage limitquotau9⚠️ Rate limited — switching to fallback provider...request entity too largezpayload too largezerror code: 413u❌ Max compression attempts (z&) reached for payload-too-large error.uR 💡 Try /new to start a fresh conversation, or /compress to retry compression.z413 compression failed after z attempts.z5Request payload too large: max compression attempts (z ) reached.u@⚠️ Request payload too large (413) — compression attempt u🗜️ Compressed z messages, retrying...u2❌ Payload too large and cannot compress further.z/413 payload too large. Cannot compress further.z9Request payload too large (413). Cannot compress further.c3,<"TF qS9xK R#5irUrdrrrs& rErrs2U&I2EUrircrrKu)⚠️ Generic 400 with large session (~z tokens, u1 msgs) — treating as probable context overflow.zserver disconnectedzpeer closed connectiong333333?u1⚠️ Server disconnected with large session (~uD msgs) — treating as context-length error, attempting compression.u)⚠️ Context limit detected from API: ru3⚠️ Context length exceeded — stepping down: uM⚠️ Context length exceeded at minimum tier — attempting compression...z!Context compression failed after z3Context length exceeded: max compression attempts (u🗜️ Context too large (~u tokens) — compressing (z)...u8❌ Context length exceeded and cannot compress further.u 💡 The conversation has accumulated too much content. Try /new to start fresh, or /compress to manually trigger compression.zContext length exceeded: z! tokens. Cannot compress further.zContext length exceeded (z" tokens). Cannot compress further.c3,<"TF qS9xK R#5irUrdrs& rErrp s%bE{AlubuEr unauthorized forbiddenu!⚠️ Non-retryable error (HTTP u) — trying fallback...non_retryable_client_error)rru❌ Non-retryable error (HTTP u%❌ Non-retryable client error (HTTP z ). Aborting. permissionuK 💡 Codex OAuth token was rejected (HTTP 401). Your token may have beenz? refreshed by another client (Codex CLI, VS Code). To fix:z? 1. Run `codex` in your terminal to generate fresh tokens.z3 2. Then run `hermes auth` to re-authenticate.u9 💡 Your API key was rejected by the provider. Check:u- • Is the key valid? Run: hermes setupu+ • Does your account have access to rDrwu? • Check credits: https://openrouter.ai/settings/creditsu6 💡 This type of error won't be fixed by retrying.zNon-retryable client error: ruU⚠️ Skipping session persistence for large failed session to prevent growth loop.)rru") exhausted — trying fallback...u❌ Rate limited after u retries — u❌ API failed after u 💀 Final error: c3,<"TF qS9xK R#5irUrd)rr|rs& rErr s$=qN=ru 💡 The provider's stream connection keeps dropping. This often happens when the model tries to write a very large file in a single tool call.z~ Try asking the model to use execute_code with Python's open() for large files, or to write the file in smaller sections.zP%sAPI call failed after %s retries. %s | provider=%s model=%s msgs=%s tokens=~%smax_retries_exhaustedzAPI call failed after z retries: u The provider's stream connection keeps dropping — this often happens when generating very large tool call responses (e.g. write_file with long content). Try asking me to use execute_code with Python's open() for large files, or to write in smaller sections.rrrrru#⏱️ Rate limit reached. Waiting zs before retry (attempt z s (attempt z4Retrying API call in %ss (attempt %s/%s) %s error=%szr _thinkingzreasoning.availabler_incomplete_scratchpad_retriesuL⚠️ Incomplete detected (opened but never closed)u🔄 Retrying API call (z/2)...uA❌ Max retries (2) for incomplete scratchpad. Saving as partial.z/Incomplete REASONING_SCRATCHPAD after 2 retries_codex_incomplete_retriesru0↻ Codex response incomplete; continuing turn (z/3)z@Codex response remained incomplete after 3 continuation attemptsu🔧 Processing z tool call(s)...z Tool call: z with args: ru🔧 Auto-repaired tool name: 'z' -> '_invalid_tool_retriesu⚠️ Unknown tool 'u2' — sending error to model for self-correction (uI❌ Max retries (3) for invalid tool calls exceeded. Stopping as partial.z#Model generated invalid tool call: zTool 'z#' does not exist. Available tools: zZSkipped: another tool call in this turn used an invalid name. Please retry this tool call.rgu1⚠️ Invalid JSON in tool call arguments for 'r%u;⚠️ Injecting recovery tool results for invalid JSON...c3f<"TF&wrVSPP8XgK"VxK( R#5irUr)rrrrs& rErrX"s,.h=NTQRSWYWbWbWgWgRgqq=Ns1 1zError: Invalid JSON arguments. z_. For tools with no required parameters, use an empty object: {}. Please retry with valid JSON.z;Skipped: other tool call in this response had invalid JSON.c3V<"TFpVPPS9xK R#5irUr)rr_HOUSEKEEPING_TOOLSs& rErr"s(0&BKK,,0CC&Bs&)u ┊ 💬 execute_coder_last_content_with_toolsuOEmpty follow-up after tool calls — using prior turn content as final responsez Calling the z toolz(empty)uAℹ️ Reasoning-only response (no visible content). Reasoning: u1ℹ️ Empty response (no content or reasoning)._empty_content_retries)rrrzr[System: Continue now. Execute the required tool calls and only send your final answer after completing the task.]u"🎉 Conversation completed after z OpenAI-compatible API call(s)z)Error during OpenAI-compatible API call #u❌ zDetailed error information:zError executing tool: z0I apologize, but I encountered repeated errors: post_llm_call)rSrassistant_responserHrBrazpost_llm_call hook failed: %slast_reasoningresponse_previewed_response_was_previewedrrrrrrrrinterrupt_message)rbrcrdrd)rSrrrBrazon_session_end hook failed: %s)brainsparklepulsemoonstarr>rLr;) zcontext lengthz context sizezmaximum contextz token limitztoo many tokenszreduce the lengthzexceeds the limitzcontext windowrzprompt is too longzprompt exceeds max length) ReadErrorrServerDisconnectedError>rrE)rr) zerror code: 401zerror code: 403zerror code: 404zerror code: 422zis not a valid modelz invalid modelzmodel not foundzinvalid api keyinvalid_api_keyauthenticationrrz not found)rFi)rrrrrr)post_api_request>rrryrx(r|rrOrPrrrrr8r9r_invalid_json_retriesrrrrrrr=rrrr~rCrerQrrrrSrBr<rarrrH has_itemsrorfrMr4rJrOrrIrr?rB get_sessionrrhermes_cli.pluginsrr`r rrrdrcrrr!rrsrrrrrrrrMrS prefetch_allrrAnew_turnrrrRrrrrZr,rmrarPrrrrrrJr`rr r(r rrrrLrRrSr3KAWAII_THINKINGTHINKING_VERBSrWrrrrrHrrrtrJr1r^r<r2rrrrfrdr*r rr0r/rrrrvarsr6rrrrr stop_reasonrErr_rrrr>rrrr2rrrupdate_from_responserr$rrgrhrirjrkrrlrmrrnrrorr1 amount_usdrprkr^rqrrrupdate_token_countsreUnicodeEncodeErrorrrrKrr*r'r"rr/r#r\rrrer7rrrrr has_availablerr#r"rNrr rr}rr!rrrrTrrrr9rrarrr5rrrnextrr frozensetallr[rrrrr rrrPr rBrJr/rM exceptionrrrsync_allqueue_prefetch_allr)rCrrvrHr\rrr _msg_previewroriginal_user_message_should_review_memoryuser_msgcurrent_turn_user_idx stored_prompt session_row _invoke_hookr)ractive_system_prompt_preflight_tokens_pass _orig_len_plugin_user_context _pre_results _ctx_partsr4r[rrcodex_ack_continuationslength_continue_retriestruncated_response_prefixcompression_attempts_ext_prefetch_cache_query prev_tools_idx_m _fwd_start_results_by_id_tm_tcidr _step_errrGrrr _injections_fenced_baserMrrr total_charsrFrgverbr/api_start_timerrprimary_recovery_attemptedmax_compression_attemptscodex_auth_retry_attemptedanthropic_auth_retry_attemptednous_auth_retry_attemptedrB restart_with_compressed_messages restart_with_length_continuationrErrr_use_streamingrr resp_modelresponse_invalid error_details output_items _resp_status_resp_incompletecontent_blocksrxr(r) resp_attrscleaned_provider_errorr sleep_endr^rincomplete_reasonstop_reason_map_trunc_content _trunc_msg _text_parts_blk_thinking_exhausted_exhaust_error_exhaust_responser< interim_msg continue_msgpartial_responserolled_back_messagescanonical_usagerrr usage_dictctx _cache_pct cost_resultr)writtendetailsr~hit_pct api_elapsedrrr@recovered_with_poolrr auth_method_dhh_fn_dhh elapsed_timer_error_summary _provider_model_status_code_str _err_body _err_body_str_is_long_context_tier_error _reduced_ctxrVold_ctxr!is_rate_limitedrpool_may_recoveris_payload_too_largeis_context_length_errorrWrRis_generic_error_is_server_disconnect _is_large parsed_limitnew_ctx_RETRYABLE_STATUS_CODESis_local_validation_error _err_message_is_generic_400is_client_status_erroris_client_error_final_summary_is_stream_drop_final_response _retry_after _resp_headers_ra_rawrrrr_assistant_tool_calls_assistant_text _think_text first_lineinterim_has_contentinterim_has_reasoninginterim_has_codex_reasoninglast_msglast_codex_itemsinterim_codex_itemsduplicate_interimrepairedinvalid_tool_callsr invalid_nameinvalid_previewrrinvalid_json_argsrArrecovery_assistantrar invalid_nameserr tool_result turn_content_all_housekeepingclean _tc_names _compressor _real_tokens_compaction_progressfallbackrrrreasoning_preview final_msgpending_handledr answered_idserr_msgrrr]_should_review_skillsrrrsf&&&&&& ` @@@rEruAIAgent.run_conversationsiX<  %%' lC ( (/ =L *C 0 0#78L#M !0)-&.B+#88s4::<'8&'"%&"&'#./+)*&(,%#( $)! ==0 0 1133%%&!00C0C D7:,6G"6L S)E1R^ #++D#6  ^ OO % %vtzz4==3M3MI MM & &Y,@,F,FB(G   2F4,-2  / 9 (8(8(B(B(D(D  $ $%9 : "9M8X 4^j !&  ' '! + 5 55&&&  $ $ ) $''4+F+FF(,%+,(FI|<! #H  1)>&   <\#=N">t"OK"(3(H(P(PD .;*.2-F-F~-V* LN *#'??"jj!(z4!@!F!FB ###V((==dootOiOij $99  $ $ $H  7 7 G G"&"9"9"H"H!IKL!MM !>288bjj((D!  !D$;$;$L$LL Z(+..??BJJ..==a@ $$78I!7LM"55FFqIU #1XE #H I595K5K @Q 16L62H28} 1 ,0((E &:&@&@b"jj00D)% )4+B+B+S+SS+&F " @ F'??2%)(^#'(<#==jj z48>>BL%'J!a&&155+;+;%%c!I,&783''AGGII%%a( " '-{{:'>$  "#"#$&!  !     2<=RTW2X2X.^`&*&:&:&G&G&O&U&USU#t222t7L7L7V7VYZ7Z  ) ) +(((" $$%Z[ a N#1D  #6~6F!G H((0022$$'MdNcNcNhNhMiijkolAlAlKlKkLL]&^_!!-f!#J$-hx.@$Ab66&>[8RVVL=Q=Q),X)=J-/N'/ '<#&776?f#<$)(+(?#(5N OPS__ $$$"2Q )$*?*? @HC '' S(8#((*E!A'''<\UYUdUdx|yFyFJ^y^ `  66|DLD|DDK'1,M $ ??? r$//!22HHXXYZ^ZmZmYnnqrs 00Fs?3355$:Z:Z:\:\$*==1^#_L'4vQtfC5HWcnrn|n|'}$$**,### 5djj\cRZm_\ey}zDzDzDfijnjtjtfuJKfLMN 3HHRL4HZ`3abc 5mA5FgNO!YY[NKK). &'( $', &+0 *&+ %#O/4 ,/4 ,"MH +z(!%!7!7 !EJ}}(99%)%E%Ej_d%E%e R$-$5'+'<'<"%)]]%8%8b"&**%)]]%)]]%)]]+9*-l*;'*4::+;+;'<0=/:'+&''=>>44Z 4T7&*N55777%gdHd&CTJJ-2N%#'#I#I&}$J$$(#?#? #K#'99;#?L((--b1+/(---..r2??? '88VWcdgVhhi%jk+++JRWXw%FX]  (G |S\ovwBIpJpJ]e]k]kPU]V'WX(-$$&M}}(99LTL`wx4'Hfj #+/3,)001CD!+L$!?!?/3,)001PQ .!3,38Xt+LL/6xAUW[/\,#OO!S ,.> ''4 @"+DMM?*T]]O T 04,)001KL*>>OWOc9d)Kim#+/3,)001CD!+ND!A!A/3,)001QR 0A5/3,)001LM#+78Y3O3OS[ScScSkors{tDtDpEIJpJ/3,'/ - 4 45G H%,Xy%A%A - 4 45Z [!)!1!1!9 - 4 45O P - 4 45P Q''+,112OP/3,111 2226$q(  //#d6J6J2KK --.lm6688*+K$%. (1 #'(B(Bx~~~(+HNN(;I&x~~zBBx~~G^G^G^080G0G0K0KO]f0g %'(I*F*F8K[K[K[(+H,<,<(=I)I5(wxY`GaGafnftftft.4X^^4D,EM)I5(FJ8nFZFZF\)vF\dadedpdpqtdu/!SVD\/F\J)v#333 ' 0Z[eZf.g h '88^_j^kklmxlyy|~B~G~GHU~V}W&X`d e '88J=/%Zbf g151J1J91U. '88RSiRj%ksw x '88RS_`cRdeT&U]a b&+5 --0D[MQ/AB#::<<./ ( --0A+Nz.{|#MMT__,==XYdXeen*op 11(Q *H +U +^ ')z ($ $%(Q;?-C(Dc$J  '88H TC&DLP Q*F{mSTU`Taadeieneno|e}d~LMZL[)\]%)IIK)$; "iikI5#888 $ /@@s-t}A !B $ 5 5h U $ 4 4 6$48y{FzGGHITHUUW7X$.$/$/$14 ("!"!JJsO }}(99!(8T!B-4X?SUY-Z*,0)%&8$??0B0F0Fx0P-078JHVZ0[-!\16GKj6j,4M,2M*>>+5vz>IPQY[dIeIejrjzjzjz)9)9!)<)D)DBFJU_WZD-QeiN!]].BB*,K(/)R(H#*4#>&#H$/$6$6wtVR7P$Q)IHSTYY{-CX\N+$6XX$($G$G$W W/4/4,t3, /!9+ !LL#'??"34D!E&*)!H.!889JK 11(Q 02C *H +^ +U )4 ' $ ==,>>080@0@0C0K0K-#4#?#?#? 71 < 7.2.K.KL]_l.m ( <#4#<#<#<$=ARAZAZ$Z$=#:Q#>$(LL+/??*;<,,C+DF)L%& )/(1-i4&L%-OOL$A=ED$:$($:$:8$DGK$D$)373K3KLe3f3l3l3n 0 $ < <=N O $ 5 5h U$46F6N6N$$.$/$/$-t$+-h ("!"x=1, LLDOO+<'>@\^cdd 3DJJ s S $ 0 0DOO3DD`adef`ggstxt~t~s2A!BFKD33CQVD33N22mC266:KK611\A1..!3.11_5Q5QQ122o6S6SS266/:[:[[677?;];]]7559Y9YY5&( *<<<+2?3T3T2UUVWdVeeghkl{mNmNiNO\i\]`haac*dJ f 22DJJ @Z@ZQZ)+3E3E03>3E3E0 +++% $ 0 0 D D$(OO1@1M1M2A2O2O6E6W6W7F7Y7Y5D5U5U'2'='='I8=[=S=S7TOS0;0B0B0;0B0B59]]59]]'2'9'9Z'G2IMQ*.**!E!"( ///#MM,@OA\]^@__lmwyLnMNOmPPXYcdrYstuXv+wx 333#}}0DD)0AZ\])^)c)cbc*1(..B_ab*c*h*hgh+2(..BY[_*`V]/1)M)R)RQRcd\c'';OQR*S*X*XWXij%/%@FAG!v' ? %(59IIe4D)147H)1N,34E|UY,Z,`,`^`)&7&?&?&E&E2O  1$(??#8#8b"&!4!4"  #jj  "& "&"&(6&2'4'*,&7(/x$'G#FFxP14O0D 366K2L!,%,,,T___+++ '88HIZIbIbHc%de '88HIZIbIbcgIhHisvxIxQxQtRUXtXjo^`ja&bc&---$2M2M2M"3";";"A"A"CK"$&&G[#eg EP!2!24!8!;C!@UWJ!gd4Eq&IA&M! 77 ZP%! 778M{\ghl\most -->-F-F-L-L"MM"4)IJJ>?;771<7LLDOO#45A"BC::a? '88PQUQtQtPuu{%|}  '88y%zCG H>?;/3/V/VW_/`,445FG--hM-d&(<''%t#%V  4!ABB:;D7==$55-<:W"4)DEE9:622a72"&"?"?@QS`"aK*.  0J0P0Pb/W/W/Y*Z'^hitixixzEjFHK_L_LDb1Q1W1W1Y,ZRW)26{G^7_2`/*.CGbGb3;8B< U__gimTnTn8<<8O+Ptx(.9oo>U.V+&x6HH ( V 4 CHH ( _ = MHH"*i!8!>!>BKOOT]D^DdDdbd eHH"*k!:!@!@bkooVaFbFhFhfh i HH !14G G * 1$OOK8559# LLDOO+<??56D2%///??? '88HM^MiMiIjHkk{%|}+++"3">">B#MMK 8H8H7IVXVaVaVkVklpVqUrru*vw#? 0::;;++43H3HH'+'='=bkk>N>N'OH'x %(99XY[YdYdYiYiXjjpqypzz{&| }3; 0 ;4E3O3O*3OR;;++43H3HH) ((3O'**)&t-DEE9:D622a72%)IIfT5J5J.K$L '9!'< GJ">B!{{//t7L7LL,22;;3C3C2DDghqgr*s+G$OO & . )7- #?!t%<==562)+%/::!{{44%dT4L9948JJt4DBKK1$+JtS4I4I47IBKK1#%;;#8#8D#4::<<48BKK1$Q JJt,;")(22a72/@/C, 9 '88ijsittwyBxC&DE559 LLDOO+<?BS,SARgdATARM,S&7&B&B#%;;#3#3}#D*..h=N.h*hC*I#OH)I%0 3pK ($*F$2BEE$-{1"!#'C%23D.483P3P)444%0483O3O)444%0%)$A$ABSUb$cM $5#<#<#B#BL#(K(KL(Y(Y8D5 /89/+-0C0&7&B&B0CCC0&7&B&B0-)-1K1K1M1M7;D4!___$($<$<\$J$P$P$RE$ $ {5'-B COOM2111! 66t<,,->]kl04D, =NZ>Z/Z,/47@]@]@]<@D9 778LkZ///K4O4OP\4]4]9=9O9O$*.*A*A*T*T$5:P:6"604,.6D***84&7%>%>%D%D"N >>~NN $+41KT#R#8"LL)z{<@D9:;D7%*3x=1+>6739=D6 ):: 1113a7 CC)5.<%-D 014/&*&C&CDUWc&d   4#F%!U( ! 519...x8 ./+0)B^)S46123/&*%=%=n%M%S%S%UN $ = =>OQ^ _IOOI.???((+MnM]]{)|}l  ! d11 1$$..!3$$..!3DOOO>t?T?T?Y?Y>ZZ[\`\q\q\{\{[|}NOP!88>RN#$.WW>DDWDW3W  hi@ $$%67 h= + EJ##!6'5)-h**$T:t<BBH%Cwwv+-#''+2F2F!$[!1&  n n        u   ;  !'$0I5"Q  TZZ        D55  T77  !?!?  !$"A"A  = =! " T77# $ !?!? D55 '$*A*ACWYZ"["`"`_` $"A"A 433 433/ 2(-$ 4222*.*A*AF& ' !%!&  & & *++t/I/II"d&;&;;$( !&'D #    N7L $$--.C^T$$778MN +3HLa --&*8n"7"7.$ B F  ??#'jj z48>>B   wE  h!,!LNN#EsKKL%V %QSTUUV~ @ NN93 ? ? @2  H*!fLL!I>[deefL%d*wv$-% $%4( '(--b1+/(---..r2"&))+">KLLDOO#44T!U]aLb))(I"&K'Z[fgjZkkv%wN O ('(--.LM+/(---..r2")-?@@QUWmotIuIu4818BB LL#'??"33{ |&*)%#*)]D"IK$($C$CI$NM;?;];]$/(7&3<^<8' +  ):: MM^;'3. :592EEDEQQ LLDOO+<?? > >9=6KIIKK!T__$55x"yz$"55FUVYFZFZ&B`u  11^_` 11A+OPTW\_`c\dgi\i 11B3s8*CPrvsBsBrCC]p^_ 11DEFS&y 11STXSYZEFG 11UVZU[\EFG 11}~ 11uvw 11rst 11rst1$K#'99;#?L!%i!9!9J #I 4 4 6I%)%>%>y%INNNU##"002& !(j) DI#D*i@E$T7I>FCN Q'?TV$LLDOO#44UVaUbbcdocppst~sAQ@R"S[_L`LLDOO#44FykQZ[aZb!ckoLpLLDOO#44Fug!NVZL[LLDOO#4ONCS!T\`La"{S'8$+Ivt$D @IIt(J6 EJJA LL#'??"34N#*1+U<2B'!K'+ )-1,/3KK+.x=L=A=S=S (.;(9>T>:H&: #8}|;w?U $ 1 1&A,qAQR,,3A;n%F!"!% 1 CG @ %$s*00'9400.);00(9400)I5 00 #i/ $'4+?+?#dFZFZB[+[ $44+/t+;+T+T@R@R@T(/ --.ij#::<<./ ($s*::5B::.);::- 9 ),+,1,/2JJ LLDOO+<QVWZ[cWdVee{.|} JJqM?C<! LLDOO+<QRI!J'+ )3;1Y>mm79Dmm)-ll. 1&-gd 7 $ '+&78))6q(93|CTBUV`%a+/ !-!"/.%)%<%< ",";";(Fi'P 'L7,B&2G LLDOO+<d:eJ79=J6 EI , H H1HEJA!LLDOO+<+"9z9.EFJJ *96H II.!( 64 @ F FBIU_`ikoUpUpIMM'2$>$B$B9b$QvxL'2c'9'k'kl>P>P>R>X>X>Z^k>kO-7 S-I.n.ncU`NfNfcfNf.n.nkvVlV.n.n_n[n*'@((DZ((^a^abEb^a^a^abEb_'8'8 !87 $')),Mk]Zr*st6688*+K$44&/KS\5))<[M#88CDF '88]^i]jjv%w@D E '88J9+U^_e^f%gos t '88J5'%RZ^ _&*4)8SWbfoWosDMtM(N:{c?Q $ /@AL.MUY !Z $ /@@.AIM !N $ /@@.AIM !N $ /@@s-t}A !B $ /@@y-zCG !H $ /@@m-nvz { $ /@@klrksst-u~B !C#/3u:3C3C3E#E$(LLDOO3DED2EMQL%R LLDOO+<a>a%;K?b??:>6*+K$)),@ Mo*pq6688*+K$)-)B)B9)M* --0G }Tabpaq.rs --0Ek]R_`n_o.pq '88MnM]%^fj k!( =$ GG #$=$$=$!(+ LL#'??"34>!?'+ )!LL#'??"34,!-'+ ) n OO[.%vs!)$(!)0< #a;FVXZB[I&)),OPY{Zrs~BCtCsDDEFQERRV+WX)),"T%8%81%<<'WXaWb%cNOOV[)^$TU =[2 r E>DD E~    . B NN;S A A  Bs )Cw?Cw%,Cw-Cw-*Cw-2Cw?Cw?"0Cx.%BCy.6Cy)CyCyCy";Cz Cz /Cz#>Cz#A Cz#&$Cz# Cz'6CzCz#5C{=C{1C{AC{@C{@0AC{=A3,C{=B AC{=C)$C{=D"C{=D13C{=E%C{=E-I4C{=O"C{=O*$C{=PA'C{=Q7C{=Q< C{=R$C{=R-AC{=S>0C{=T/$C{=U$C{=U9#C{=VC{=V;C{=WC{%W;C{%XDC{=\$C{=\)AC{=^B=C{=aAC{=bC{=b2D.C{=g!(C{=h AC{=i'C{=i9C{=jC{=j6 C{=kAC{=lAC{=m?C{=nA.C{=pA C{=q C{=q*A1C{=s?C{=t&C{=uI0C{=~4C{=~=E\'^<E\'_(E\'_?E\'` E\'` E\'`# E\'`1E\'aB"E\'c#E\,c)BE\'e8BE\'g=E\,h E\'hE\'h(!E\'i 6E\'j:E\'j<\:E_\=E\>\>E_] E]] E_]E]]E_] E]"]E_]!E]"]"E_]*E^?^2E^:^3E_^:E^?^? E__ E__E__E__E__ Eg=_+Eg8_?E``Eg8`)E`<`9Eg8`;E`<`<Eg8aB#Eg8c5Eg8dEed Eed8 Eee?Eg8f A!Eg8g8Eg=h Eh-h Eh(h(Eh-h0 Eh?h>Eh?i EiiEii EjiEi<i<Ejc<<V^8dQhRS[RS[S[,RS[/#)rqrrrr)rPrrl)rsrns"rErtr.$s( ( (C ((82D (PS (rHc 8VPWR7pVR,#)z Simple chat interface that returns just the final response. Args: message (str): User message stream_callback: Optional callback invoked with each text delta during streaming. Returns: str: Final assistant response )rr)ru)rCrrr]s&&& rErY AIAgent.chat$s#&&w&P&''rH)rr r#r$r rrr0r8r rr r r?rAr&rrrVrrrrrrvrrr1r/r0r2rrrr rr!rPrrrrJrDrrKrNrSrMrJrrCrrrtrrr rBr>rarrrerrHrbrOr rLrfr?r>r;r=rr1rYr%rdrcrFrErJrerLrKr;rCr^rBrirjrar`r<rRrQrPrMrNrOrIrXr_rGrjrmrnrhrrrqrprSrkr=rlrgror7rirbr]rZr[rWrVrDr\rTrUrr4rH)rrrrU)FF>rrmrrrrYrJr>rrrrr)NNNNN)rerfrgrhrirr1setterrFrrrrrrrrrrrrr/rBrYr_rrrrrrrrrrr staticmethodrrrrrr2r6rrGrMrRr`rfrorsrrr rrrrrrrrrrr%r1rJrTrXr}rrrrr.rrwrrrrrrrrr*r/r4r>rKrPrfrrrsrrrrrr r rr0r;rCrKrtrgrfrrrrrrrrrr]rrrurYrkrlrms@rEr,r,s__>> %)!% &*'+"' % '+ #'+'+%)!,1(,+/(,+/&*'+%)"&*.&*$(+/15#(!!%.2)-$)(* % $iw w r,=\y v$*5**(&UU(CC 44vv % %%%.  EeEeP@@DB B H V V$ L L GhhT**$ K K.F.F`-->??0ccJ D D&&&&P))4>>@ P &* PPd@D@DD%V%VN ((   $"@))l)l)d++ !!abCCJ:GG"8 0!!*      :wwrWWr{# {{z''  b0b0H//  :*88t0" DDLWWGGyyvKgKgZT:!D!!F%%N = =JJ63& 37 3&3&jDD ;";"~     F">BF"F"Tx1x1x>>D#,-# KK^(11f*[*[X"YYTTl T TD,,@ttl6 2 2[[z]-]a]-r{]-]-~**.HHTVTVTpDTDTL 0%Y%YNUUnE$E$NH ( ( (rHr,cV^8dQhR\R\R\R\R\R\R\R\R \R \R \R \/ #) rqrrBr;r1 max_turnsrErF list_toolsrG save_sampleverboserK)rPrr)rss"rErtrt$sS/S/ S/ S/S/ S/  S/  S/S/S/S/S/S/S/rHc  \R4\RR4V'Ed_^RIHp Hp Hp^RIHpHp\R4\RS4\R4\RT4V!4p.p.p.pVP4FawppV!V4pV'gKVV3pVRU9dVPV4K6VRV9dVPV4KPVPV4Kc \R4VFVwppVR,'dRPVR,4MR p\R VR R VR , 24\RV 24KX \R4VFkwppVR,'dRPVR,4MR p\R VR R VR , 24\RV 24\RVR, 24Km \R4VF4wpp\R VR R VR , 24\RVR, 24K6 \R4V!4pVP4FiwppVR,'dRMRp\RV RV RVR , 24VR,'dKE\RRPVR,4 24Kk V !4p\R\V4 R 24\V4FpV !V4p\R!V R"V R#24K \R$4\R%4\R&4\R'4\R(4\R4\R)4\R*4\R4\R+4\R,4\R4\R-4\R.4R/#R/pR/p V'd=VPR04U!u.uFp!V!P4NK pp!\R1V 24V'd=VPR04U!u.uFp!V!P4NK p p!\R2V 24V'd"\R34\R44\R54\VVVVVV VV V R67 p"TfR8p$MTp$\R9T$ 24\RW4T"P#T$4p%\RW4\R:4\RR4\R;T%R<, 24\R=T%R>, 24\R?\T%R@,4 24T%RA,'d)\RB4\RX4\T%RA,4T 'd\%\&P(!44RC,p&RDT& RE2p'T"P+T%R@,T$T%R<,4p(RFT(RG\,P.!4P14RHTRz:J:J499T*%56PVL F4)3tM':&;< = N<.1 2 %d<&8%9: ; - 23+JD$ F4)3tM':&;< = %d<&8%9: ;, DE02)//1JD$";//UUF BvhavR](;'<= > $$*499T.5I+J*KLM 2'(  )#i.)9FG *I*95G GI;ggYa8 9+ &' +, bc ^_ `a d  -. ]^ d  $% ab d  67 VW!!4D4J4J34O P4Oq4O P '(='>?@5F5L5LS5Q!R5Q!'')5Q!R ()?(@AB /0 JK GH$24/#-    } b     | ,- / # #J /F / %& (O OF;/0 12 VK01 23 OCz 234 56  &' h f%&' %b) #I;e488 :   ;   Z 113 U  , Z   :osW== 5uQGH> 77HI J -.i!Q"S*  045h>= : 4QC8 9 9 :sTX!X 4X$Y :)X7#Y  X4X//X47 Y Y Y-Y((Y-__main__> read_filer web_searchr web_extract ha_get_state search_filesrxvision_analyzeha_list_entitiesha_list_services>rMr rL) NrNr NNFFFFr)riatexitr&rconcurrent.futuresrVrrrrrrerrrRrrxrrrweakreftypesrr8typingrrrrrrfirerpathlibr r\r hermes_cli.env_loaderr r__file__parent _project_env_loaded_env_paths _env_pathrr rrrrtools.terminal_toolrtools.interruptrrFtools.browser_toolrrrWragent.prompt_builderrrrrrrrrrr r!r"r#r$r%agent.context_compressorr&agent.subdirectory_hintsr'agent.prompt_cachingr(r)r*r+r,r-r.r/r0agent.usage_pricingr1r2rr3r4rQr5r[r6r7rwagent.trajectoryr8r9r:rutilsr;r<r>r|r~r rrrrUcompileVERBOSErrrrrrrrrrrrrrr*r,r FirerdrHrEr sJ*      8 $  ! ,, ,5 H~$$v- &<\Z&  :IF' KKIJ +;.1<  7<>}}}D 5.*.*b;)7)7\"9+.! " CD  JJ jj!45)X="? -. ZZ<II 0%J$- `wH(wH(tQS/l zIIdOrH