(Gj<:dZddlmZddlZddlZddlZddlZddlZddl Z ddl Z ddl m Z m Z ddlmZmZmZmZmZmZmZddlmZddlmZmZm Z m!Z!m"Z"ddl#m$Z$dd l%m&Z&dd l'm(Z(m)Z)dd l*m+Z+m,Z,m-Z-ej.e/Z0dBdZ1dZ2dZ3dCdZ4dDdZ5dZ6dEdZ7dddddddFd.Z8dGdHd1Z9d/d2dd3dId6Z:dJd8Z;dKd:ZZ>dMdNd?Z?d@dAgZ@dS)OuTool-call execution — sequential and concurrent dispatch. Both AIAgent methods (``_execute_tool_calls_sequential`` and ``_execute_tool_calls_concurrent``) live here as module-level functions that take the parent ``AIAgent`` as their first argument. ``run_agent`` keeps thin wrappers so existing call sites work; tests that patch ``run_agent._set_interrupt`` are honored because the extracted functions reach back through the ``run_agent`` module via ``_ra()`` for that symbol. ) annotationsN)AnyOptional) KawaiiSpinnerbuild_tool_previewbuild_tool_labelget_cute_tool_messageget_tool_emojiredact_tool_args_for_display_detect_tool_failure)ToolGuardrailDecision)_is_destructive_command_is_multimodal_tool_result_multimodal_text_summary!_append_subdir_hint_to_multimodalmake_tool_result_message)get_active_env)propagate_context_to_thread)maybe_persist_tool_resultenforce_turn_budget) BudgetConfigDEFAULT_BUDGETbudget_for_context_windowreturnrc tt|dddd}|rtt|ntS#t$r tcYSwxYw)aResolve a tool-result BudgetConfig scaled to the agent's context window. Large-context models keep the historical 100K/200K char defaults; small models (e.g. a 65K-token local model switched into mid-session) get a budget proportional to their window so a single large tool result can't push the request past the model's limit (#23767). Falls back to the default budget when the context length isn't resolvable. context_compressorNcontext_length)getattrrintr Exception)agentctxs 9/home/rurouni/.hermes/hermes-agent/agent/tool_executor.py_budget_for_agentr$6smge%94@@BRTXYY69M(S222~M sAAAAg@z@ float | Nonectjdd}|stS t |}n8#t $r+t d|ttcYSwxYw|dkrdS|S)N HERMES_CONCURRENT_TOOL_TIMEOUT_Sz8invalid HERMES_CONCURRENT_TOOL_TIMEOUT_S=%r; using %.0fsr)osgetenvstrip"_DEFAULT_CONCURRENT_TOOL_TIMEOUT_Sfloat ValueErrorloggerwarning)rawvalues r# _resolve_concurrent_tool_timeoutr4Ms )6 ; ; A A C CC 2112c  222 F  .   2111 2 zzt LsA2A76A7messagesliststagestrNonec ||dS#t$r'}td||Yd}~dSd}~wwxYw)a`Best-effort incremental SessionDB flush for tool-call progress. Tool execution can perform side effects that terminate or restart the current Hermes process before the normal turn-end persistence path runs. Flush the already-appended assistant/tool messages immediately so the transcript survives destructive-but-valid tool calls. z5Incremental tool-call persistence failed after %s: %sN)_flush_messages_to_session_dbr r0r1)r!r5r7excs r#%_flush_session_db_after_tool_progressr=_sp\ ++H55555 \\\NPUWZ[[[[[[[[[\s A AA cddl}|S)zRLazy reference to ``run_agent`` so patches like ``run_agent._set_interrupt`` work.rN run_agentr?s r#_rarArs r< RuntimeErrorboolc$dt|vS)Nz6cannot schedule new futures after interpreter shutdown)r8)r<s r#%_is_interpreter_shutdown_submit_errorrFxs Cs3xx OOrB) duration_msstatus error_type error_messagemiddleware_trace function_name function_argsdictresultreffective_task_id tool_call_idrGrrH str | NonerIrJrKOptional[list[dict[str, Any]]]c  ddlm} | ||||pdt|ddpd|pdt|ddpdt|ddpd|||| t| pg dS#t$rYdSwxYw)Nr)_emit_post_tool_call_hookr) session_id_current_turn_id_current_api_request_id) rLrMrOtask_idrVrQturn_idapi_request_idrGrHrIrJrK) model_toolsrUrr6r ) r!rLrMrOrPrQrGrHrIrJrKrUs r#_emit_terminal_post_tool_callr]|s 999999!!''%+ulB77=2%+E#5r::@b"5*CRHHNB#!'!"2"8b99            sA$A(( A65A6user interruptreasonc:tjd|dddS)NTool execution cancelled by cancelled)errorrHF ensure_ascii)jsondumps)r_s r#_cancelled_tool_resultrhs8 :>>b       !sBB B=B82B=8B=tuple[Any, dict]c  d  fd }ddlm}||||pdt|d dpd|pdt|d dpdt|d dpd }| fS)N next_argsrNrrcLt|tr|nSN)rrN)rexecuterM observed_argss r#_executez6_run_agent_tool_execution_middleware.._executes+%/ 4%@%@S m w}%%%rBr)run_tool_execution_middlewarer)rVrWrX) original_argsrYrVrQrZr[rrNrr)rrr) r!rLrMrPrQrrrrOrs ` ` @r#$_run_agent_tool_execution_middlewarers"M&&&&&&&& DCCCCC * *#!'R5,339r!'R1266<"u&?DDJ   F =  rBapi_call_countcX$TUV|j}t|}t}jrt jd|d|D]b}t|jj d|jj d|j td|jj cdSgU|D]} | jj } | dkrd _ n | d krd _ tj| jj} n#tj$ri} YnwxYwt%| t&si} d} d d lm} | | jkrO| | \}}}|s4|r2|t1vr|} |} ntjd d |did} n#t4$rYnwxYwt7| | t9| ddpd\} }d}d}| ;| }t;| | |t9| ddpddd| t=| nS d dlm }|| | pdt9ddpdt9| ddpdt9ddpdt9ddpdt=|}n#t4$rd}YnwxYw|Ptjd |id}t;| | |t9| ddpddd|t=| nj!"| | }|j#s_$|}d}t;| | |t9| ddpdddt9|ddpd t=| || d!vrnj%j&rb | 'd"d}|r8j%(|}j%)|d#| n#t4$rYnwxYw| d$krj%j&r | 'd%d}tU|ra| 'd&p%tWj,d'tWj-}j%)|d(|dd)n#t4$rYnwxYwU| | | |||fd*.d+UD}j/sPt9d,d-d.kr:t d/|d0|taUd1D]\}\}}}}}}tc||p|}tj|d} j2rqt d2|d3|d4t=|3d5t 4d6tj|d7d8t| j5kr| dj5d9zn| }!t d2|d3|d4t=|3d:|!UD]}\}}}}}}| j6rj tc||p|}to||}"6d;||"|O#t4$r!}#tqj9d<|#Yd}#~#ud}#~#wwxYw~UD]q\}}}}}}| j:r^ tc||p|}:|j ||C#t4$r!}#tqj9d=|#Yd}#~#id}#~#wwxYwrdg|zVtaUD]\}\}}}}}}| |||d>dd|fV|<|_;<d?|d@|VfdA}$d}%=rj>rVtj@tjB}&t|&dB|dCdDjCE}%|%D dFtaUD}'g}(iTt})t}*|*tjH|*znd}+|'rtt|'t},d dGlKmL}-|-|,H}.d}/ ta|'D]\}0\}}}} |.Mt|$||||U|dI}1n#t$r}2t|2s|'|0d}3tRdJt|3|3D]/\}4}5}6}7V|4 U|4dI}dK|6dL}8|6|7|8d>dd|fV|4<0Yd}2~2n#d}2~2wwxYw|(|1|T|1<tjG}9d}: dM};|+l|+tjHz }<|}=nYt|;|<};tjTU|(|;O\}=}>n$tjTU|(|;O\}=}>|>sn|+tjH|+krd}/TfdP|>D})UfdQ|)D}?tRdR|*t|)d*.|?ddS|>D]}1|1VjW5t=jX}@dddn #1swxYwY|@D]5}A tZd|A&#t4$rY2wxYwnjrpd}/|:s1d}:[jdTt|>dUdV|>D]}1|1VtjTU|>dWOnttjG|9z }B|Bd kr_|BdXzdYkrVTUfdZ|>D}?<d[|Bd\t|>d]d*.|?ddId5|.]|/ |/^n#|.]|/ |/^wxYw|%rRtd_VD}Ctd`VD}D|%_da|Cdb|dc|DdddenZ#|%rStd_VD}Ctd`VD}D|%_da|Cdb|dc|DdddewwxYwtaUD]\}\}}}}}}V|}Ed}F||)vr^|E\|*|*dddfndg}GdK|dh|G}Ht;|||Ht9|ddpddidj|Ht=| t|*pd>}In|Ejr>d|d}Ht;|||Ht9|ddpddkdldmt=| n=dK|dn}Ht;|||Ht9|ddpdd do|Ht=| d>}InY|E\} } }H}I}J}F}|Fsa| | |H|Jp}H|JrKt|H}Kt|Kdqkr |Kddqn|K}LtRdr| |I|L|FsF c| | |H|Jn,#t4$r}Mtqj9ds|MYd}M~Mnd}M~MwwxYw|FsSj6rL 6dt| dd|I|J|Hun.#t4$r!}#tqj9d<|#Yd}#~#nd}#~#wwxYwj2rCtqj9dv| dw|Idxdftqj9dyt|Hdz|H=r,t|||I|H{}Ned||Nnj/st9d,d-d.krt|H}Oj2r>t d}|d1zdw|Idxdft 4d~|OnHt|Oj5kr|Odj5d9zn|O}Pt d}|d1zdw|Idxd|Pd_;<d|d|Iddd|Fsfjfr_ tc||p|}f|j |||Hn.#t4$r!}#tqj9d|#Yd}#~#nd}#~#wwxYwt|Hs&t|H||j t|n|H}Hjjk||}Q|Qr%t|Hrt|H|Qn|H|Qz }Hm||H}Rt||R|j td|nd1tU}|d kr*| d}St|St||d krn|dSdS)zExecute 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)[Tool execution cancelled — # was skipped due to user interrupt]cancelled tool result r7Nmemoryr skill_managerqrc'O' is not available in this session. Use tool_search to find tools you can call.Frdidr)rLrMrPrQblockedtool_scope_block rLrMrOrPrQrHrIrJrKget_pre_tool_call_block_messagerVrWrXrYrVrQrZr[rK plugin_blockTguardrail_blockmessage Tool blocked by guardrail policy>patch write_filepathbefore terminalcommandworkdir TERMINAL_CWDbefore terminal: <z, c3(K|] \}}}}}}|VdSr).0_names r# z0execute_tool_calls_concurrent..s/LL(;4Aq!tLLLLLLrBtool_progress_modealloffu ⚡ Concurrent: u tool calls — rx 📞 Tool : ()Args: indentre...) - tool.startedTool progress callback error: Tool start callback error: z executing z tools concurrently: c ftjj} j5 j|dddn #1swxYwY jr4 td|n#t$rYnwxYw ddl m }| j n#t$rYnwxYwtj } |||jddt!|}nP#t"$r  dn#t$rYnwxYwt' ||t)|ddpd|t!| }tj |z } t*d || |||| dd |f|<Y j5 j|dddn #1swxYwY td |dS#t$rYdSwxYwt$r0} d |d | }t*d|| dYd} ~ nd} ~ wwxYwtj |z } t3||\} } | r&t*d|| |ddn*t*d|| t5||||| | d |f|< j5 j|dddn #1swxYwY td |dS#t$rYdSwxYw# j5 j|dddn #1swxYwY td |w#t$rYwwxYwxYw)z%Worker function executed in a thread.NTrset_activity_callback)r5pre_tool_block_checkedskip_tool_request_middlewaretool_request_middleware_tracekeyboard interruptrr)rLrMrPrQrjrKztool %s cancelled (%.2fs)FError executing tool '': z_invoke_tool raised for %s: %sexc_infoztool %s failed (%.2fs): %s#tool %s completed (%.2fs, %d chars)) threadingcurrent_threadident_tool_worker_threads_lock_tool_worker_threadsadd_interrupt_requestedrA_set_interruptr tools.environments.baser_touch_activityrm _invoke_toolrr6KeyboardInterrupt interruptrnrr0infodiscardrcr len)index tool_callrLrMrK _worker_tidrstartrOduration tool_erroris_errorrr!rPr5resultss r# _run_toolz0execute_tool_calls_concurrent.._run_tools  .006  , 8 8  & * *; 7 7 7 8 8 8 8 8 8 8 8 8 8 8 8 8 8 8  %  $$T;7777       E E E E E E ! !%"7 8 8 8 8    D   4  i++!!%L%+/15267G2H2H,  %   OO$89999 D@"/"/&7!(D"!=!=!C$%)*:%;%; 9;;. 7QQQ"/RVX]_o!p$0 @ @*22;??? @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ $$UK88888    + i i iP-PPJPP =}jcg hhhhhhhh iy{{U*H.}fEEKHa i 8-SYZ^[^Z^S_```` A=RZ\_`f\g\ghhh+]FHhX]_opGEN0 @ @*22;??? @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ $$UK88888     0 @ @*22;??? @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ $$UK8888    s'AA A "A>> B  B B&& B32B3 /C<:M< I DI  D+(I *D++A5I  M(GGG"G?? H  H  I &I?MI  B MLLL "L11 L?>L?N0 M1% N01M5 5N08M5 9N0="N N0 N-*N0,N--N0u ⚡ running z tools concurrentlydots spinner_typeprint_fnc2g|]\}\}}}}}}|||||fSrr)ritcrargsrK block_resultblocked_by_guardrails r# z1execute_tool_calls_concurrent..usD   YYBd$4lDX#D$ ###rB)DaemonThreadPoolExecutor) max_workerszWinterpreter shutdown while scheduling concurrent tools; skipping %d unsubmitted tool(s)rz<': Python interpreter is shutting down; tool was not startedg@c:h|]}||Sr)done)rfs r# z0execute_tool_calls_concurrent..s5555&'!&&((5 !555rB)timeoutc(h|]}|v|Srr)rr future_to_indexs r#rz0execute_tool_calls_concurrent..s3--- ! O33,A.333rBc,g|]}|dSrxr)rr parsed_callss r#rz1execute_tool_calls_concurrent..s2*** !)OA.***rBzIconcurrent tool batch timed out after %.1fs; %d tool(s) still running: %su⚡ Interrupt: cancelling z pending concurrent tool(s)forceg@c@g|]}|v|dSrr)rr rrs r#rz1execute_tool_calls_concurrent..s=*** ! O33));.s"@@!!-A----@@rBc3*K|]}||dVdS)Nr rrs r#rz0execute_tool_calls_concurrent..s&CCQQ]AaD]]]]CCrBu⚡ /z tools completed in .1fzs totalszthe configured timeoutz': timed out after r tool_timeoutrbriz*Tool execution cancelled by user interruptz!': thread did not return a resultthread_missing_resultfailedr"Tool %s returned error (%.2fs): %s(file-mutation verifier record failed: %stool.completedrrrOTool  completed in .2f Tool result ( chars): rO ✅ Tool Result: s - tool completed:  (s)Tool complete callback error: content tool_name tool_use_idenvconfig tool result r>r?)p tool_callsrr$rprint log_prefixappendrfunctionrrr=_turns_since_memory_iters_since_skillrfloads argumentsJSONDecodeErrorrrNr{rrTOOL_CALL_NAMEresolve_underlying_callrrgr rrr]r6hermes_cli.pluginsr_tool_guardrails before_callallows_execution_guardrail_block_result_checkpoint_mgrrgetget_working_dir_for_pathensure_checkpointrr*r+getcwdjoinry enumerate_redact_tool_args_for_displayverbose_loggingkeys _wrap_verboselog_prefix_charstool_progress_callback_build_tool_previewloggingrtool_start_callback _current_toolr _should_emit_quiet_tool_messages_should_start_quiet_spinnerrandomchoicerget_waiting_faces _print_fnrsetr4rm monotonicmin_MAX_TOOL_WORKERStools.daemon_poolrsubmitrrCrFr0r1 concurrentfuturesrcancelrrrAr_vprintrshutdownsumstopr._append_guardrail_observationr_record_file_mutation_result_get_cute_tool_message_impl _safe_printtool_complete_callbackrrr_subdirectory_hintscheck_tool_callr%_tool_result_content_for_active_model$_apply_pending_steer_to_tool_resultsr)Wr!assistant_messager5rPrrB num_tools _tool_budgetrrrLrM_ts_scope_blockr _underlying_underlying_args_errrKrrr block_messageguardrail_decision file_pathwork_dircmdcwdtool_names_strrrr display_argsargs_str args_previewpreviewcb_errrspinnerfacerunnable_callsrqtimed_out_indices timeout_sdeadliner rexecutorabandon_executor submit_indexr  submit_error skipped_calls skipped_i_tc skipped_name skipped_argsrO _conc_start_interrupt_logged wait_timeout remainingr not_done_still_running worker_tidstid _conc_elapsed completed total_durrrsuffixfunction_result tool_durationr _err_textresult_preview_ver_errcute_msg _preview_strresponse_preview subdir_hints _tool_contentturn_tool_msgsrrrsW` `` @@@r#execute_tool_calls_concurrentr2s #-JJI%U++L !  !SS9SSSTTT  B OO4  f1Afff    2Ar{/?AA      LW}W} !*/  H $ $()E % % n , ,'(E $  Jy'9'CDDMM#   MMM -.. M$  0 0 0 0 0 0 222696Q6QR_6`6`3 -t / /"&?&F&FFF(3 (8 *.*#!NK!N!N!N6 ). +/+/+/     D +S ''/ D"55; + + + ' ' $  &*L )++#"3$Yb99?R --!%&6!7!7      %NNNNNN ? ?!!-3&ulB??E2!(D"!=!=!C#E+=rBBHb#*52KR#P#P#VTV%)*:%;%; ! ! !  % % % $  %(#z7M*BQVWWW -"/"/'&7!(D"!=!=!C$-"/%)*:%;%;     &+%;%G%G Wd%e%e"):#(#@#@AS#T#TL+/(1&3&3+*;%,Yb%A%A%GR(#4&-.@)T&R&R&xVx)-.>)?)?       777Ed>d-??!?S"X!?!?!D Y }FVXdfz{||||YYLL|LLLLLN   X/CU K Ku T T N9NNnNNOOOYbcoqrYsYs X X UAUD$ 0,@T8tDDLLz,UCCCH$ XMQMM$MMl6G6G6I6I1J1JMMMNNNe))(DJ|TUdi4j4j4jkkllllLOPXMM\a\rLrLrx(?)?(?@5HHyA VQVV$VVdiikk1B1BVV VVWWWWP\ I ILD$(,8L  #   ' I I>??4 T Ti T T TcityuDEEE cc  ]fgs]t]t    &)ee466 3<3H4>##i//d R c.113DEEK C B B B B B//KHHHH$ H 9B>9R9R#+#+5L"51b$$OO7 BBAr4QUWcdeWfghWi(D\RR"!(6|}}(E > .. KX""FIsL,&y193? 3J13M 0%`\%`%`%`!' %1$0$*$'$($)$46" 234NN1%%%)*OA&&#ikk $)!Q#&L+$,t~/?/?$? $>>-0UU55+2555(DD,/|Y+G+GL-7-?-D-D '.E..ND((*4);)@)@#\*A**h$+0@0@H0L0L+/(----%----) ****%6***;% 122 IInRaR&899 "*''AHHJJJJ"<KK*.u/I*J*JKKKKKKKKKKKKKKKK#.%%C% # 4 4T3 ? ? ? ?#,%%% $%1+/(004-!MM#(#3!N!N#&x==!N!N!N&** "*''AHHJJJJ#*//#/FFF$' k(A$B$BM$q((]R-?!-C-C*****%-*** --[[["8}}[[:>))NSUTUSUDV:W:W[[[]Qp!!--#3"!!--#3"  c@@w@@@@@ICC'CCCCCI LLa aaIaa9aaaa b b b  c@@w@@@@@ICC'CCCCCI LLa aaIaa9aaaa b b b b  cV__kUlUlZ@Z@Q QBd,l

>\"B r!/p/ 3b=<p/= eA4e;p/eE)p//k p/kp/kp/ "lp/ l p/lDp/r!/q  r!!As8z {#z=={{,, |6||B /AB:B: AC%CAC C AC%cp4@At}t|jdD]\}Ajr|j|dz d}|r/jdt |dd|D]P}|jj}  t| d| d|j td |  QnAjj@ tjAjj} n;#tj$r)} t"d | i} Yd} ~ nd} ~ wwxYwt'| t(si} d} d d lm} @| jkr9| | \}}}|s|r|t3vr|@|} nd|d} n#t4$rYnwxYwt7@| t9Addpd\} }d}d}| | }d}n~ d dlm}|@| pdt9ddpdt9Addpdt9ddpdt9ddpdt?|}n#t4$rYnwxYwd}|$j !@| }|j"s|}|dup|du}|rn@dkrd _#n @dkrd _$j%st9dddkrtM@| p| }tj'|d }j(rqtSd!|d"@d#t?|*d$tS+d%tj'|d&d'nft |j,kr|dj,d(zn|}tSd!|d"@d#t?| *d)||s@_-.d*@|s( d d+l/m0}|j.n#t4$rYnwxYw|sqj1rj tM@| p| }te@|}1d,@||n.#t4$r!}tgj4d-|Yd}~nd}~wwxYw|sej5r^ tM@| p| }5Aj @|n.#t4$r!}tgj4d.|Yd}~nd}~wwxYw|sr@d/vrnj6j7rb | 8d0d}|r8j69|}j6:|d1@n#t4$rYnwxYw|s@d2krj6j7r | 8d3d} tw| ra| 8d4p%tyj=d5tyj>}!j6:|!d6| dd7n#t4$rYnwxYwtj?}"|Stj'd8|id }#d9}$t@| |#t9Addpdd:||t?|;  n|aA|}#d9}$t@| |#t9Addpdd:dt?|;  nw@d?krdfdD }%t@| t9Addpd|%E\}#} tj?|"z }$Cr)dFtd?| |$|#G n@dHkrdfdI }%t@| t9Addpd|%E\}#} tj?|"z }$Cr)dFtdH| |$|#G nc@dkrdAfdJ }%t@| t9Addpd|%E\}#} tj?|"z }$Cr)dFtd| |$|#G n׉@dKkrdfdL }%t@| t9Addpd|%E\}#} tj?|"z }$Cr)dFtdK| |$|#G nM@dMkrdfdN }%t@| t9Addpd|%E\}#} tj?|"z }$Cr)dFtdM| |$|#G nÉ@dOkr| 8dP}&|&r)t'|&t>rdQt |&dR}'n)| 8dSpdddT}(|(rdU|(dVndW}'d})CriErUtjGtjI}*t|*dX|'dYjJZ})|)K|)_Ld}+ dfd[ }%t@| t9Addpd|%E\}#} |#}+d_Ltj?|"z }$tdO| |$|+G},|)r|)M|, nPCrdF|, n"#d_Ltj?|"z }$tdO| |$|+G},|)r|)M|,wCrdF|,wwxYwjNr@jNvr d})CrtjGtjI}*t@}-tM@| p| }t@|p@}t|*dX|-dX|dYjJZ})|)Kd}. d@fd\ }%t@| t9Addpd|%E\}#} |#}.nQ#t4$rD}/tj'd8d]@d^|/i}#t"Qd_@|/d`Yd}/~/nd}/~/wwxYwtj?|"z }$t@| |$|.G},|)r|)M|,n+CrdF|,n#tj?|"z }$t@| |$|.G},|)r|)M|,wCrdF|,wwxYwjRr:jRS@rd})CrErtjGtjI}*t@}-tM@| p| }t@|p@}t|*dX|-dX|dYjJZ})|)Kd}0 d@fda }%t@| t9Addpd|%E\}#} |#}0nQ#t4$rD}/tj'd8db@d^|/i}#t"Qdc@|/d`Yd}/~/nd}/~/wwxYwtj?|"z }$t@| |$|0G},|)r|)M|,nCrdF|,n#tj?|"z }$t@| |$|0G},|)r|)M|,wCrdF|,wwxYwj%rd})CrErtjGtjI}*t@}-tM@| p| }t@|p@}t|*dX|-dX|dYjJZ})|)Kd}1 tU@| Aj jVpdt9ddpdt9ddpdjWrt?jWndddt9dddt9dedt?|f }#|#}1n#t$r_t@| t9Addpd|"t?|g}#|#}1 Zdhn#t4$rYnwxYwt4$r0}/di@dj|/}#t"Qdk@|/d`Yd}/~/nd}/~/wwxYwtj?|"z }$t@| |$|1G},|)r|)M|,nCrdF|,n#tj?|"z }$t@| |$|1G},|)r|)M|,wCrdF|,wwxYw tU@| Aj jVpdt9ddpdt9ddpdjWrt?jWndddt9dddt9dedt?|f }#n#t$r]t@| t9Addpd|"t?|g Zdhn#t4$rYnwxYwt4$r0}/di@dj|/}#t"Qdk@|/d`Yd}/~/nd}/~/wwxYwtj?|"z }$t'|#tr8j(r|#nt |#dlkr |#ddln|#}2t |#}3n|#}2t t|#}3t@|#\}4}5d dml]m^}6| o |6@}7|7rEt@| |#t9Addpdt|$dnzt?|o|sA`@| |#|4p}#j(r|#nt |#dlkr |#ddln|#}2|4rt"dq@|$|2nt"adr@|$|3|sF b@| |#|4n,#t4$r}8tgj4ds|8Yd}8~8nd}8~8wwxYw|sSj1rL 1dt@dd|$|4|#un.#t4$r!}tgj4d-|Yd}~nd}~wwxYwd_-.dv@dw|$dxdyj(rRtgj4dz@d{|$d|d}t|#}9tgj4d~t |9d|9|sfjdr_ tM@| p| }dAj @||#n.#t4$r!}tgj4d|Yd}~nd}~wwxYwt|#s&t|#@Aj t|n|#}#jhi@| }:|:r%t|#rt|#|:n|#|:z }#k@|#}; t@|;Aj td@ ldj%st9dddkrj(r;tSd|d{|$d|d}tS+d|#nkt'|#tr|#nt|#}jd|>dd|j|dD]P}|jj}  t| d| d|j td|  Qn>jmd kr1|t |jkrtjnjmt |j}?|?d kr(t|? dt||?d krl|?dSdS)z`Execute tool calls sequentially (original behavior). Used for single calls or interactive tools.rxNrrTrrrrrz(Unexpected JSON error after validation: rrqrrrr)rrrrrVrWrXrrrrrrFrdrrrrrrrrrzexecuting tool: rrrr>rrrrrrrrrrrcrrrrrrtodorrNrrcddlm}||d|ddjS)Nr) todo_tooltodosmergeF)rrstore)tools.todo_toolrrT _todo_store)r _todo_toolr!s r#rz/execute_tool_calls_sequential.._executesTCCCCCC!z#--00#--77+rB)rLrMrPrQrr2r1session_searchc }|s%ddlm}tjd|dSddlm}||dd|d|d d |d |d |d d|d|j S)Nr)format_session_db_unavailableF)successrc)rqueryr) role_filterlimitr rVaround_message_idwindowrsort) rrrrVrrrdbcurrent_session_id) _get_session_db_for_recall hermes_staterrfrgtools.session_search_toolrrTrV)r session_dbr_session_searchr!s r#rz/execute_tool_calls_sequential.._executes"==?? !dJJJJJJ:%B_B_BaBa&b&bcccWWWWWW&#--44 ) m < <#--33(}}\::&/mm4G&H&H$==155"v..!','7    rBcZ|dd}|d}ddlm}||d||d|d|j }jr"j||fd  |S) Ntargetr operationsr) memory_toolactionr;old_text)rrr;rrrcPtddS)Nr)rYrQ)_build_memory_write_metadatar)r!rPrsr#zAexecute_tool_calls_sequential.._execute..s/u/Q/Q$5)0D$)G)G0R00rB)build_metadata)rTtools.memory_toolr _memory_store_memory_managernotify_memory_tool_write)rrr _memory_toolrOr!rPrs r#rz/execute_tool_calls_sequential.._executes"x::&]]<88 IIIIII%$==22!%MM)44&]]:66)- ()BB!((((((C rBclarifycddlm}||dd|djS)Nr) clarify_toolquestionr)choices)rrcallback)tools.clarify_toolrrTclarify_callback)r _clarify_toolr!s r#rz/execute_tool_calls_sequential.._executesTLLLLLL$}&]]:r::%MM)44"3rB read_terminalc ddlm}||d|dtddS)Nr)read_terminal_tool start_linecountread_terminal_callback)rrr)tools.read_terminal_toolrrTr)r_read_terminal_toolr!s r#rz/execute_tool_calls_sequential.._executes]^^^^^^**(}}\::#--00$U,DdKKrB delegate_tasktasksu🔀 delegating u tasks · (/agents to monitor)goalru🔀 u · (/agents to monitor)u'🔀 delegating · (/agents to monitor) rrc.|Sr)_dispatch_delegate_task)rr!s r#rz/execute_tool_calls_sequential.._executes 88CCCrBc>j|S)N)r5)rhandle_tool_call)rr!rLr5s r#rz/execute_tool_calls_sequential.._execute<s# 3DD]T]hpDqqqrBzContext engine tool 'z ' failed: z1context_engine.handle_tool_call raised for %s: %src:j|Sr)rr)rr!rLs r#rz/execute_tool_calls_sequential.._execute^s 0AA-QZ[[[rBz Memory tool 'z1memory_manager.handle_tool_call raised for %s: %srtru) rQrVrZr[ enabled_toolsskip_pre_tool_call_hookrrtrurrrrrz&handle_function_call raised for %s: %sr)!agent_runtime_owns_post_tool_hookrl)rLrMrOrPrQrGrKr&r(rr)r*r+r6r7r"r8r,r-r.r#r/r0r9r:r@r3r4r5z remaining tool call(s)u[Tool execution skipped — z* was not started. User sent a new message]zskipped tool result rAr)pr$rYrBrrsrDrrFrrErrr=rfrIrJrKr0r1rrNr{rrrLrMrr rrrNrr6rOrPrQrGrHryrZrgr[rCr\r]r^rcrrrr_r`rarrbrSrrTrUrVrr*r+rWrmr]rRrrdryrerfrgrrhrir_delegate_spinnerrv_context_engine_tool_names_get_tool_emoji_build_tool_labelrcrhas_toolrAhandle_function_callrVvalid_tool_namesrrnrr8r agent.agent_runtime_helpersrrrwrrxrr{rrrr|r}rr~r tool_delaysleepr)Br!rr5rPrrrremaining_calls skipped_tcrrMerrrrrrK _block_msg_block_error_typer_guardrail_block_decisionr_execution_blockedrrrrrrrrrrtool_start_timerrr tasks_arg spinner_label goal_previewrr_delegate_resultremoji _ce_resultr _mem_result_spinner_resultr _result_len_is_error_resultrr_executor_must_emit_post_hookr _log_resultrr_fr_strrr num_tools_seqrLrsB` `` @@r#execute_tool_calls_sequentialr!s"%U++L!"3">BBR )R ) 9  % /:1Q344@O | !1nn3K_K_nnnvz {{{-   )27  8 f\fffM!! 6A<AA E!*/   Jy'9'CDDMM#    NNIaII J J JMMMMMM -.. M *.  0 0 0 0 0 0 222696Q6QR_6`6`3 -t "&?&F&FFF(3 (8 J JJJ(    D +S ''/ D"55; + + + ' '%) *  &(J 2   NNNNNN<<!!-3&ulB??E2!(D"!=!=!C#E+=rBBHb#*52KR#P#P#VTV%)*:%;%;        CG!  !&!7!C!CMS`!a!a %6 ?,>)'t3\7PX\7\  )  h & &()E % % n , ,'(E $ jGE3G$O$OSX$X$X8 VVgZgLz,UCCCH$ jVQVV-VV$|?P?P?R?R:S:SVVVWWWe))(DJ|TUdi4j4j4jkkllllLOPXMM\a\rLrLrx(?)?(?@5HHyA hQhh-hh$}?Q?Q?S?S:T:ThhZfhhiii! F"/E   ! !"D]"D"D E E E "  IIIIII%%e&;<<<<    " Ie&B I I<]MZZk^k -m\JJ,,^]GUabbbb I I I GvGGHHHHHHHH I" Fe&? F F<]MZZk^k ))), |TTTT F F F DFDDEEEEEEEE F" m7N&N&NSXShSp&N )--fb99 $4MMiXXH);; ";M";";    " mz&A&AeF[Fc&A #'' 266*3//'++I66`")NTVT]T_T_:`:`C);;;SbS;;    )++  !"j':)>USSSOM )++&"3$Yb99?R ,(!%&6!7!7     ' 2$;;v}Vcl{#|#|#|~~ . . .      ".R++"3$Yb99?R ... *O]!IKK/9M5577 J I#>?OQ^`mwF$G$G$GIIJJJ h & &        2.R++"3$Yb99?R ... *O]!IKK/9M5577 B A#>xXen}#~#~#~AABBB i ' '      .R++"3$Yb99?R ... *O]!IKK/9M5577 C B#>y-Yfo~###BBCCC o - -      .R++"3$Yb99?R ... *O]!IKK/9M5577 I H#>P]_lvE$F$F$FHHIII o - -%))'22I Z 488  a3y>> a a a - 1 1& 9 9 ?R"E $CBLBBBBB G5577 E<]<]<_<_ }]%D%F%FGG'4(A(A-(A(APVafapqqq &-E ##  3DDDDDD1U"/"/&7!(D"!=!=!C$ 222.$3 *.' $ o = 6 Wdm}~~~3LL****;;==3MM/x//222 +/' $ o = 6 Wdm}~~~3LL****;;==3MM/x//22223  -W :-5Cc2c2cG5577 }]%D%F%FGG' 66<]MZZk^k +M<HHYM'4(C(C%(C(C'(C(CRXchcrsss J 3rrrrrrrr1U"/"/&7!(D"!=!=!C$ 222.-  | | |"&*g7t}7t7thr7t7t-u"v"v PR_akvz {{{{{{{{ |!% o = 6}mUbkuvvv3LL****;;==3MM/x//222 !% o = 6}mUbkuvvv3LL****;;==3MM/x//22223  "v :u'<'E'Em'T'Tv :G5577 E<]<]<_<_ }]%D%F%FGG' 66<]MZZk^k +M<HHYM'4(C(C%(C(C'(C(CRXchcrsss K 3\\\\\\\1U"/"/&7!(D"!=!=!C$ 222..  | | |"&*g7l}7l7l`j7l7l-m"n"n PR_akvz {{{{{{{{ |!% o = 6}mUbkvwww3LL****;;==3MM/x//222 !% o = 6}mUbkvwww3LL****;;==3MM/x//22223  T :G5577 E<]<]<_<_ }]%D%F%FGG' 66<]MZZk^k +M<HHYM'4(C(C%(C(C'(C(CRXchcrsss "O( 3"%%%"<"<!=2C!*$/52#E+=rBBHb#*52KR#P#P#VTVBGBX"b$u'=">">">^b,015%,U4F%M%M&-e5H$&O&O267G2H2H#= # ##2$   "I"/"/&7!(D"!=!=!C.%)*:%;%;####2OO$89999 D q q q"Y="Y"YZ"Y"Y E}V`ko pppppppp q!% o = 6}mUbkz{{{3LL****;;==3MM/x//222 !% o = 6}mUbkz{{{3LL****;;==3MM/x//22223 q"%%%"<"<!=2C!*$/52#E+=rBBHb#*52KR#P#P#VTVBGBX"b$u'=">">">^b,015%,U4F%M%M&-e5H$&O&O267G2H2H#= # #%   7"/"/&7!(D"!=!=!C.%)*:%;%;OO$89999 D q q q"Y="Y"YZ"Y"Y E}V`ko pppppppp q!IKK/9M os + + 4050E__),_)=)=)C)C%% o..KK-Nc/2233K3=/RR! RQQQQQ" " H11%GG & )  )++&"3$Yb99?R  455!%&6!7!7    " #AA' BO 160E__),_)=)=)C)C%%   j NN?P]_m n n n n KK=}m]h i i i " T T22!=/CS T T T H(SSSSSSSS T" Ie&B I I,,$mT4*5E*-  I I I GvGGHHHHHHHH I# WWW-WWWWXXX   T MS-SS}SSSS T T T2?CCK MR#k*:*:RR[RR S S S! Ie&B I I<]MZZk^k ,,Y\=,Xghhhh I I I GvGGHHHHHHHH I,O<< R3##! 011     CR 0@@P]^^  0)/:: 01/<PPPP</CCMSbcc 0 y|\\]]]-  000     228Q??? `GE3G$O$OSX$X$X$ `IAII]IIIIJJJe))*oFFGGGG-7-M-Mg//SVWfSgSgORSZ||^c^tOtOt7+BE,B+B#Ce#K#K{B ^A^^]^^^L\^^___  % !c2C2N.O.O*O*O-899A=I MMU-iiyiiiquM v v v/:122>   )27  8 k<kkkM!! 6??? E  a  A,=,H(I(I$I$I Ju' ( ( ()455MqHm^__5>J[;\;\eqrrrr q 228]KKKKKs:C<<D4 D//D4A F F)(F) A,I  II3P  PP$:Q R )RR .S S1S,,S1AU U%$U%=BX XX 1l44A7n+$3ru s&":s!u!s&&uA0w '2{~ |($:|#~#|((~A0A@ CB$AE3E2AJE3AAHF4AG G AHG AGGAHGAGG AHG$&AHH AJHAHHAJJA0AK7K;B"ANN>AP=OAO3O2AP=O3 APO=AP=O?APP AP=P &AP8P8AP=V3AW W AW5WAW0W0AW5XAXX AY X)AYYAY [/A\\ A\/\A\*\*A\/rr!)rr)rr&)r5r6r7r8rr9)r<rCrrD)rLr8rMrNrOrrPr8rQr8rGrrHrRrIrRrJrRrKrSrr9)r^)r_r8rr8)rLr8rMrNrPr8rQr8rjr.r_r8rIr8rKrSrr8)rro) rLr8rMrNrPr8rQr8rr) rLr8rMrNrPr8rQr8rr)r)r5r6rPr8rrrr9)A__doc__ __future__rconcurrent.futuresrprfrar*rfrrmtypingrr agent.displayrrr`rrr ryr rr rZr agent.tool_guardrailsr agent.tool_dispatch_helpersrrrrrtools.terminal_toolrtools.thread_contextrtools.tool_result_storagerrtools.budget_configrrr getLogger__name__r0r$rmr-r4r=rArFr]rhrnrrrrr!__all__rrBr#r0sC  #"""""   877777=<<<<<XWWWWWWWWW  8 $ $    "&+"$\\\\& PPPP! $7;       F$#*7;:....b!!!!6!!!!@O HO HO HO HO Hfa La La La La LN$# rB