߲j\ ,UdZddlmZddlZddlZddlZddlZddlmZddl m Z m Z m Z m Z ddlmZmZej"dZehdZed d d8d Zd9d Zd:d;d Zd:d d?dZGddeej8Zej<ej<ej>ej@ejBdZ"de#d<ehdZ$ddddddej<dejBdej@diZ%de#d <d@d!Z&d"Z'd#Z(d$Z)d%Z*d&Z+ dAdd'd(d)d* dBd+Z,dCd,Z-iZ.d-e#d.<ej^Z0dAdDd/Z1dAdEd0Z2dFd1Z3dAdGd2Z4dHd3Z5Gd4d5Z6 dIddddddd6 dJd7Z7y)Kz`Child progress relay, console formatting and child system-prompt construction for delegate_task.) annotationsN)contextmanager)AnyDictListOptional)_active_subagents_active_subagents_lockztools.delegate_tool>errorfailedtimeoutFexc_infoc'K dy#t$rM}|Yd}~y|jdt|kDr||fz}tj|g|d|iYd}~yd}~wwxYww)uBest-effort block: any Exception is swallowed (never reaches the run) and, when ``log_message`` is given, logged at debug — the exception fills a trailing unsatisfied ``%s``.N%r) Exceptioncountlenloggerdebug) log_messagerlog_argsexcs A/home/ubuntu/.hermes/hermes-agent/tools/delegate_tool_progress.py_quietrsb@ @      S !CM 13&(H [?8?h? @s4A" A" AAA"eGbL! "$ 'S%.AQQR?SSr;c>|xsdjjdd}t|dkDr|dddz}|rd|d nd}t|}|d k(r|rd |nd}d ||d Sd|} |r| d |z } t ||} | r| d| j dz } | dzS)uOne clean, human-readable line describing a failed subagent, rendered directly to the user (CLI spinner echo, gateway platform notice). Says what happened and what to do next; never the raw exception when the child loop classified the failure, e.g. ``⚠️ Subagent failed — "research competitor pricing" after 12s: the model it was given was not found at the AI model service. Details: /agents, or ask me to retry with a smaller task.``r#  r>N9r'u — ""r z after u⚠️ Subagent timed outz without finishing. I will carry on without it; ask me to retry it, or raise delegation.child_timeout_seconds in config.yaml if these tasks legitimately take longer.u⚠️ Subagent failedz: .z;. Details: /agents, or ask me to retry with a smaller task.)r)replacerrEr:rstrip) goalstatusr duration_secondsr8 goal_label goal_partelapsedafterr/reasons rformat_subagent_failure_linerV@s*"##%--dC8J :_u, *4& A&"I/0G (/''#B' {5':  $I; /D ''## &~u =F  "V]]3'()) O OOr;c,eZdZdZdZdZdZdZdZdZ dZ y ) DelegateEventuFormal delegation progress event types. The relay normalises incoming legacy strings (``tool.started``, ``_thinking``, …) to these via ``_LEGACY_EVENT_MAP``; external consumers (gateway SSE, ACP adapter, CLI) still receive the legacy strings during the deprecation window. TASK_SPAWNED / TASK_COMPLETED / TASK_FAILED are reserved for future orchestrator lifecycle events, not emitted yet.zdelegate.task_spawnedzdelegate.task_progresszdelegate.task_completedzdelegate.task_failedzdelegate.task_thinkingzdelegate.tool_startedzdelegate.tool_completedN) __name__ __module__ __qualname____doc__ TASK_SPAWNED TASK_PROGRESSTASK_COMPLETED TASK_FAILED TASK_THINKINGTASK_TOOL_STARTEDTASK_TOOL_COMPLETEDr;rrXrX`s/K +L,M.N(K,M/3r;rX) _thinkingzreasoning.availablez tool.startedztool.completedsubagent_progresszDict[str, DelegateEvent]_LEGACY_EVENT_MAP> subagent.textsubagent.startsubagent.completeri _on_startrj _on_completerh_on_text _on_thinking _on_progresszDict[Any, Optional[str]]_EVENT_HANDLERSct|tst|tr |tvr|S tj |xs t|S#t tf$rYywxYw)uwLifecycle string / DelegateEvent / legacy string / ``delegate.*`` string → dispatch key; None for unknown events.N)r@rXr(_LIFECYCLE_EVENTSrgget ValueError TypeError)rs r_normalize_eventrvs]*m,J1LQ[_pQp $$Z0MM*4MM  "s!AA A z The workspace's project context files are reproduced below. Their conventions and invariants are binding for your work in this workspace. a Complete this task using the tools available to you. When finished, provide a clear, concise summary of: - What you did - What you found or accomplished - Any files you created or modified - Any issues encountered Important workspace rule: Never assume a repository lives at /workspace/... or any other container-style path unless the task/context explicitly gives that path. If no exact local path is provided, discover it first before issuing git/workdir-specific commands. Keep your final summary tight: lead with outcomes, prefer bullet points over paragraphs, and don't replay your whole process. Your response is returned to the parent agent as a summary, and overlong summaries crowd out the parent's context window.u ## Subagent Spawning (Orchestrator Role) You have access to the `delegate_task` tool and CAN spawn your own subagents to parallelize independent work. WHEN to delegate: - The goal decomposes into 2+ independent subtasks that can run in parallel (e.g. research A and B simultaneously). - A subtask is reasoning-heavy and would flood your context with intermediate data. WHEN NOT to delegate: - Single-step mechanical work — do it directly. - Trivial tasks you can execute in one or two tool calls. - Re-delegating your entire assigned goal to one worker (that's just pass-through with no value added). Coordinate your workers' results and synthesize them before reporting back to your parent. You are responsible for the final summary, not your workers. zYour own children MUST be leaves (cannot delegate further) because they will reach the maximum nesting depth. The system manages this automatically; no parameter override is available.zYour own children can themselves delegate because depth remains. The system determines this automatically from the nesting depth; children at the maximum depth cannot delegate further. No parameter override is available.leaf)workspace_pathrolemax_spawn_depth child_depthc\dg}|r$|jr|jd||rt|jr||jd|dd}tdd5d d lm}|t|d }d d d |jr&|jt |jz|jt|d k(r6|dz|k\rtnt} |jtd|d|dz| zdj|S#1swYxYw)aFocused system prompt for a child agent. role='orchestrator' appends a delegation-capability block (modeled on OpenClaw's buildSubagentSystemPrompt); its depth note is literal truth grounded in the passed config so the LLM can't confabulate nesting.z@You are a focused subagent working on a specific delegated task.z CONTEXT: z WORKSPACE PATH: zg Use this exact path for local repository/workdir operations unless the task explicitly says otherwise.r#z-subagent: workspace context-files load failedTrr)build_context_files_prompt)cwd skip_soulN orchestratorryzNOTE: You are at depth z3. The delegation tree is capped at max_spawn_depth=z. rG) r)appendr(ragent.prompt_builderr_CONTEXT_FILES_INTRO_COMPLETION_INSTRUCTIONS_LEAF_CHILDREN_NOTE_NESTED_CHILDREN_NOTE_ORCHESTRATOR_BLOCKjoin) rNcontextrzr{r|r}parts _ctx_filesr child_notes r_build_child_system_promptrs5P PE7==? |G9-.#n-335 !u u  Cd S ] G3N8KW[\J ]     LL- 0@0@0BB C LL)* ~,7!O,N(Ti  ' }4ghwgxxz{ |  99U  ] ]s )D""D+c ddlm}|tt|ddddt|ddt|ddg}td|D]}t d5t j jt j jt|}t j j|r,t j j|r |cdddcSdddy#1swYxYw)zBest-effort local workspace hint for child prompts: only a concrete absolute directory is ever injected (never a fake container path).r)scope_terminal_cwd_subdirectory_hintsN working_dir terminal_cwdr) agent.runtime_cwdrgetattrfilterrospathabspath expanduserr(isabsisdir) parent_agentr candidates candidatetexts r_resolve_workspace_hintrs5ggl  r;c |j|j|jd}|jdDcic]}t |||t ||c}|j t |j |d<dD]<\}}|jj|s"t|j|||<>|j|d<|Scc}w)N)rrrN)rrrrr))rchild_session_id)rrr) rrrQupdaterrlistrrsr(r)rkwksrcdsts r_identity_kwargsz$_ChildProgressRelay._identity_kwargs<s,0OO4??dhdsdst 0^1bijnpqbrb~1gdA&& A == $!$--0BzNa 5HC##C(d..s343 5 ??< @s CCNc |jr=td5|j||||fii|j|dddyy#1swYyxYw)NzParent callback failed: %s)rrr)rr tool_namepreviewrr s r_relayz_ChildProgressRelay._relayIsd >>45 nz9gtmGl$J_J_JaGlekGlm n n  n ns )A  Ac|jrDtd5|jjd|jd|dddyy#1swYyxYw)zIPrint one tree-view line above the CLI spinner (no-op without a spinner).zSpinner print_above failed: %srHu├─ N)rrrr)rrs r _tree_linez_ChildProgressRelay._tree_lineOs\ <<89 L ((1T\\^,>djj KK+uT\\^r;c|jr(|jdt|jd|jdd|xs|jxsdi|y)Nr7rr#)ri)rQrrrrrrrr s rrkz_ChildProgressRelay._on_start\sM ?? OOeF4??B$?#@A B Yg.N.NBYRXYr;c jdtvrCddlm}j}|fdt |dt |ddt |dd j d d iy) NrOr)render_notificationc jtjjdjdxsjdjdS)NrOsummaryrPr8)r rPr8)rrVrQrs)r rrsrz2_ChildProgressRelay._on_complete..ksW(DOOVZZ%9IAVAaZa%+ZZ0B%CTZT^T^_oTp)r;_notification_platformplatformcli_notification_config)r user_configr)rj)rsSUBAGENT_FAILURE_STATUSESgateway.warning_notificationsrrrr)rrrrr rparents` ` ` rrlz _ChildProgressRelay._on_completeasq ::h #< < I&&F !)A76S]_dCef#F,BDI    CCFCr;c*|jd|y)Nrhr)rrs rrmz_ChildProgressRelay._on_textts OW 5r;c||xs|xsd}|jdt|dd|jd|y)Nr#u💭 "rrJzsubagent.thinkingr)rrr)rrrrr rs rrnz _ChildProgressRelay._on_thinkingzs?)))r &b!1 2!45 ' 6r;c|xs|xsd}|r|jd||jr9td5|jd|j|dddyy#1swYyxYw)Nr#rz Parent callback relay failed: %srf)rrrr)rrrrr summary_texts rroz _ChildProgressRelay._on_progresss|!1G1r  OOeL>2 3 >>:; W2t||~6F|n4UV W W  W Ws %A''A0cp|xjdz c_|jHt5tj|j}||j|d<|xsd|d<ddd|j rBddlm}||xsdd|}|r t|dnd}|j|r|d |d n||jrg|jd ||||jj|xsdt|j|jk\r|j!yyy#1swYxYw) Nryrr# last_toolr)get_tool_emojirH#z "rJz subagent.tool)rrr r rsr agent.displayrrrrrrrr _BATCH_SIZEr) rrrrr recrr/shorts r_on_tool_startedz$_ChildProgressRelay._on_tool_starteds 1    '' 7'++D,<,<=?(,C %'0BC $  7 << 4$Y_"56a {CD+2F7B'E OOEtfCwa0t D >> KKGT B JJ  io2 .4::$"2"22 3  7 7s :D,,D5c ~t|}|dntj|d}|t||||||yy)Nr)rvrprsr)rrrrrr keymethods r__call__z_ChildProgressRelay.__call__sGz*/*=*=cCU*V   !GD& !)WdF C r;) rrArNr(rrrrrrAreturnNone)r r()r zDict[str, Any]NNN)rr(rr(rr()rr(r r )r r )rr(rr()rYrZr[r\rrrrrrrrkrlrmrnrorr rdr;rrrsZ K  %( 36 CF TW     n L Z D&6 7 W&Dr;r)rrrrrrc t|dd} t|dd} | s| sy| || d<t||| | ||||||| } || _| S)uRelay for one child's events (see ``_ChildProgressRelay``), or None when the parent has neither a spinner nor a progress callback — the child then runs with no progress callback at all (zero behavior change)._delegate_spinnerNtool_progress_callbackr)rrr) rrNrrrrrrrrrrrelays r_build_child_progress_callbackrsnl$7>G &>EI 9'3 O$ D'9j+yRWY^`hju E&E Lr;)r Optional[str]rrrbool) rrrrrrr rr r ))r rr,rAr r()r8rr rr,rAr r()rDrr r(r) rNrrOrr rrPrr8rr r()rrr r)N)rNr(rrrzrr{r(r|rAr}rAr r()r r)rrrrr r() rrrrArrArrr r()r/r(r r ) rrrrr/r(rrr r )rr(rrAr r()ry)rrArNr(rrArrrrrz Optional[int]rrrzOptional[List[str]]rzOptional[Dict[str, Any]]r zOptional[callable])8r\ __future__rloggingenumr threading contextlibrtypingrrrrtools.delegate_tool_registryr r getLoggerr frozensetrrr!r0r:rErVr(EnumrXrarbrcr^rg__annotations__rrrprvrrrrrrrrLockrrrrrrrrrdr;rr#sf" %,,R   0 1&&DEHM @ @, L8T\`P P!.P7:PUXPP P@ 4C 4 ,,(66!33#77&44 /+VWkZ%%t -)'  3Q y )-'QUci' '%'AN']`''+.' 'R .0*/%y~~' &^9CDCDLABcg#DY]$(RV:=S`,9IV"8P r;