Ki6dZddlZddlZejeZddlZddlZddlm Z m Z ddl m Z m Z mZmZegdZdZdZdZgd Zd efd Zd=d ed eed efdZdeed eefdZd>deded eefdZ d?ded ed eedeeedeededeedeedeedeefdZ d@ded ed e ee ffdZ dAd eed eedeeedeee ee fdeed ef dZ de!d e!fd Z"d e!fd!Z#d"d#d$d%d&d'd%d(d'd)d*d%id+d,d)d$d%d-d'd%d.d'd)d*d%id/d,d0d gd1dd2d3d4d5d'd6gd1d7Z$dd8l%m&Z&e&j'd"d9e$d:ed;<dS)Ba Delegate Tool -- Subagent Architecture Spawns child AIAgent instances with isolated context, restricted toolsets, and their own terminal sessions. Supports single-task and batch (parallel) modes. The parent blocks until all children complete. Each child gets: - A fresh conversation (no parent history) - Its own task_id (own terminal session, file ops cache) - A restricted toolset (configurable, with blocked tools always stripped) - A focused system prompt built from the delegated goal + context The parent's context only sees the delegation call and the summary result, never the child's intermediate tool calls or reasoning. N)ThreadPoolExecutor as_completed)AnyDictListOptional) delegate_taskclarifymemory send_message execute_code2)terminalfilewebreturncdS)zr r delegationcode_executioncg|]}|v| Srr).0tblocked_toolset_namess r z(_strip_blocked_tools..Ks$ B B B!1,A#A#AA#A#A#Arr)r$r+s @r_strip_blocked_toolsr-Fs2 C B B Bx B B BBr task_index task_countc t|dd t|dd ssdS|dkr d|dzdnddgd d td tf fd }fd }||_|S)aBuild a callback that relays child agent tool calls to the parent display. Two display paths: CLI: prints tree-view lines above the parent's delegation spinner Gateway: batches tool names and relays to parent's progress callback Returns None if no display mechanism is available, in which case the child agent runs with no progress callback (identical to current behavior). _delegate_spinnerNtool_progress_callbackr.[] r tool_namepreviewcp|dkrz rv|r t|dkr |dddzn|pd} d d|dn2#t$r%}td|Yd}~nd}~wwxYwdS r|r t|d kr |dd dzn|pd}d d lm}||}d d |d|}|r |d |dz } |n2#t$r%}td|Yd}~nd}~wwxYw r |t krrd }  dd |n2#t$r%}td|Yd}~nd}~wwxYw dSdSdS)N _thinking7z...r u ├─ 💭 ""zSpinner print_above failed: %s#r)get_tool_emojiu├─ z ", subagent_progress🔀 zParent callback failed: %s) len print_above Exceptionloggerdebug agent.displayr?r r!clear) r7r8shorter?emojilinesummary _BATCH_SIZE_batch parent_cbprefixspinners r _callbackz1_build_child_progress_callback.._callbackes  # # F29dc'llR>O>O"--V]VcacF''(KF(K(K%(K(K(KLLLL FFFLL!A1EEEEEEEEF F  B.5`#g,,:K:KWSbS\E))RYR_]_E 4 4 4 4 4 4"N9--E9v99e99i99D )(u(((( B##D)))) B B B =qAAAAAAAA B   MM) $ $ $6{{k))))F++BI13L63L73L3LMMMM BBBLL!=qAAAAAAAAB   ))sGA A=A88A=C(( D2DDE,, F6FFcrrrrd} dd|n2#t$r%}td|Yd}~nd}~wwxYwdSdSdS)z._flushs   ii''G D -/Hv/Hw/H/HIIII D D D ?CCCCCCCC D LLNNNNN     s. AAAN)getattrstrrV) r/ parent_agentr0rTrVrOrPrQrRrSs @@@@@r_build_child_progress_callbackr[Nsl$7>>G &>EEI 9t(2A~~ #a # # # #2FKF!!S!3!!!!!!!!!!FI rmodelmax_iterationsoverride_provideroverride_base_urloverride_api_keyoverride_api_modec ddlm} tt|ddpt|rt fd|D} n<|r&t|ddrt |j} nt t} t||} t|dd}|s*t|dr|j d}t||}|p|j }|pt|dd}|p|j }| p|}| pt|d d}t|d d}tt|d gpg}| d(id |d|d |d|d |d |d |d|dt|dddt|dddt|ddd| ddd| dd|dd|jdddddddt|ddd|jd|jd |jd!|jd"|d#d}t|d$dd%z|_t|d&rbt|d'd}|r5|5|j|dddn #1swxYwYn|j||S))a Build a child AIAgent on the main thread (thread-safe construction). Returns the constructed child agent without running it. When override_* params are set (from delegation config), the child uses those credentials instead of inheriting from the parent. This enables routing subagents to a different provider:model pair (e.g. cheap/fast model on OpenRouter while the parent runs on Nous Portal). r)AIAgentenabled_toolsetsNcg|]}|v| Srr)r)r*parent_toolsetss rr,z&_build_child_agent..s#.[.[.[Qa?FZFZqFZFZFZrapi_key_client_kwargsproviderapi_mode acp_commandacp_argsbase_urlr\r] max_tokensreasoning_configprefill_messages quiet_modeTephemeral_system_prompt log_prefix [subagent-]platformskip_context_files skip_memoryclarify_callback session_db _session_dbproviders_allowedproviders_ignoredproviders_order provider_sortr3iteration_budget_delegate_depthr._active_children_active_children_lockr) run_agentrcsetrXDEFAULT_TOOLSETSr-rdr#hasattrrhgetr[r\rmlistrvr|r}r~rrrr )r/rrr$r\r]rZr^r_r`rarcchild_toolsets child_promptparent_api_keychild_progress_cbeffective_modeleffective_providereffective_base_urleffective_api_keyeffective_api_modeeffective_acp_commandeffective_acp_argschildlockrfs @r_build_child_agentrs."!!!!!',0BDII]M]^^O@-.[.[.[.[(.[.[.[\\ @',0BDII@-l.KLL-.>??-dG<BB  (CQGG..%" ()&#66@VVD&*4]S%L*Q*QXWX,6~U|,T,T[..Z[% ! !  X  #ZZ1WXXE'N" "5*FMM & - - K489I4J4JK 1  |tjddiSt|dd}|tkrtjddtdiSt }|dt }|p|} t||} n:#t$r-} tjdt| icYd} ~ Sd} ~ wwxYw|r%t|tr|dt} nI|r1t|tr| r|||d g} ntjdd iS| stjdd iSt| D]I\} }|d d  stjdd| dicSJtj}g}t#| }d| D}ddl}t|j}g} t| D]\} }t)| |d |d|dp|| d| || d| d| d| d }||_|| ||f ||_n #||_wxYw|dkr;|d\}}}t/d|d ||}||n,d}t|dd}t1t5}i}|D]0\} }}|t.| |d ||}| ||<1t5|D]} |} n5#t8$r(} ||}!|!ddt| ddd} Yd} ~ nd} ~ wwxYw|| |dz }| d}!|!t#|kr||!nd|!}"| dd}#| d d!}$|$d"krd#nd$}%||z }&|%d%|!dzd&|d'|"d(|#d) }'|r9 ||'n4#t8$rt=d*|'YnwxYwt=d*|'|r`|&dkrZ |d+|&d,|&dkrd-nd d.[#t8$r&}(t@!d/|(Yd}(~(d}(~(wwxYw dddn #1swxYwY|"d01|rtG|d2r|j$r|D]} | dt#|kr|| dd nd })|j$%|)| d3d pd | dt#|kr#t|| dd4d5d nd 6#t8$rYwxYwtMtj|z d4}*tj||*d7d89S):a Spawn one or more child agents to handle delegated tasks. Supports two modes: - Single: provide goal (+ optional context, toolsets) - Batch: provide tasks array [{goal, context, toolsets}, ...] Returns JSON with results array, one entry per task. Nrz.delegate_task requires a parent agent context.rrz Delegation depth limit reached (z,). Subagents cannot spawn further subagents.r]rrr$z7Provide either 'goal' (single task) or 'tasks' (batch).zNo tasks provided.rrzTask z is missing a 'goal'.c.g|]}|dddS)rN(r)r)r*s rr,z!delegate_task..s$555a1V9SbS>555rrr$r\rirmrgrj) r/rrr$r\r]rZr^r_r`rar.r2) max_workers)r/rrrZrr/rr?ru✓u✗z [/r5z (zs)z rBz tasksz remainingzSpinner update_text failed: %sc|dS)Nr/r)rs rzdelegate_task..0s 1\?r)key_memory_managerrNr session_id)taskrchild_session_id)resultstotal_duration_secondsF) ensure_ascii)'jsondumpsrX MAX_DEPTH _load_configrDEFAULT_MAX_ITERATIONS_resolve_delegation_credentialsrrYrrMAX_CONCURRENT_CHILDRENr enumeraterrrCrrrrr rrsubmitrrrErDprint update_textrFrGsortrr on_delegationr)+rrr$rr]rZdepthcfgdefault_max_itereffective_max_itercredsr task_listir overall_startrn_tasks task_labels _model_tools_parent_tool_nameschildrenr*r_i_trcompleted_count spinner_refexecutorfuturesfutureridxlabeldurricon remainingcompletion_linerK _task_goaltotal_durations+ rr r sN"z7$TUVVV L"3Q 7 7E z <9<<<     ..Cww/1GHH';+;//\BB ///z7CHH-......../ `E4((`2223 `*T3''`DJJLL`"wHMMN z7$]^___ ;z7$89:::Y''KK4xx##))++ K:w(H(H(H(HIJJ J J J KN$$MG)nnG559555K '&&&lDEE HDi(( + +DAq&1V9aeeI6F6Fz**6heGn1 "' "3uZGX!&y!1"' "3 E0BE , OOQ5M * * * * +2D ..1C .CCCC!||  B"1bj%FFvl,?FF ,C D D D1 JG' $ $ 1e!% 6!- )#$&w//% J% J "MMOOEE   !&/C&)")#'!$S%&,- EEEEEE u%%%1$L),/#k2B2B,B,B C(( PS ii 2A668S11 &+ 5 5uu5#o5 %)"Q"QSU"Q"QW"Q"Q"Q"Q#"Q"Q"Q26#//@@@@$6664?44555556000111J9q==J#//0q 0q0qy\]~~ce0q0q0qrrrr$JJJ %EqIIIIIIIIJI% J1 J1 J1 J1 J1 J1 J1 J1 J1 J1 J1 J1 J1 J1 J1 Jh  22 333  .?@@ \Ea   E CHCVY\]bYcYcCcCcU5#67??ik ,::# 99Y339rdijvdwz}G{H{HeHeHWXeL6I-J1-M|]_%`%`%`NP;     4>++m;Q??N :"0   sB C "C?C C 9BJ J%AS3M/.S3/ N!9NS3N!!BS38Q S3Q-*S3,Q--S3 $R1/S31 S!;SS3S!!S33S7:S73BW WWrc pt|dpdpd}t|dpdpd}t|dpdpd}t|dpdpd}|rk|p&tjdd}|st d|}d }d } d |vrd }d } nd|vrd}d} ||||| dS|s|dddddS ddlm} | |} n)#t$r} t d|d| d| d} ~ wwxYw| dd}|st d|d|| d| d|| d| dt| dpgdS)uResolve credentials for subagent delegation. If ``delegation.base_url`` is configured, subagents use that direct OpenAI-compatible endpoint. Otherwise, if ``delegation.provider`` is configured, the full credential bundle (base_url, api_key, api_mode, provider) is resolved via the runtime provider system — the same path used by CLI/gateway startup. This lets subagents run on a completely different provider:model pair. If neither base_url nor provider is configured, returns None values so the child inherits everything from the parent agent. Raises ValueError with a user-friendly message on credential failure. r\rNrirmrgOPENAI_API_KEYzeDelegation base_url is configured but no API key was found. Set delegation.api_key or OPENAI_API_KEY.customchat_completionszchatgpt.com/backend-api/codexz openai-codexcodex_responseszapi.anthropic.com anthropicanthropic_messages)r\rirmrgrjr)resolve_runtime_provider) requestedz$Cannot resolve delegation provider 'z': z. Check that the provider is configured (API key set, valid provider name), or set delegation.base_url/delegation.api_key for a direct endpoint. Available providers: openrouter, nous, zai, kimi-coding, minimax.zDelegation provider 'z^' resolved but has no API key. Set the appropriate environment variable or run 'hermes login'.rjcommandargs)r\rirmrgrjr)r*) rYrrosgetenvrrhermes_cli.runtime_providerr'rEr) rrZconfigured_modelconfigured_providerconfigured_base_urlconfigured_api_keyrg base_lowerrirjr'runtimers rrrGs3777++1r2288::Bdcggj117R88>>@@HDcggj117R88>>@@HDSWWY//5266<<>>F$  7y)2..4466  <  )..00 % *j 8 8%H(HH J . ."H+H& +      &     HHHHHH**5HIII  Q3F Q Q3 Q Q Q    kk)R((G   O$7 O O O   "KK ++KK ++KK ++;;y))W[[((.B//  sE,, F6F  Fc ddlm}|di}|r|Sn#t$rYnwxYw ddlm}|}|diS#t$ricYSwxYw)aNLoad delegation config from CLI_CONFIG or persistent config. Checks the runtime config (cli.py CLI_CONFIG) first, then falls back to the persistent config (hermes_cli/config.py load_config()) so that ``delegation.model`` / ``delegation.provider`` are picked up regardless of the entry point (CLI, gateway, cron). r) CLI_CONFIGr&) load_config)clir5rrEhermes_cli.configr6)r5rr6fulls rrrs """"""nn\2..  J       111111{}}xx b)))  s# 00%A A)(A)r aSpawn one or more subagents to work on tasks in isolated contexts. Each subagent gets its own conversation, terminal session, and toolset. Only the final summary is returned -- intermediate tool results never enter your context window. TWO MODES (one of 'goal' or 'tasks' is required): 1. Single task: provide 'goal' (+ optional context, toolsets) 2. Batch (parallel): provide 'tasks' array with up to 3 items. All run concurrently and results are returned together. WHEN TO USE delegate_task: - Reasoning-heavy subtasks (debugging, code review, research synthesis) - Tasks that would flood your context with intermediate data - Parallel independent workstreams (research A and B simultaneously) WHEN NOT TO USE (use these instead): - Mechanical multi-step work with no reasoning needed -> use execute_code - Single tool call -> just call the tool directly - Tasks needing user interaction -> subagents cannot use clarify IMPORTANT: - Subagents have NO memory of your conversation. Pass all relevant info (file paths, error messages, constraints) via the 'context' field. - Subagents CANNOT call: delegate_task, clarify, memory, send_message, execute_code. - Each subagent gets its own terminal session (separate working directory and state). - Results are always returned as an array, one entry per task.objectstringzWhat the subagent should accomplish. Be specific and self-contained -- the subagent knows nothing about your conversation history.)type descriptionzBackground information the subagent needs: file paths, error messages, project structure, constraints. The more specific you are, the better the subagent performs.arrayr<zToolsets to enable for this subagent. Default: inherits your enabled toolsets. Common patterns: ['terminal', 'file'] for code work, ['web'] for research, ['terminal', 'file', 'web'] for full-stack tasks.)r<itemsr=z Task goalzTask-specific contextzToolsets for this specific taskr)r< propertiesrequiredzBatch mode: up to 3 tasks to run in parallel. Each gets its own subagent with isolated context and terminal session. When provided, top-level goal/context/toolsets are ignored.)r<r?maxItemsr=integerzSMax tool-calling turns per subagent (default: 50). Only set lower for simple tasks.)rrr$rr])rr= parameters)registryr&c t|d|d|d|d|d|dS)Nrrr$rr]rZ)rrr$rr]rZ)r r)r*kws rrrsp} XXf  ##*%%hhwxx 011VVN++  - - -ru🔀)rtoolsetschemahandlercheck_fnrLrW)r.)NNNN)NN)NNNNNN)(__doc__rr getLogger__name__rFr+rconcurrent.futuresrrtypingrrrr frozensetDELEGATE_BLOCKED_TOOLSrrrrrrrYr#r-rcallabler[rrr rrrDELEGATE_TASK_SCHEMAtools.registryrEregisterrrrrWs"   8 $ $ ????????,,,,,,,,,,,,#$$$ ...T S8C=C,C49CcCCCCEEsEcEZbckZlEEEEb(,'+&*'+ccc cc]ctCy! c C= c  c }c }csmc }ccccP  VSVSVS VS  #s(^ VSVSVSVSr!$(,0$( qq 3-q c]qtCy!q Dc3h( ) q SM q qqqqhVVVVVVrd8  I2!,!J  (+(   $)1+ N N,4E\#]#]$+&,h%7+L%%##"(  R#."7e9 9 ty==7YYz$#####    - -)       r