+ Wj Z^Rt^RIt^RItR]P 9d/^RIHt]P!4'd]P!4^RI t ^RI t ] P!]4t^RIt^RIt^RIt^RIt^RIt^RIt^RIHtHtHtHtHt^RIHt^RIHt^RIH t H!t!^R I"H#t#R R lt$R R lt%^RI&H't'^RI(H)t)^RI*H+t+H,t,]#!4t-])!]-]!].4P^R, R7t0]0Ft1]PeR]14K ]0'g]PeR4^RI3H4t4^RI5H6t6H7t7^RI8H9t:^RI;Ht>H?t?^RI@HAtA^RIBHCtC^RIDHEtE^RIFHGtG^RIHHItI^RIJHKtKHLtL^R IMHNtN^R!IOHPtP^R"IQHRtR^R#ISHTtT^R$IUHVtV^R%IWHXtX^R&IYHZtZ^R'I[H\t\^R(I]H^t^^R)I_H`taHbtc^R*IdHete^R+IfHgtg^R,IhHitjHktlHmtn^R-IoHptqHrtsHttt^R.IuHvtvHwtwHxtx^R/IyHztzH{t{^R0I|H}t}H~t~HtHt^t]EP!4tR1R2ltR3R4ltR5R6ltR7R8ltR9R:ltR;R<ltR=R>lt!R?R@]4t!RARB]C]E]G]I]K]N]P]R]T]V]X]Z]\]^4t0ROmt0RPmtRCtRDREltRFRGltRHRIltRQRJRKllt]RL8Xd^RMIHt]!]!]RN74hR# ]dt]PR8wdhRtAELRtAii;i)Ra!AIAgent: the tool-calling agent runner (conversation loop, tool execution, session lifecycle). 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") Nhermes_bootstrapzhermes_cli.main)_early_recovery)ListDictAnyOptionalCallable)datetime)Path)CLI_FAMILY_SOURCESsession_source_for)get_hermes_homecFV^8dQhR\R\\,/#)sourcereturn)strr)formats"=C:\Users\johnn\AppData\Local\hermes\hermes-agent\run_agent.py __annotate__r+s  C HSM cV\9gK\PPR4;'gRP 4P 4R9dR#\P !4# \dR#i;i)zcwd to stamp on a new session row (``hermes -c`` / ``--resume``), or None. Only local CLI sessions record one: gateway/cron/remote backends (non-"local" ``TERMINAL_ENV``) have no stable host cwd for the agent's tools. TERMINAL_ENVlocalN)r)r osenvirongetstriplowergetcwdOSError)rs&r_launch_cwd_for_sessionr"+sb ''BJJNN>,J,U,Ug+\+\+^+d+d+fn{+{yy{ sA.. A=<A=c>V^8dQhRRR\\,/#)ragentAIAgentrrr)rs"rrr9s hsmrcf\VRR4p\VRR4p\VRR4pV'gV'g V'gR#R\VRR4;'gRRTR\VR R4R \VR R4;'gR R VR\VRR4R\VRR4/p\VRR4'dVPVR&\VRR4pV'g^RIHpV!4pVR8XdRpV'dWTR&\ P !V4# \dRpL;i;i \dR#i;i)zGateway routing ``origin_json`` for a session row; None when the agent carries no gateway identity. Mirrors ``SessionSource.to_dict()`` so state.db consumers see the same fields ``record_gateway_session_peer`` writes. _chat_idN_gateway_session_key_user_idplatformrchat_id chat_name _chat_name chat_type _chat_typedmuser_id user_name _user_name thread_id _thread_id _user_id_alt user_id_alt _profile_nameget_active_profile_namedefaultprofile)getattrr7hermes_cli.profilesr; Exceptionjsondumps)r$r, session_keyr2originr=r;s& r_gateway_origin_jsonrE9s< eZ.G%!7>KeZ.G {gGE:t4::IwWUL$7geUacgFhFpFplp7K d)K[Zabgiuw{Z|F und++ % 2 2}e_d3G   C-/G i G#yzz&!! G  s$ D8D! DD! D0/D0)IterationBudget)load_hermes_dotenv)get_provider_request_timeoutget_provider_stale_timeoutz.env) hermes_home project_envz$Loaded environment variables from %sz7No .env file found. Using system environment variables.)get_toolset_for_tool) cleanup_vmget_active_env) set_interrupt)cleanup_browser)agent_connection_surfacescoped_connection_surface)is_trivial_prompt)ClientLifecycleMixin)StreamDeliveryMixin)StatusOutputMixin)ApiRequestHooksMixin)ApiErrorSummaryMixinis_provider_stream_parse_error)InterruptControlMixin)TurnExplainersMixin)ActivityTrackingMixin)RateLimitCreditsMixin)SessionPersistenceMixin)CompressionFacadeMixin)TurnFacadeMixin)VisionMessagePrepMixin)ReasoningParamsMixin)forwardforward_static)ActivityProvenance)is_local_endpoint)coalesce_tool_call_iddeterministic_call_iduniquify_tool_call_ids)"_derive_responses_function_call_id_split_responses_tool_id_summarize_user_message_for_log)ToolGuardrailDecisionappend_toolguard_guidancetoolguard_synthetic_result)record_guardrail_decisionrecord_guardrail_warnings)base_url_host_matchesbase_url_hostname env_float"model_forces_max_completion_tokensc(V^8dQhR\RR/#)rfnrN)r)rs"rrrs   t rc<V!V/VBR# \dR#i;i)zKRun one teardown step, swallowing any exception so sibling steps still run.N)r@)rwargskwargss&*,r_quietlyr{s&  DF    s  c4V^8dQhR\R\RR/#)renginehookrNrr)rs"rrrs&KKcKK$Krc\W4'gR#\W4!V/VBR# \d"p\P RY4Rp?R#Rp?ii;i)zTInvoke an optional context-engine lifecycle hook; failures are logged, never raised.Nz'context engine %s during transition: %s)hasattrr>r@loggerdebug)r}r~ryrzexcs&&*, r_call_engine_hookrsL 6 Kt.v. K >JJKs( AAAcFV^8dQhR\R\\,/#rvaluerrrint)rs"rrrs"ccc#crcp\V\4'd \V\4'g V^8dV#R#)zE``value`` when it is a real positive int (bools excluded), else None.N) isinstancerbool)rs&r _positive_intrs-uc**:eT3J3JuWXy5b^bbrctV^8dQhR\R\\\\3,,R\/#)rr$task_cfgr)rrdictrr)rs"rrrs3\\\xS#X/G\D\rcH^RIHpHpV!V4R8H;'d V!W4#)zaTrue when an automatic background review targets the managed local runtime under ``defer: auto``.) defer_modereview_targets_managed_localauto)agent.review_idle_queuerr)r$rrrs&& r_review_should_deferrs#P h 6 ) [ [.J5.[[rc0V^8dQhR\R\/#)rr$rr)rs"rrrs@@S@S@rcT\\VRR4;'g \V44#) session_idN)rr>id)r$s&r_review_queue_keyrs" wulD1>>RY ??rcJV^8dQhR\R\\,RR/#)rr$messagesrN)rrlist)rs"rrrs+XXcXXd^XPTXrc\aaa\SRR4oS'd\VVV3Rl4R#R#)zTell the context engine the session ended (flush DAG, close DBs) at the same lifecycle moment as the memory manager, so per-session engine state never leaks into the next session.context_compressorNcd<SPSP;'gRS;'g.4#)r)on_session_endr)r$r}rsr4_notify_context_engine_session_end..s'..u/?/?/E/E2x~~SUVr)r>r{)r$rr}sff@r"_notify_context_engine_session_endrs%U0$ 7F VWrc$V^8dQhR\/#rrr)rs"rrrsQQtQrcVRJ;'d5VP4;'d\VP44^8#)zWait for credential-pool rotation (True) or fall back to ``fallback_model`` (False) after a 429. Rotation only helps when the pool has somewhere to go; a single-credential pool would retry the same quota. See issues #11314 and #13636. N) has_availablelenentries)pools&r!_pool_may_recover_from_rate_limitrs8 t  P P 2 2 4 P PT\\^9Lq9PPrcRaa]tRt^toRtRRRRRR/V3RlV3RllltRtVtV;t#) _StreamErrorEventzProvider error synthesized from a standalone Responses ``type=error`` SSE frame (Codex-style backends). Gives ``_summarize_api_error`` / the entitlement detector the familiar ``.body`` / ``.status_code`` shape. codeNparam status_codec f<V^8dQhRS[RS[S[,RS[S[,RS[S[,RR/#)rmessagerrrrN)rrr)r __classdict__s"rr_StreamErrorEvent.__annotate__sFssshsms8TW=s&sms7;src <\SV`V4WW43wVnVnVnVnRRVRVRVRR//VnR#)errorrrrtypeN)super__init__rrrrbody)selfrrrr __class__s&&$$$rr_StreamErrorEvent.__init__sM !@Gu@a= diT-=%,y'64QXZ_agip.q$r r)rrrrr) __name__ __module__ __qualname____firstlineno____doc__r__static_attributes____classdictcell__ __classcell__)rrs@@rrrs6 sds[_s.2sssrrcV a]tRt^toRtRt]V3RlRl4t]PV3RlRl4tRRRRRRRRR] PRRRR R R R R^dRRRRRR RRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRRR R R R RRRRRRR ^R ^ R RRRR RR3VV3R lR llt Rt V3RlRlt V3RlRltRRRRRRRR RR/V3RlRlltRV3RlRllt]V3RlRl4t]V3RlR l4tRV3R!lR"llt]!R#R$4tRR%R /V3R&lR'lllt]!R(R)4t]!R(R*4t]!R(R+4tV3R,lR-lt]!R(R.4t]!R(R/4tV3R0lR1ltV3R2lR3lt ]!R4R54t!]!R4R64t"V3R7lR8lt#RV3R9lR:llt$RV3R;lR<llt%RV3R=lR>llt&V3R?lR@lt'V3RAlRBlt(V3RClRDlt)V3RElRFlt*RV3RGlRHllt+V3RIlRJlt,V3RKlRLlt-V3RMlRNlt.V3ROlRPlt/]!R#RQ4t0]!R#RR4t1]V3RSlRTl4t2]RUR/V3RVlRWll4t3V3RXlRYlt4]V3RZlR[l4t5V3R\lR]lt6]!R#R^4t7]V3R_lR`l4t8V3RalRblt9RV3RclRdllt:]!R#Re4t;]!R#Rf4t<]!RgRh4t=^RiI>H?t?H@t@HAtA]!RjRk4tBRV3RllRmlltCRV3RnlRolltD^tEV3RplRqltF]!RjRr4tG]!R#Rs4tHV3RtlRultIRV3RvlRwlltJRV3RxlRylltKRzR/V3R{lR|lltLV3R}lR~ltMV3RlRltNV3RlRltOV3RlRltPV3RlRltQV3RlRltR]V3RlRl4tSV3RlRltTV3RlRltUV3RlRltV]WV3RlRl4tX]WV3RlRl4tY]V3RlRl4tZ]!RR4t[]!]\4t]]V3RlRl4t^]_!0Rm4t`]!R#R4ta]RR/V3RlRll4tb]V3RlRl4tc]!R#R4td]V3RlRl4te]V3RlRl4tf]!]g4th]!R#R4ti]!RR4tj]!]k4tl]!]m4tn]!]o4tp]!RgR4tq]!RgR4tr]!RgR4tsV3RlRltt]!R#R4tu]!R#R4tv]!RgR4twV3RlRltxV3RlRltyRR/V3RlRlltzV3RlRlt{V3RlRlt|RV3RlRllt}V3RlRlt~]!R#R4t]RV3RlRll4t]!RR4t]!RR4t]!RgR4tV3RlRltRtVtR#)r%z(AI Agent with tool calling capabilities.z[hermes-agent: tool call arguments were corrupted in this session and have been dropped to keep the conversation alive. See issue #15236.]c <V^8dQhRS[/#rr)rrs"rrAIAgent.__annotate__s#rcVP#N) _base_urlrs&rbase_urlAIAgent.base_urls ~~rc$<V^8dQhRS[RR/#)rrrNr)rrs"rrrs;;c;d;rcpWnV'dVP4MRVn\V4VnR#)rN)rr_base_url_lowerrs_base_url_hostnamerrs&&rrrs&05u{{}2"3E":rNrFallic^<V^8dQhRS[R,RS[R,RS[R,RS[R,RS[R,RS[S[,R,RS[R,R S[S[,R,R S[R S[R S[R,R S[S[,R,RS[S[,R,RS[RS[RS[RS[RS[R,RS[RS[RS[S[,R,RS[S[,R,RS[S[,R,RS[R,RS[RS[R,RS[S[,RS[R,RS[RS[3,R,R S[RS[3,R,R!S[RS[3,R,R"S[RS[3,R,R#S[RS[3,R,R$S[RS[3,R,R%S[RS[3,R,R&S[RS[3,R,R'S[RS[3,R,R(S[RS[3,R,R)S[RS[3,R,R*S[RS[3,R,R+S[RS[3,R,R,S[RS[3,R,R-S[RS[3,R,R.S[RS[3,R,R/S[RS[3,R,R0S[RS[3,R,R1S[RS[3,R,R2S[RS[3,R,R3S[RS[3,R,R4S[S[S[S[.R3,,R5S[S[S[.R3,,R6S[R,R7S[S[S[3,R,R8S[R,R9S[S[S[3,R,R:S[S[S[S[3,,R,R;S[R,RS[R,R?S[R,R@S[R,RAS[R,RBS[R,RCS[R,RDS[RES[RFS[RGS[RHS[R,RIS[ RJS[S[,RKS[S[S[3,R,RLS[RMS[RNS[ROS[RPS[RQS[R,RRS[S[S[3,R,RSS[R,RTS[RUS[S[RS[3,,/S#)VrrNapi_keyproviderapi_mode acp_commandacp_argscommandrymodelmax_iterations tool_delayenabled_toolsetsdisabled_toolsetssave_trajectoriesverbose_logging quiet_modetool_progress_modeephemeral_system_promptlog_prefix_chars log_prefixproviders_allowedproviders_ignoredproviders_order provider_sortprovider_require_parametersprovider_data_collectionopenrouter_min_coding_scorertool_progress_callback.tool_start_callbacktool_complete_callbackthinking_callbackreasoning_callbackclarify_callbackread_terminal_callbackread_preview_callbackdrive_preview_callbackread_window_below_callbackconnection_callback tour_callbacktheme_callbacksetup_beat_callback step_callbackstream_delta_callbackinterim_assistant_callbacktool_gen_callbackstatus_callbacknotice_callbacknotice_clear_callbackevent_callbackreaction_callback max_tokensreasoning_config service_tierrequest_overridesprefill_messagesr+r2r8r3r,r-r/r5gateway_session_keyskip_context_filesload_soul_identity skip_memoryskip_background_reviewparent_session_iditeration_budgetrun_budget_secondsfallback_modelcheckpoints_enabledcheckpoint_max_snapshotscheckpoint_max_total_size_mbcheckpoint_max_file_size_mbpass_session_idrequested_provider capabilitiescwd side_agenttool_result_metadata_callback) rrrfloatrrrrrrF)rrs"rrrs:4(4(*4(.1Dj4(KNQU:4(hknrhr4(4Z4(37s)d2B4(UXZ^T^4(nrrumvy}m}4( 4(  4( DL 4(s)d*4(GK3iRVFV4( 4(;?4(UY4( 4(CF*4(4(254( 9t+4(HLCySWGW4(rvvyqz~BrB4(Tz4(HL4(psuyoy4(&.e_4($J4(!)c 2T 94(X``ceh`hWilpWp4( !)c 2T 9!4( V^^acf^fUgjnUn!4("%S#X.5#4("QYY\^aYaPbeiPi#4($!)c 2T 9%4($ZbbegjbjYknrYr%4(&!)c 2T 9'4(&_ggjlogo^psw^w'4((&c3h/$6)4((OWWZ\_W_N`cgNg)4(*!c*T1+4(,&c3h/$6-4(. S)D0/4(0 (S1D814(0^ffiknfn]orv]v14(2$CH-434(2OWWZ\_W_N`cgNg34(4"#s(+d254(4S[[^`c[cRdgkRk54(6!3+t*;!<=74(8$HcUD[$9:94(:$J;4(::>c3h$9N;4(:fikoeo;4(< S>D0=4(<LPPTUXZ]U]P^K_bfKf=4(>*?4(>/2Dj?4(>ORTXj?4(>mprvlv?4(@tA4(@03TzA4(@NQSWZA4(@loqukuA4(B!4ZC4(D!E4(D?CE4(FG4(F<@G4(H-0$JI4(J*K4(JGOuoK4(LS#X-M4(N"O4(NFIO4(P'*Q4(PORQ4(RS4(R*U4(VW4(X(0d0C'DY4(rcW \4P4UWUXu/uFwpWpXVWR9gKXWXXbK pYpWpXV e\P!R\^R7^RIHpZVZ!V3/XYBR#uupXpWi)ubForwarder — see ``agent.agent_init.init_agent`` (same keyword parameters, minus ``tool_delay``).Nz_tool_delay is deprecated and ignored; sequential tool calls no longer sleep between executions.) stacklevel) init_agent)rr)localsitemswarningswarnDeprecationWarningagent.agent_initr&)[rrrrrrrrryrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr r r r r rrr+r2r8r3r,r-r/r5rrrrr session_dbrrrrcredential_poolrrrrrrrr r!memory_managerr"kv init_kwargsr&s[&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&& rrAIAgent.__init__sk^)/(8\(81AE[<[tq!t(8 \  ! MM@AS`a c/4';' ]s A)A)c \VRR4'dR#VPe VP#^RIHpV!4VnRVnVP# \ d\ PRRR7R#i;i)zSessionDB for recall, opening the default state DB when no ``session_db`` was passed so the advertised ``session_search`` tool stays usable._persist_disabledFN)acquireTz SessionDB unavailable for recallexc_info)r> _session_dbhermes_state_registryr6_owns_session_dbr@rr)rr6s& r_get_session_db_for_recall"AIAgent._get_session_db_for_recall"sx 4,e 4 4    '## #  5&yD $(D !## #  LL;dL K s$A"A<;A<c <V^8dQhRS[/#r)r)rrs"rrr5sSS3Src H^RIHpV!VPVP4#)z``model_config`` for the lazily created session row: the init config plus a live /yolo toggled before the first turn (``hermes --resume`` restores it).)with_session_yolo)tools.approval_yolor@_session_init_model_configr)rr@s& r_session_row_model_config!AIAgent._session_row_model_config5s : !@!@$//RRrc<V^8dQhRR/#rrN)rrs"rrr;s!W!WD!Wrc \VRR4'g%VP'gVP'gR#\VP4p^RIHpV!4pVPPVPYPVP4VP\VRR4\VRR4\VRR4\VRR4\VR R4\VR R4;'g\VR R4\V4VP\V4VR 7R VnR# \dRpLi;i \d"p\ P#RT4Rp?R#Rp?ii;i)zYCreate the session DB row on first use; a transient failure leaves it to retry next turn.r5FNr:r*r)r(r0r6r.r4)rrr model_config system_promptr2rCr,r/r5 display_name origin_jsonrr  profile_nameTz5Session DB creation failed (will retry next turn): %s)r>_session_db_createdr9r r+r?r;r@create_sessionrrrC_cached_system_promptrE_parent_session_idr"rwarning)rrr;profile_for_sessiones& r_ensure_db_sessionAIAgent._ensure_db_session;sN 4,e 4 48P8P8PX\XhXhXh #DMM2 W +G&=&?#    + +??6!;;=TMgMgj$7WTSikoEpj$774Q]_cCd!$ d;$T<>cc'$P\^bBc06$JaJa+F3BU , (,D $' + '+#  +( W NNRTU V V Ws7 D/CE/ D?<E>D??E E. E))E.old_session_idnew_session_idprevious_messagescarry_over_context reset_engineTc l<V^8dQhRS[S[,RS[S[,RS[S[,RS[RS[RR/#)rrWrXrYrZr[rN)rrrr)rrs"rrr^sTkk!)#kGOPS}k#D>kFJkbfk  krc \VRR4pV'gR#V'dVe\VRW4V'd \VR4\T;'gVRJ;'g T;'gT4pT;'g\VRR4;'gRp V'dV 'd\VR4'dRVR VR \ \VR R44R \VR R4R \VR R4R \VRR4/VCp V P 4U U u/uFwrV R9gKWbK p p p \VRV 3/V BV'd$V'dV 'd\VRW4R#R#R#R#uup p i)uDrive the context engine's session transition: on_session_end → on_session_reset → on_session_start → carry_over_new_session_context. Each hook is optional (the built-in compressor only resets).rNron_session_resetrron_session_startrWrZr+rcontext_lengthconversation_idr)carry_over_new_session_context)Nr)r>rrrr r() rrWrXrYrZr[ extra_contextr} should_starttarget_session_id start_contextr0r1s &$$$$$, r"_transition_context_engine_session*AIAgent._transition_context_engine_session^sa3T:  /; f&6 Z  f&8 9Nrr.?t.KrrOarrers *SSgdL".MSSQS -'&BT2U2U .2FHZ.wtZ/NOw35EwvWgimGn!741G#N S` M /<.A.A.C[.CdaqPZGZTQT.CM[ f&8:K ]} ] .5F f&F j6G. \s EEcL<V^8dQhRS[S[,RS[S[,RS[/#)rrYrWrZ)rrrr)rrs"rrr{s3/X/XXd^/X\deh\i/X04/Xrc NRFp\W^4K RVnRVnRVnRVnRVnRVn^VnRVnRVn RVn VPV\VRR4WRR7\VR R4p\VRR 4;'gR pVeS\VR 4'd?V'd5V\VR R 48wd!VP\VR R4V4R#R#R#R#R# \d"p\ P#RT4Rp?R#Rp?ii;i)zReset session-scoped token/cost counters and compressor state for a fresh session. With ``previous_messages`` / ``old_session_id`` / ``carry_over_context`` the context engine gets the full transition lifecycle instead of a bare reset. gunknownnoneNFrT)rWrXrYrZr[rrbind_session_state _session_idr9z2context engine bind_session_state during reset: %s) session_total_tokenssession_input_tokenssession_output_tokenssession_prompt_tokenssession_completion_tokenssession_cache_read_tokenssession_cache_write_tokenssession_reasoning_tokenssession_api_calls)setattrsession_estimated_cost_usdsession_cost_statussession_cost_source _usage_anchor_turn_base_usage_anchor_frozen_workspace_snapshot_user_turn_count_compaction_prompt_drift_logged _turn_author_is_user_initiated_turnrgr>rrmr@rr)rrYrWrZcounterr}rers&&&& rreset_session_stateAIAgent.reset_session_state{sC G D1 %  +.'#, #) "'+$+/'!"/4, ',$ //)'$ VZ:[/ei 0 3T:#D,;AAr  763G#H#HM^%)KK X))'$ t*LN_`LN_#H  X QSVWW XsC88 D$DD$cL<V^8dQhRS[S[,RS[RS[S[,/#)rconfig_context_lengthruntime_context_lengthrrrr)rrs"rrrs. < <(3- rmin)rrexplicitruntimes&& r"_effective_lmstudio_context_length*AIAgent._effective_lmstudio_context_lengths}!!67(>@PRh ij . EB C C /1A5I J Jw  8#7w) )!-w;8;rc&<V^8dQhRS[RS[/#)r load_resultrrr)rrs"rrrs  3 4 rc \\VRR44;'g.\\VRR44;'d\VRR4RJ#)z@Return true when a management load was rejected or unverifiable.rFrr`Nrr>)rs&r_lmstudio_load_was_unverified%AIAgent._lmstudio_load_was_unverifiedsOGKU;<  &6> ? x xGKYikoDptxDx rc6<V^8dQhRS[S[,RS[/#)rrrr)rrs"rrrs   Xc]  ^a  rc  VP;'gRP4P4R8wdR#\VRR4;'gRP4P4R8Xd\P R4R#^RIHpVf\VR R4pV!VPVP\VR R4VR R 7#) z;Preload LM Studio unless configured to rely on JIT loading.rlmstudioNlmstudio_load_moderjitz:LM Studio explicit preload skipped: lmstudio_load_mode=jit)ensure_lmstudio_model_loaded_config_context_lengthrT)return_load_result) rrrr>rrhermes_cli.models_localrrr)rrrs&& r_ensure_lmstudio_runtime_loaded'AIAgent._ensure_lmstudio_runtime_loadeds MM  R & & ( . . 0J > D. ; I Iz P P R X X Z^c c LLU VH ($+D2JD$Q !+ JJ wtY'CEZos  rzagent.agent_runtime_helpers switch_model keep_replaycx<V^8dQhRS[S[S[S[S[3,,,RS[RS[S[S[3,/#)rrrr)rrrrrrr)rrs"rrrsDHH d38n!56HOSH c3hHrc n^;r4\V\4'dTM.Fp\V\4'dVPR4R8wdK1VP RR4p\V\4'gK[V'gKeV^, pV\ V4, pK V'gRVnRVRV/#)zOn HTTP 400 ``invalid_encrypted_content``: pop ``codex_reasoning_items`` from every assistant message and, unless ``keep_replay``, disable Responses reasoning replay. Returns ``{"messages", "items"}`` counts.role assistantcodex_reasoning_itemsNFrr()rrrrpopr_codex_reasoning_replay_enabled)rrrstripped_messagesstripped_itemsmsgr(s&&$ r_disable_codex_reasoning_replay'AIAgent._disable_codex_reasoning_replays ./. *8T : :HBCc4((CGGFO{,JGG3T:E%&&55!Q&!#e*, C38D 0-wGGrzagent.stream_diagstream_diag_initstream_diag_capture_responseflatten_exception_chainc&<V^8dQhRS[RS[/#)rrr) BaseExceptionr)rrs"rrrsqq]qtqrc H\VRR4R8H;'d \V4#)zTrue for a malformed Anthropic event-stream frame (surfaced by the SDK as a plain ``ValueError``); that is wire trouble, not local validation, so it follows the truncated-JSON retry path.rNanthropic_messages)r>rY)rrs&&r_is_provider_stream_parse_error'AIAgent._is_provider_stream_parse_errors(tZ.2FFppKijoKpprlog_stream_retryemit_stream_dropc*<V^8dQhRS[RS[RR/#)rtaskrrN)rr)rrs"rrrs' E EC Em E Erc HVPV4pT;'gVPPP 4p\ V4^8dVR,P4R,pVPRV RV 24R# \d\T4pLi;i)z4Surface a compact warning for failed auxiliary work.:NNz...u⚠ Auxiliary z failed: N) _summarize_api_errorr@rrrrrrstrip _emit_warning)rrrdetails&&& r_emit_auxiliary_failureAIAgent._emit_auxiliary_failures ..s3F22CMM2299; v; D\((*U2F ^D66(CD  XF sBB! B!c6<V^8dQhRS[S[S[3,/#rrr)rrs"rrrs  tCH~ rc  ZRUu/uFpT\WR4;'gRbK up#uupi)zBReturn the live main runtime for session-scoped auxiliary routing.r)rrrrr auth_moderr>)rkeys& r_current_main_runtimeAIAgent._current_main_runtimes>k j B'--2 -j   s((zagent.conversation_compression#check_compression_model_feasibilityreplay_compression_warningc6<V^8dQhRS[S[,RS[/#)rrrr&)rrs"rrrs#rrhsmrrrc vVe \V4#\VRR4;'g\\VRR44#)zCHostname of ``base_url``, or of the agent's own base URL when None.rrr)rsr>rrs&&r _hostname_forAIAgent._hostname_fors=  $X. .t126qq:KGTXZkmoLp:qqrc4<V^8dQhRS[R,RS[/#rrNrrr)rrs"rrr s#@@cDj@D@rc *VPV4R8H#)z8Return True when a base URL targets OpenAI's native API.zapi.openai.com)rrs&&r_is_direct_openai_urlAIAgent._is_direct_openai_url s!!(+/???rc4<V^8dQhRS[R,RS[/#rr)rrs"rrrs>>S4Z>4>rc Ve\V4P4M\VRR4;'gRp\VR4#)zZTrue when a base URL targets Azure OpenAI (standard client, but NO Responses API support).rrzopenai.azure.com)rrr>rr)rrurls&& r_is_azure_openai_urlAIAgent._is_azure_openai_urls='/';c(m!!#'$PaceBfBlBljl$S*<==rc4<V^8dQhRS[R,RS[/#rr)rrs"rrrs#sssTzsTsrc VPV4p\V4;'dVR8H;'gVPR4#)zKReturn True when a base URL targets GitHub Copilot's OpenAI-compatible API.api.githubcopilot.comz.githubcopilot.com)rrendswith)rrhostnames&& r_is_github_copilot_urlAIAgent._is_github_copilot_urls>%%h/H~rr8/F#F#q#q(J[J[\pJqrrc <V^8dQhRS[/#r)r#)rrs"rrrsSSESrc f\VPVP4pVeV#\RR4#)zPer-call request timeout: per-model ``timeout_seconds`` > provider ``request_timeout_seconds`` > ``HERMES_API_TIMEOUT`` > 1800s.HERMES_API_TIMEOUTg @)rHrrrt)rcfgs& r_resolved_api_call_timeout"AIAgent._resolved_api_call_timeouts/+4==$**EosR95I6+RRrc6<V^8dQhRS[S[S[3,/#r)tupler#r)rrs"rrrsuUD[7Irc \VPVP4pVeVR3#\P!R4pVe\ V4R3#^RIHpV!VP4pVeVR3#R#)a3Base non-stream stale timeout: per-model ``stale_timeout_seconds`` > provider-wide > ``HERMES_API_CALL_STALE_TIMEOUT`` > reasoning floor > 90s. Returns ``(seconds, uses_implicit_default)``; the implicit flag lets callers auto-disable the detector for local endpoints only when the user configured nothing. FHERMES_API_CALL_STALE_TIMEOUT)!get_reasoning_stale_timeout_floor)gV@T)rIrrrgetenvr#agent.reasoning_timeoutsr)rr env_timeoutrreasoning_floors& r%_resolved_api_call_stale_timeout_base-AIAgent._resolved_api_call_stale_timeout_basesw) C ?: ii ?@  "%u, , O;DJJG  &"E) )rc&<V^8dQhRS[RS[/#)r api_payloadr)rr#)rrs"rrr3sSUrc VP4wr#\VRR4;'gVP;'gRpV'd%V'd\V4'd \ R4#^RIHpHpHp^RI H pV!V4p V R8d \VR4MV R 8d \VR 4MTp VP4p VPR 8XdV 'g\W!V44p V 'gW!V4,p V 'g V!W 4p V #) zEffective non-stream stale timeout for ``api_payload`` (an ``api_kwargs`` dict or legacy ``messages`` list), scaled by estimated context size and capped by the run budget.rNrinf)_high_effort_silence_floorcap_to_run_budgetestimate_request_context_tokens)long_decode_stale_multiplierign@iPgb@codex_responses)rr>rrfr#agent.chat_completion_helpersrrragent.gemini_long_decodermax_stale_timeout_is_explicitr) rr stale_baseuses_implicit_defaultrrrrr est_tokenstimeoutrs && r!_compute_non_stream_stale_timeout)AIAgent._compute_non_stream_stale_timeout3s-1,V,V,X) 4d3JJt}}JJ X2CH2M2M<  A AI4[A ,6,@#j%(`jms`sc*V[F\zD224 ==- -h'#=d#CDG 3K@ @G'6Grc <V^8dQhRS[/#rr)rrs"rrrLsKKDKrc \VPVP4RJ;'g\P!R4RJ#)zTrue when the user explicitly configured the stale timeout (config or env var); implicit values (reasoning floors, the 90s default) yield to the run-budget cap, explicit ones never do.Nr)rIrrrrrs&rr"AIAgent._stale_timeout_is_explicitLs?+4==$**ETQJJ99<=TI KrcF<V^8dQhRS[S[,RS[S[,/#rrrr&)rrs"rrrRs#  Xc] hsm rc VPR8wdR#^RIHpV!V4P'gR#VeTM VP;'gRp\ P !RVP44'gR#RV: R2#)zActionable hint when the request matches a known Codex silent-reject shape (currently the ``gpt-5.5`` family: connection accepted, no events, no error), else None. Makes the stale timeout actionable.rN)classify_responses_routerz(?:^|[/\-_])gpt-5\.5(?:$|[\-_])z/Codex backend appears to be silently rejecting ay on chatgpt.com/backend-api/codex (no stream events, no error). This is a known backend-side pattern that has affected ChatGPT Plus accounts intermittently. Workaround: try `gpt-5.4` on the same OAuth profile, or switch to a different model/provider in your fallback chain. Some ChatGPT Codex accounts do not support `gpt-5.4-codex`. See hermes-agent#21444 for symptom history.)ragent.codex_responses_adapterris_codex_backendrresearchr)rrr eff_models&& r_codex_silent_hang_hintAIAgent._codex_silent_hang_hintRsv ==- -J'->>>#/UTZZFFB yy;Y__=NOO=i]K: : rc <V^8dQhRS[/#rr)rrs"rrrjsLLDLrc .\VPR4#)z1Return True when the base URL targets OpenRouter.z openrouter.airrrrs&r_is_openrouter_urlAIAgent._is_openrouter_urljs$T%9%9?KKrc <V^8dQhRS[/#rr)rrs"rrrnszzzrc xa\;QJdV3RlR4F 'gK R# R#!V3RlR44#)zFReturn True when the base URL targets GitHub Copilot or GitHub Models.c3P<"TFp\SPV4xK R#5irr).0hrs& r *AIAgent._is_copilot_url..ps$yKxa()=)=qAAKxs#&TF)rzmodels.github.ai)anyrsfr_is_copilot_urlAIAgent._is_copilot_urlns.syKxyssysysyKxyyyrc <V^8dQhRS[/#rr)rrs"rrrrszzdzrc VP;'gRP4P4R9;'gVP4#)zTrue when the active provider is GitHub Copilot under any alias (``copilot`` / ``github-copilot`` / ``github``) or by base URL; a bare equality check would silently skip credential recovery.r>githubcopilotgithub-copilot)rrrr'rs&r_is_copilot_providerAIAgent._is_copilot_providerrs@ ##**,2248__yycgcwcwcyyrc <V^8dQhRS[/#rr)rrs"rrrwsZZ4Zrc \VRR4R8H;'d3\VRR4R8H;'dR\VRR4;'gR9#) z:Return True for the ChatGPT OAuth Codex Responses backend.rNrrrz chatgpt.comz/backend-api/codexrrrs&r_is_codex_backendAIAgent._is_codex_backendws_j$/3DDYYD"6;}LYY(WT;Lb-Q-W-WUWX Zranthropic_prompt_cache_policy._direct_native_anthropic_tool_cache_capabilityc&<V^8dQhRS[RS[/#rr)rrs"rrrsDDSDTDrc nVP4PR^4R,PR4#)zmTrue for GPT-5.x, which OpenAI and OpenRouter reject on /v1/chat/completions (``unsupported_api_for_model``)./zgpt-5)rrsplit startswith)rs&r_model_requires_responses_api%AIAgent._model_requires_responses_apis-{{}##C+B/::7CCrrc<<V^8dQhRS[RS[S[,RS[/#)rrrr)rrr)rrs"rrrs(< "4 48Q8Q W ()< = = ) + O8??44U;;  s$ B BBc&<V^8dQhRS[RS[/#r)rr)rrs"rrrs%%s%t%rc VP4'gHVP4'g2VP4'g\VP4'dRV/#RV/#)z``max_completion_tokens`` for newer OpenAI families (and Azure / Copilot serving them), else ``max_tokens``. URL-first, then model-name fallback for third-party endpoints fronting those models.max_completion_tokensr )rrrrurrs&&r_max_tokens_paramAIAgent._max_tokens_paramsT  & & ( (D,E,E,G,G4KfKfKhKh5djjAA+U3 3e$$rc6<V^8dQhRS[RS[S[,/#)r api_kwargsrr)rrs"rrrs  # (3- rc \V\4'gR#RF)p\VPV44pT^8gK'Tu# R# \\ 3dKCi;i)z@Extract the outgoing response token cap from a prepared request.N)max_output_tokensrMr )rrrr TypeError ValueError)rQrrs& r%_requested_output_cap_from_api_kwargs-AIAgent._requested_output_cap_from_api_kwargssc*d++OC JNN3/0qy P z*  sA  AAc&<V^8dQhRS[RS[/#rcontentrr)rrs"rrrsQQcQdQrc x\V4;'d)\VPV4P44#)z[True when text remains after stripping reasoning blocks (reasoning-only output is retried).)r_strip_think_blocksr)rrZs&&r_has_content_after_think_block&AIAgent._has_content_after_think_blocks-G}PPd&>&>w&G&M&M&O!PPrstrip_think_blocksc&<V^8dQhRS[RS[/#rYr)rrs"rrrsttctdtrc T;'gRP4pV'gR#VR,pVPR4;'gVR9;'g\V4R8#)zCHeuristic: does visible assistant text look intentionally finished?rFz```u%.!?:)"']}。！？：）】」』》^ir9)rrord)rZstrippedlasts& r_has_natural_response_ending$AIAgent._has_natural_response_endings[MMr))+|  'ss43[+[ss_bcg_hls_ssrc <V^8dQhRS[/#rr)rrs"rrrs***rc VP;'gRP4pVP;'gRP4pRV9d VR8wdR#VPpRV9gRV9dR#RV9gRV9dR #VR8H#) uOllama-hosted GLM models misreport finish_reason='stop'. Matches only explicit Ollama signatures (port 11434, "ollama" in URL, provider ollama), never arbitrary local proxies; excludes Ollama Cloud (``ollama.com`` / ``:cloud``), which reports faithfully — rewriting it would manufacture truncations. Crucially it does NOT match arbitrary local/private endpoints (LiteLLM/sglang/vLLM/LM Studio proxies, Tailscale boxes), which report finish_reason correctly and were the source of #13971's false-positive truncation continuations. Two signatures identify it: the ``ollama.com`` host (provider ``ollama-cloud``) and the ``:cloud`` model suffix (cloud generation proxied through a local 11434 endpoint, #98406). Applying the stop→length rewrite to them manufactures false truncations and causes the continuation nudge to consume the model's output budget on the next retry, making further false-positives more likely. rglmzaiFz ollama.comz:cloudollamaz:11434T)rrrr)r model_lowerprovider_lowerbases& r_is_ollama_glm_backendAIAgent._is_ollama_glm_backendszz''R..0 ----2446  #%(?## 4 8{#: t x4/))rc<<V^8dQhRS[RS[S[,RS[/#)r finish_reasonrr)rrrr)rrs"rrrs/CCSC_ghl_mCy}Crc FVR8wg(VPR8wgVP4'gR#\;QJd&RT;'g.4F 'gK RM RM!RT;'g.44'gR#Ve\VRR4'dR#\VRR4p\ V\ 4'gR#VP V4P4p\V4^8g\P!R V4'gR#VPV4'*#) zIDetect conservative stop->length misreports for Ollama-hosted GLM models.stopchat_completionsFc3z"TF1p\V\4;'dVPR4R8HxK3 R#5i)rtoolNrrr)r"rs& rr$:AIAgent._should_treat_stop_as_truncated..s1cSa3:c4(FFSWWV_-FFSa;;TN tool_callsrZz\s) rror&r>rrr\rrrrre)rrrassistant_messagerrZ visible_texts&&&& r_should_treat_stop_as_truncated'AIAgent._should_treat_stop_as_truncateds F "dmm7I&IQUQlQlQnQnscS[SaSa_aSacssscS[SaSa_aSaccc  $0A>@ | r !5,)G)G44\BBBr!looks_like_codex_intermediate_ackextract_reasoningzagent.chat_completion_helperscleanup_task_resources)_MEMORY_REVIEW_PROMPT_SKILL_REVIEW_PROMPT_COMBINED_REVIEW_PROMPTzagent.background_review#summarize_background_review_actionsc \<V^8dQhRS[S[,RS[RS[RS[S[,RS[RR/#)rmessages_snapshot review_memory review_skillsfocusrrN)rrrrr)rrs"rrrsD44$t*4UY4044EMc]4ei4vz4rc  PVf\VR^4^8dR#RpVf^RIHpV!4wrV'gR#^RIHp \ V !V4W#WFVR7p Vf>V'g6\ W4'd%^RIHp V PV\V4V 4R#VP!R/V BR#)aYPost-turn review entry point: decide WHEN, then spawn. A review whose runtime is the MANAGED LOCAL llama-server is queued for machine idle (``defer: auto``) instead of hitting the user's GPU mid-session; everything else spawns immediately. ``explicit`` (/refine) is never deferred but does not touch the ``focus``-keyed delegate/enabled gates. N_delegate_depth)load_background_review_settings)!_clone_background_review_messages)rrrrrrQUEUErG) r>agent.background_reviewragent.turn_finalizerrrrrrenqueuer_spawn_background_review_now) rrrrrrrrenabledrrzrs &&&&&& r_spawn_background_review AIAgent._spawn_background_reviews =WT+.__annotate__/s ( ($ (rc h< S!4SPS\SSSSS S^,SR74R#))rrrrrrrN)_maybe_requeue_preempted_reviewr) rrrrrrrrtargetrs r_target_with_requeueBAIAgent._spawn_background_review_now.._target_with_requeue/s944Z&7}dq(FWZ[F[%B'(rTz bg-review)rdaemonname) rrrrtools.thread_contextr threadingThreadstartr@)rrrrrrrrrrrr_promptrrrsffffffff @@rr$AIAgent._spawn_background_review_nows   E248    <'}Tah:PXOFG  ( ( (   $?@T$U^bit u { { }  (z :  s AA>>Bc<V^8dQhRR/#rFrG)rrs"rrr?sKKTKrc VPP4'dVPR4eR#VPR^4VP8d#\P RVP4R#\ WPR44'gR#^RIHpVPV\V4\V44R# \d\PRRR 7R#i;i) zRequeue a deferred-mode review that a live turn cancelled. Only for automatic reviews on the managed local runtime; bounded attempts stop a busy box cycling forever. rNrz5Preempted background review dropped after %d requeuesrrzPreempted-review requeue failedTr7)cancel_requestedis_setr_REVIEW_REQUEUE_MAX_ATTEMPTSrinforrrrrrr@r)rrrzrs&&& rr'AIAgent._maybe_requeue_preempted_review?s K..55776::g;N;Zzz-q1D4U4UU SUYUvUvw'jj.DEE 5 MM$ 1$ 7f F K LL:TL J Ks(C C AC : C +C "C/.C/build_memory_write_metadata#apply_pending_steer_to_tool_resultsc <V^8dQhRS[/#r)r)rrs"rrrWs  d rc H^RIHp\VRR4pT!\VRR4\VRR4;'gRVeTM\PRVP RVP R VPR VPPR VPP/R 7#) zaDiagnostic snapshot: ``last_activity_*`` plus the short aliases gateway and delegate readers use.)build_activity_snapshot_last_activity_provenanceN_last_activity_ts_last_activity_descr current_toolapi_call_countr budget_used budget_max)last_activity_atlast_activity_descriptionlast_activity_provenanceextra) agent.session_activityrr>reUNKNOWN _current_tool_api_call_countrrused max_total)rr provenances& rget_activity_summaryAIAgent.get_activity_summaryWsBT#>E &$T+>E&-d4I4&P&V&VTV3=3IZOaOiOi 2 24DdFZFZ $"5"5}dF[F[F`F`d33==  rc2<V^8dQhRS[R,RR/#rrNrr)rrs"rrrgs ; ; ; ;rc a\SRR4'dR#RSnSP'dXSPPRR7'd6SPP T;'g.4\V3Rl4\SV4R# \ d#p\ PRTRR7Rp?LERp?ii;i) zShut down the memory provider and context engine at session end (idempotent: gateway cleanup and ``close()`` may both call it)._memory_provider_shutdownFNT) session_endz9Memory provider on_session_end failed during shutdown: %sr7c8<SPP4#r)_memory_manager shutdown_allrsrr2AIAgent.shutdown_memory_provider..rsT11>>@r) r>rrclaim_teardownrr@rrRr{r)rrrTsf& rshutdown_memory_provider AIAgent.shutdown_memory_providergs 44e < < )-&    D$8$8$G$GTX$G$Y$Y n$$33HNNC @ A*4: nZ\]hlmm nsB1B C B==Cc2<V^8dQhRS[R,RR/#rr)rrs"rrrus;;dTk;T;rc faaSP'd\VV3Rl4\SS4R#)zjFlush end-of-session extraction on session_id rotation (/new, compression) without tearing providers down.cN<SPPS;'g.4#r)rr)rrsrr/AIAgent.commit_memory_session..ysT11@@RPrN)rr{r)rrsffrcommit_memory_sessionAIAgent.commit_memory_sessionus$     P Q*4:rrc D<V^8dQhRS[RS[RS[RS[R,RR/#)roriginal_user_messagefinal_response interruptedrNr)rrr)rrs"rrr|s8s\_nr15HLrc V'g#VP'dV'd V'gR#\VRR7p\VRR7pV'd V'gR#RVP;'gR/VeRV/M/Cp\VRR4pVeWR&VPP!WV3/VB\ V4'g3VPP YPP;'gRR 7R#R# \dR#i;i) uMirror a completed turn into external memory providers (``sync_all`` + ``queue_prefetch_all``). Uses ``original_user_message`` (``user_message`` may carry injected skill content). Interrupted turns are skipped: partial output is not durable truth. Best-effort — an offline backend never blocks. A partial assistant output, an aborted tool chain, or a mid-stream reset is not durable conversational truth — mirroring it into an external memory backend pollutes future recall with state the user never saw completed. The prefetch is gated on the same flag: the user's next message is almost certainly a retry of the same intent, and a prefetch keyed on the interrupted turn would fire against stale context. See #15218. N )seprrrr turn_author)r)rrlrr>sync_allrSqueue_prefetch_allr@) rrrrr user_text response_text sync_kwargsrs &$$$$ r_sync_external_memory_for_turn&AIAgent._sync_external_memory_for_turn|s t333K` 34ItT 7DQ m  ')>)>B{]e]qJPXCYwy{K!$=K&-8M*  ) )) Rk R$Y//$$77 ooNcNcac7d0   sC3.A8C3'C33 DDc<V^8dQhRR/#rFrG)rrs"rrrs 8 8 8rc aSPRR7\SPV3Rl4SPR4\SP4\ SRR4e"\SP P4R#R#)aRelease LLM clients, child agents and memory providers WITHOUT tearing down session tool state (gateway cache eviction: the session may resume on the same task_id, so processes, sandbox, browser and computer-use are kept). Idempotent; distinct from ``close()``.Tsoftc*<SPVRR7#) cache_evictreason)_retire_shared_openai_clientcrs&rr)AIAgent.release_clients..sT5V5VWXan5V5orrrN)_close_active_childrenr{_drop_shared_client_close_request_clients_close_codex_sessionr>r release_softrsfrrelease_clientsAIAgent.release_clientssp ###. ))+op ##M2 **+ 4*D 1 = T))66 7 >rc<V^8dQhRR/#rFrG)rrs"rrrs33t3rc  la\SRR4p\SP\V\4'dTMR4SP \SRR4;'gR4SP RR7\SPV3Rl4SPR4\SP4.Sn RSn .Sn \V\4'd+^R I Hp\W!\SR R4\SR R434\SP4\SP 4R#) zqRelease every resource this agent holds (idempotent); each phase is guarded so one failure never blocks the rest._session_messagesNrrFrc,<SPVRRR7#) agent_closeT)rshared)_close_openai_clientrs&rrAIAgent.close..sT5N5NqYfos5N5trr )forget_message_token_memorP_cached_system_prompt_static)r>r{rrr_close_task_resourcesrrrrr_db_flush_scan_prefix_streamed_assistant_text_partsagent.model_metadata_token_memor_trim_process_memory_finalize_owned_session_row)rsession_messagesrsf rclose AIAgent.closes #4).s U[[]r)_active_children_lockr_active_childrenclearr@rr{)rrchildrenrs&$ @rrAIAgent._close_active_childrens +++ 5 56%%++-, E))+ * + ,+   !s@B0BBB) B BB B&%B&) B76B7c:<V^8dQhRS[S[.R3,RR/#)rclose_fnNr)rr)rrs"rrrs&  HcUD[,A d rc J\VRR4pVeV!V4RVnR#R#)zLHand the shared OpenAI/httpx client to ``close_fn`` and clear the attribute.clientN)r>r&)rr$r&s&& rrAIAgent._drop_shared_clients,x.   V DK rc$<V^8dQhRS[RR/#)rrrNr)rrs"rrrsMMSMTMrc b\VPVR7\VPVR7R#)zNDrop the cached per-request wire clients (reused across sequential LLM calls).rN)r{#_close_cached_request_openai_client&_close_cached_request_anthropic_client)rrs&&rrAIAgent._close_request_clientss"99&I<r/r)r codex_sessions& rrAIAgent._close_codex_sessions2 &6=  $"&D     ! %rc<V^8dQhRR/#rFrG)rrs"rrrs66$6rc &^RIHpV!RRR7R#)zXCollect cycles, then return freed heap pages to the OS (the page release is glibc-only). trim_memoryTz agent close)forcerN)hermes_cli.mem_trimr5r4s rrAIAgent._trim_process_memorys 4$}5rc<V^8dQhRR/#rFrG)rrs"rrrs))T)rc aa\VRR4o\VRR4o\VRR4'd!S'dS'd\VV3Rl4\VRR4'dSeRVn^R IHpV!S4R#R#R#) uqEnd the session row unless ownership was handed forward (compression helpers, review forks sharing the parent's id; end_session() is first-reason-wins), then release the SQLite handle ONLY when this agent owns it — a dedicated handle left open pins its fds and token-writer thread for the process lifetime. The owner flag is cleared first so close() stays idempotent.r9Nr_end_session_on_closeTc(<SPSR4#)r ) end_session)r-rsrr5AIAgent._finalize_owned_session_row..sZ33J Nrr;F)release_or_close)r>r{r;r:r?)rr?r-rs& @@rr#AIAgent._finalize_owned_session_rowsq T=$7 T<6 40$ 7 7J: N O 4+U 3 3 8N$)D ! ? Z ( 9O 3rcJ<V^8dQhRS[S[S[S[3,,RR/#)rhistoryrN)rrrr)rrs"rrr s(4S#X+?Drc VPV4pVeVwr4\^\T;'g^44pT\VP P 4PR^4;'g^48dYVP PW5R7VP'g+VPVP R\V4 R24\R4R# \\3d^pLi;i)uReplay the most recent todo tool response (the gateway builds a fresh AIAgent per message). Only results paired with an earlier assistant Todo-tool call count — a forged bare ``role: tool`` message must not seed the store (GHSA-5g4g-6jrg-mw3g).Nrevision)rDu📋 Restored z todo item(s) from historyF)_latest_todo_responserrrTrU _todo_storesnapshotrrestorer_vprintrr_set_interrupt)rrBfoundlast_todo_responselast_todo_revisionhistory_revisions&& r_hydrate_todo_storeAIAgent._hydrate_todo_store s**73  5: 2  %#&q#.@.E.EA*F#G  #d&6&6&?&?&A&E&EjRS&T&Y&YXY"ZZ  (();(WLLDOO#4N3GYCZB[[u!vwu z* %#$  %sC!!C76C7c\<V^8dQhRS[S[S[S[3,,RS[S[,/#)rrBr)rrrrrr)rrs"rrrs,T$sCx.-Ahuorc ^RIHp\\V4^, R R 4EF pW,pVP RR4pVP R4R8wg.\ V\ 4'dVPW4'gKc\V4V8d7\PRVP;'gR\V44KRV9dK\P!V4pR T9gK\ TR ,\4'gKTR ,TP R ^43u# R # \P\3dEK1i;i) uaWalk history backwards for the newest paired, size-bounded todo result → ``(todos, revision)``.)MAX_TODO_RESULT_CHARSrZrrrwzKSkipping oversized todo tool response during hydration: session=%s chars=%drlz"todos"todosrDNr9)tools.todo_toolrSrangerrrr _tool_response_matches_todo_callrrRrrAloadsJSONDecodeErrorrTr)rrBrSidxrrZdatas&& rrEAIAgent._latest_todo_responses 9W)2r2C,Cggi,Gwwv&( 7C0H0HPTPuPuv}QDQD7|33 56:oo6O6OQTU\Q]_' zz'*$:d7mT#B#BG}dhhz1&===!3" (()4  sD66EEcR<V^8dQhRS[S[S[S[3,,RS[RS[/#)rrB tool_indexr)rrrrrr)rrs"rrr4s1  tDcN7K Y\ ae rc ^Tu;8:d\V48dMMW,PR4MRpV'gR#\VRV4F8pVPR4pVR8XdVPWC4u#VR9gK7R# R#)uTrue when the nearest prior assistant message issued a Todo-tool call (legacy aliases and the ``tool_call`` bridge canonicalized) with this ``tool_call_id``; a ``user``/``system`` boundary or missing id means unpaired → must not hydrate. tool_call_idNFrr>usersystem)rrreversed_assistant_has_todo_tool_call)clsrBr^r`priorrs&&& rrW(AIAgent._tool_response_matches_todo_call3s CDzB`TWX_T`B`w*..~>fj gkz23E99V$D{"88MM)) 4 rcB<V^8dQhRS[S[S[3,RS[RS[/#)r assistant_msgr`rrrrr)rrs"rrrDs,  $sCx. X[ `d rc aaa^RIHoVPR4p\V\4;'d?\ ;QJd!VVV3RlV4F 'gK R# R#!VVV3RlV44#)z?True when the paired call resolves to the registered Todo tool.)is_todo_tool_callr{c3l<"TF)pSPV4S8H;'d S!V4xK+ R#5ir)_get_tool_call_id_static)r"tcrerlr`s& rr$8AIAgent._assistant_has_todo_tool_call..Is84 ak[]C ( ( , < V VARSUAV Vaks44TF)rUrlrrrr&)rerir`r{rlsf&f @rrd%AIAgent._assistant_has_todo_tool_callCsf 6"&&|4 *d+  4 ak4   4 ak4 1  rc <V^8dQhRS[/#rr)rrs"rrrNs)))rc VP#)z)Check if an interrupt has been requested.)_interrupt_requestedrs&ris_interruptedAIAgent.is_interruptedMs(((rzagent.system_promptbuild_system_promptc <V^8dQhRS[/#rr)rrs"rrrXsHH#Hrc \V\4'dFVPR4p\V\4'dVPRR4;'gR#R#\\VRR4RR4;'gR#)zhFunction name of a tool_call entry (dict or object); Gemini requires it on every ``role: tool`` message.functionrrN)rrrr>)rorws& r_get_tool_call_name_static"AIAgent._get_tool_call_name_staticWsi b$   #B1;B1E1EBFF62&,," M2 Mwr:t4fbAGGRGrsanitize_api_messagesdrop_codex_reasoning_itemscB<V^8dQhRS[S[S[3,RS[RS[/#)rrr~rrj)rrs"rrrcs,!!c3h!X\!hl!rc 8\V\4'd.VPR4R8wgVPR4'dR#VPR4'dR#\P VPR44'dR#^RIHpV!VPR 44'dR#VPR 4;'gVPR 4pVPR 4p\V\4'dVP4'g\V\4'd V'dR#VPR 4pV'dK\V\4'd5\;QJdR V4F 'gK R# R#!R V44#R#)aTrue if ``msg`` is an assistant turn whose only payload is reasoning (no text, no tool_calls). Providers converting reasoning to thinking blocks reject it (400 "final block cannot be thinking"), so the turn is dropped from the API copy; the transcript keeps the reasoning block. rrr{F_thinking_prefillTrZ)has_compaction_checkpointrreasoning_content reasoningreasoning_detailsc3z"TF1p\V\4;'dVPR4R8HxK3 R#5i)rrNrx)r"items& rr$6AIAgent._is_thinking_only_assistant..s3j^iVZz$-QQ$((62Bk2QQ^irz) rrrr%_content_has_real_payloadagent.native_compactionrrrrr&)rr~rrrd codex_itemss&$ r_is_thinking_only_assistant#AIAgent._is_thinking_only_assistantbs+#t$$;(F#''R^J_J_ 77& ' '  , ,SWWY-? @ @ F $SWW-D%E F FGG/0HHCGGK4H WW( ) y# & &9??+<+<*RQUBVBV[]gg56 %*[$*G*G3j^ij33 j3 j3j^ijj jrc&<V^8dQhRS[RS[/#rYr)rrs"rrrs553545rc \V\4'd\VP44#\V\4'dVFp\V\ 4'gV'dR#K&VP R4pVR8XdFVP RR4p\V\4'dVP4'dR#KKVR9gKR# R#VRJ;'dVR8g#)z`True when assistant ``content`` carries anything beyond (redacted) thinking blocks / whitespace.TrtextrFN>thinkingredacted_thinking)rrrrrrr)rZblockbtypers& rr!AIAgent._content_has_real_payloads gs # # ( ( gt $ $ !%..# &)F? 99VR0D!$,,#2>,"CC!d"44w"}4r"drop_thinking_only_and_merge_usersc&<V^8dQhRS[RS[/#rr{rr)rrs"rrrsTdrc ^RIHpV!4p\RV44pW28:dV#^.rTVF@pVPPR8XdWB8dK&V^, pVP V4KB \ PRW2, V4V#)zCap delegate_task calls in one turn at max_concurrent_children (non-delegate calls all kept); returns the original list when nothing was truncated.)_get_max_concurrent_childrenc3^"TF#qPPR8XgK^xK% R#5i) delegate_taskN)rzr)r"ros& rr$3AIAgent._cap_delegate_task_calls..s![2{{7G7G?7ZQQs- -rzUTruncated %d excess delegate_task call(s) to enforce max_concurrent_children=%d limit)tools.delegate_toolrsumrzrappendrrR)r{r max_childrendelegate_countkept_delegates truncatedros& r_cap_delegate_task_calls AIAgent._cap_delegate_task_callss E35 [[[  ) $%r B{{?2!1!#   R  :;I;XZf hrc&<V^8dQhRS[RS[/#rr)rrs"rrrsGGDGTGrc \4.r!VFpVPPp\P!\P !V4RRR7pVPPV3pWQ9d-\PRVPP4KVPV4VPV4K \V4\V48dV#T# \ \3dLi;i)zDrop duplicate (tool_name, arguments) pairs in one turn (first wins). Valid JSON arguments are canonicalized so key order/whitespace can't evade dedup; returns the original list when nothing was removed.T) separators sort_keyszRemoved duplicate tool call: %s),:)setrz argumentsrArBrXrTrUrrrRaddrr)r{seenuniquerorrs& r_deduplicate_tool_callsAIAgent._deduplicate_tool_callssubfB --I  JJtzz)'<_cd ;;##Y/C{@"++BRBRS HHSM MM" Vs:6vFJFz*  s-C""C65C6repair_tool_callinvalidate_system_promptinterruptible_api_call interruptible_streaming_api_calltry_activate_fallbackc <V^8dQhRS[/#rr)rrs"rrrsggtgrc ^\VR^4\\VRR4;'g.48#)uWhether a fallback provider remains (mirrors ``try_activate_fallback``'s guard) — gates the "trying fallback..." status so we never announce one that won't be attempted. See #17446. _fallback_index_fallback_chainN)r>rrs&r_has_pending_fallbackAIAgent._has_pending_fallbacks2 t.2SGXZ^9_9e9ece5fffrrestore_primary_runtimetry_recover_primary_transportbuild_api_kwargsc$<V^8dQhRS[RR/#)rdecisionrN)rm)rrs"rrrs LL1FL4Lrc VP'dVPfWnVP'd#\WPVP4R#R#)z?Record the first guardrail decision that should stop this turn.N) should_halt_tool_guardrail_halt_decisionrpactionrrrs&&r_set_tool_guardrail_halt AIAgent._set_tool_guardrail_haltsB    D$F$F$N19 .     %dOOX]] K rc&<V^8dQhRS[RS[/#rrrrmr)rrs"rrrs  <V^8dQhRS[RS[RS[RS[RS[RS[/#)rr function_argsfunction_resultfailedr`r)rrr)rrs"rrrs;  s 4 be .2 BE OR rcFVPPWW4R7pR;p;rVP4'd[VPPY\ V\ 4'dTMRWTR7p V P V PV PrpV'd\ V\ 4'dTpVPR9d \W64p\YV'dT MR4VP'dVP!V4MGVPP"p V e.V P$R9d\W<4pVP!V 4V'dT;'gRR,V,pV# \d"p \PRT 4Rp ? ELRp ? ii;i))rN)r`rz1stall-guard identical-call observation failed: %srz >haltr*)identical_call_streak_haltidentical_cycle_halt)_tool_guardrails after_call_stall_guards_enabled observe_callrrnoticestubkindr@rrrrnrqrr halt_decisionr) rrrrrr`r stall_notice result_stub stall_kind observationr streak_halts &&&&$$ r_append_guardrail_observation%AIAgent._append_guardrail_observationsr((33Io3m376 6{  % % ' ' W"33@@O]`AaAaogk!-A 9D8J8JKL\L\^i^n^n: :os;;)O ??. .7RO!$ *RVW      ) )( 3//==K&;+;+;?u+u";O"Y--k: .44">MO' W PRUVV WsAE44 F ?FF c <V^8dQhRS[/#rr)rrs"rrrs::t:rc .\\VRR44#)zCConfig gate for the runtime anti-stall guards (agent.stall_guards). _stall_guardsTrrs&rrAIAgent._stall_guards_enabledsGD/4899rc&<V^8dQhRS[RS[/#rr)rrs"rrrs440E4#4rc:VPV4\V4#r)rrors&&r_guardrail_block_resultAIAgent._guardrail_block_results %%h/)(33rc0<V^8dQhRS[RS[RS[RR/#)rreffective_task_idrrN)rrr)rrs"rrrs,"4"4t"4X["4mp"4y}"4rc VPpWW43pRVn\\V44;_uu_4\ V4^8:dVP !V!M^RIHp\V4pVe(VP'd\VP4MRp V!WYR7p \ V 4^8Xd5V ^,^,R8Xd VPM VP p V !V!M^RI H p V !V.VO5RV /RRR4RVn\VR R4'dRVn^R IHp V !R R 7R#R# +'giLD;i RTni;i) zExecute the assistant's tool calls and append results to ``messages``. The segment planner splits the batch into runs of parallel-safe calls (read-only, non-overlapping file targets, opted-in MCP) separated by sequential barriers, run in emission order. T)_plan_tool_batch_segmentsN) execution_cwdparallel)execute_tool_calls_segmentedsegmentsF_trim_after_tool_batchr4zlarge tool resultr)r{_executing_toolsrRrQr_execute_tool_calls_sequentialagent.tool_dispatch_helpersrrNr r _execute_tool_calls_concurrentagent.tool_executorrr>rr7r5)rr|rrrr{ryr active_envexec_cwdrrunrr5s&&&&& r_execute_tool_callsAIAgent._execute_tool_callss1 '11 !->O $ **+CD+IJJz?a'77>U!/0A!BJ7A7MR\R`R`R`tJNN3fjH8\H8})EMa[QR^WaEadAAgkhKhKT T4TTDT8TK%*D ! 415 9 9 +0D ' 7 2 3 :#KJ%*D !s*EAD0>A6D04E0 E ;E E c&<V^8dQhRS[RS[/#)rrrr)rrs"rrr?s   T  c  rc p^RIHpHpV!VPR4VPR4V!VPR44VPR4VPR4\ VR^4^8*VPR4VPR 4VPR 4VPR 4VR 7 #) zaSingle call site for delegate_task dispatch; new DELEGATE_TASK_SCHEMA fields are added only here.)_strip_model_hidden_task_fieldsrgoalcontexttasksrrrimagesr subagent_idr) r r r rr backgroundr rrr parent_agent)rr rrr>)rrr _delegate_tasks&& r_dispatch_delegate_taskAIAgent._dispatch_delegate_task?sh""6*M4E4Ei4P1-2C2CG2LM(,,-=>]EVEVW]E^#D*;Q?!D]M^M^_gMh $$X.%))-8-BSBST]B^mq   r invoke_toolc2<V^8dQhRS[RS[RS[RS[/#)rlabelrindentrr)rrs"rrrQs/ D DS D DS Ds Drc  ^RIp^RIp\^(VPR4P\ V4, 4p.pVP R4FTp\ V4V8:dVPV4K&TPVPWuRRR7;'gV.4KV V V 2RV,PV4,#)zqWord-wrap verbose tool output to the terminal width (each existing line separately), continuation lines indented.NrTF)widthbreak_long_wordsbreak_on_hyphens)x) shutiltextwraprget_terminal_sizecolumnsrsplitrextendwrapjoin)rrrrr wrap_width out_linesraw_lines&&& r _wrap_verboseAIAgent._wrap_verbosePs V55i@HH3v;VW !  4(H8} *  *  x\`sx!y"H"HG~HI ) %!TF]$8$8$CCCrzagent.tool_executorexecute_tool_calls_concurrentexecute_tool_calls_sequentialhandle_max_iterationsc0<V^8dQhRS[S[,/#rr&)rrs"rrrbsx}rc P\VRR4pV'd \V4#\VRR4pV'gR#\VRR4;'gTp\VRR4pVfV#VPV4;'gT# \d\P RRR7Tu#i;i) zSession-lineage ROOT id for Portal usage attribution, so one conversation keeps a single ``conversation=`` tag across compression rotation; subagents resolve via ``_parent_session_id``._cached_conversation_rootNrrQr9z%Conversation root lineage walk failedTr7)r>rget_conversation_rootr@rr)rcachedsidrdbs& r_conversation_root_idAIAgent._conversation_root_idbs:DA v; dL$/2D9@@S T=$ / :L ++E2;;e ;  LL@4L PL s#A>;A>>$B%$B%)rrrrr/rrrr~rrr;r9rNrrrrrr}r|rr&r{rzry)NNFr)FFNF)FFNNF>rwrarbrzr developer)r7)z )rrrrr&_TOOL_CALL_ARGUMENTS_CORRUPTION_MARKERpropertyrsettersysmaxsizerr<rCrUrgr staticmethodrrr_forwardrr_forward_static_stream_diag_init_stream_diag_capture_response_flatten_exception_chainr_log_stream_retry_emit_stream_droprr$_check_compression_model_feasibility_replay_compression_warningrrrrrrr rrrr'r.r2_anthropic_prompt_cache_policyr5r<rIrNrVr]r\reror~"_looks_like_codex_intermediate_ack_extract_reasoning_cleanup_task_resourcesrrrr$_summarize_background_review_actionsrrrr_build_memory_write_metadata$_apply_pending_steer_to_tool_resultsrrrrrrrrrrrrrOrE classmethodrWrdru_build_system_prompt_sanitize_coalesce_tool_call_idrnr{ frozenset_VALID_API_ROLES_sanitize_api_messagesrr#_drop_thinking_only_and_merge_usersrr _sanitize_uniquify_tool_call_ids_uniquify_tool_call_ids_repair_tool_call_invalidate_system_prompt_codex_deterministic_call_id_deterministic_call_id_codex_split_responses_tool_idrk(_codex_derive_responses_function_call_idrj_interruptible_api_call!_interruptible_streaming_api_call_try_activate_fallbackr_restore_primary_runtime_try_recover_primary_transport_build_api_kwargsrrrrrrr _invoke_toolr)rr_handle_max_iterationsr5rr)rs@rr%r%s 3 O+ __;; $4X\uy"&TaeAE!kk#'-1Y]"'[`"'t #r.2Z^EI$(e}A7;!%<@sw<@qu8JLHV[HH$((;=OP$,-@B`$a!./BD]^qq !!46HI !46HI E E  ,44TV{+|("*+KMi"jrr @@>> ss SS *2KK   0LLzzzz ZZ &..KMl%m"5=>[^N6O2DD @RS ()>@Z [**FG+,JK)56^)_&&'FH`a(01PRt(u%%&EG^_gg ((EG`a%-.KMl%m" !@BTULL   HJ  D::44"4"4H   9=IL D D D&..CEd%e"%-.CEd%e"%&EG^_rr%uh 💡 Usage Examples: # Use predefined toolsets python run_agent.py --enabled_toolsets=research --query='search for Python news' python run_agent.py --enabled_toolsets=development --query='debug this code' python run_agent.py --enabled_toolsets=safe --query='analyze without terminal' # Combine multiple toolsets python run_agent.py --enabled_toolsets=web,vision --query='analyze website' # Disable toolsets python run_agent.py --disabled_toolsets=terminal --query='no command execution' # Run with trajectory saving enabled python run_agent.py --save_trajectories --query='your question here'cV^8dQhRR/#rFrG)rs"rrrs%%T%rc 0^RIHpHp^RIHpHp\ R4\ R$4\ R4\ R%4...repV!4FCpV!V4pV'gKV\9dTMV\9dTMTp V PWx34KE \ R4VFSwrx\ RVR RVR , 24\ R VR ,'dR PVR ,4MR 24KU \ R4VFhwrx\ RVR RVR , 24\ RVR,'dR PVR,4MR 24\ RVR, 24Kj \ R4VF3wrx\ RVR RVR , 24\ RVR, 24K5 \ R4V!4P4Ffwrx\ RVR,'dRMR RV RVR , 24VR,'dKB\ RR PVR,4 24Kh V!4p \ R\V 4 R24\V 4Fp \ R V R!\V 4 R"24K \ \4R##)&zi``--list_tools``: print toolsets (basic / composite / scenario / legacy), every tool, and usage examples.)get_all_tool_namesget_available_toolsets)get_all_toolsetsget_toolset_infou 📋 Available Tools & Toolsets:u' 🎯 Predefined Toolsets (New System):u 📌 Basic Toolsets:u • 15z - descriptionz Tools: resolved_toolsz, rlu5 📂 Composite Toolsets (built from other toolsets):z Includes: includesz Total tools: tool_countu! 🎭 Scenario-Specific Toolsets:20u3 📦 Legacy Toolsets (for backward compatibility):z availableu✅u❌r: z Requirements: requirementsu 🔧 Individual Tools (z available):u 📌 z (from )Nz2--------------------------------------------------z(----------------------------------------) model_toolsrhritoolsetsrjrkprint_BASIC_TOOLSETS_COMPOSITE_TOOLSETSrr%r(rsortedrL_LIST_TOOLS_USAGE) rhrirjrkbasic_toolsetscomposite_toolsetsscenario_toolsetsrrbucket all_toolsrs r_print_tool_listingrsoF; ,- (O 45 (O<>B(9N "% 4'+'>^Z^buZuDV|MF MM4, ' #  "#$  tBis4 #6"789 FVAWAWDIId+;&<=]cdef% BC(  tBis4 #6"789 d:>N>Ntyyj)9:TZ[\] !$|"4!567) ./'  tBis4 #6"789 !$|"4!567( @A,.446  D--5594&4 CVBWXYK  &tyyn1E'F&GH I7#$I %c)n%5\ BCI&   {'*>y*I)J!LM' rc~V^8dQhR\\,R\R\\\,,/#)rrawrr)rrr)rs"rrrs.HSM#(49:MrcV'gR#VPR4Uu.uFq"P4NK pp\V RV 24V#uupi)uGComma-separated toolset CLI arg → list (echoed), or None when absent.Nrrs)r"rrx)rrtnamess&& r_parse_toolset_argrsE  # # /1WWYE / UG2eW  L 0sA c LV^8dQhR\R\R\R\RR/#)rr$result user_queryrrN)r%rr)rs"rrrs1 6 67 6D 6c 6RU 6Z^ 6rc R\\P!44R, R2pRVPVR,W!R,4R\P !4P 4RVRVR,R V/p\VR R R 7;_uu_4pVP\P!VR ^R74RRR4\RV 24R# +'giL ;i \dp\RT 24Rp?R#Rp?ii;i)z```--save_sample``: write one trajectory (same format as batch_runner) to a UUID-named JSON file.sample_:NNz.json conversationsr completed timestamprquerywzutf-8)encodingF) ensure_asciirNu" 💾 Sample trajectory saved to: u ⚠️ Failed to save sample: ) ruuiduuid4_convert_to_trajectory_formatr now isoformatopenwriterArBrxr@)r$rrrsample_filenameentryfrTs&&&& r_save_sample_trajectoryrsDJJL 1" 56e +, (O"$$ 4./?AXY/0AC[\ /0 JK GHG2/[k  +3HJ  | ,- /  # #J /F FG OF;/00B6+CVBWWhilmst~mjAiB CD  :VDT=UUVvz5A -.#  045s8E E& E!!E&__main__)r)r>webvisioncreativeterminalr>analysisresearch full_stack developmentcontent_creation) NrNr NNFFFF)rrModuleNotFoundErrorrrr<modules hermes_clirrestore_interrupted_pullrelaunch_after_restorerAlogging getLoggerrrrrtimerrr)typingrrrrrr pathlibr agent.session_sourcer r hermes_constantsr r"rEagent.iteration_budgetrFhermes_cli.env_loaderrGhermes_cli.timeoutsrHrI _hermes_home__file__parent_loaded_env_paths _env_pathrrvrLtools.terminal_tool_lifecyclerMrNtools.interruptrOrJtools.browser_tool_lifecyclerPtools.connectors.turnrQrRagent.memory_providerrSagent.client_lifecyclerTagent.stream_deliveryrUagent.status_outputrVagent.api_request_hooksrWagent.api_error_summaryrXrYagent.interrupt_controlrZagent.turn_explainersr[agent.activity_trackingr\agent.rate_limit_creditsr]agent.session_persistencer^agent.compression_facader_agent.turn_facader`agent.vision_message_prepraagent.reasoning_paramsrbagent.lazy_forwardrcr?rdr@rreagent.model_metadatarfagent.message_sanitizationrgrQrhrZrirVrrjr]rkr\rlagent.tool_guardrailsrmrnro/hermes_cli.observability.shared_metrics_harnessrprqutilsrrrsrtru_MAX_TOOL_WORKERSEvent_openrouter_prewarm_doner{rrrrrrr@rr%ryrzr|rrrragent.legacy_cli_legacy_cli_main SystemExitrGrrrsL  CKK'*//11..0    8 $  66G, D34X &