߲jQdZddlmZddlZddlZddlZddlmZmZm Z m Z ddl m Z m Z ejdZd#dZd$dZd d d d%d Zehd ZehdZd&dZd'dZd(dZd)dZd*dZdZdZdZd+dZd,dZd-dZ d.dZ!d/dZ"ejFZ$ejJZ&ejJZ'dZ(d0dZ)d1dZ*d2dZ+d3d Z, d4d!Z-d5d6d"Z.y)7zmSubagent result post-processing: summary budget/spill, tool-trace summaries, lifecycle hooks and cost rollup.) annotationsN)AnyDictListOptional)urlsplit urlunsplitztools.delegate_toolc|yt|tr|St|trdjd|DSt|trt j |dtSt|S)zStable text for tool-result content. Some OpenAI-compatible paths return content-block lists; observability must never crash on them. c3K|]o}t|tr$t|jdtr|dn6t|trt j |dtn t|qyw)textF ensure_asciidefaultN) isinstancedictgetstrjsondumps).0items @/home/ubuntu/.hermes/hermes-agent/tools/delegate_tool_results.py z*_stringify_tool_content..sa 'tT2z$((6BRTW7XDLFPQUW[F\DucBT  sA5A7Fr)rrlistjoinrrr)contents r_stringify_tool_contentr sn'3'4 yy     '4 zz'sCC w<c t|}|sy|jjdrt tj|}t |trN|jdsr$failedfailuretimeoutTr)zerror:zfailed:z traceback z exception:) rlstrip startswithrloads Exceptionrrrrstriplower splitlines)rparsedfirsts r_looks_like_error_outputr2s&g.G ~~"":. ZZ(F fd # JJw 3vzz(';'Ar#B#H#H#J#P#P#RV#7>7I7I7KG    # ) ) + 1 1 3QSE   M NN F sC44 DD i@) max_entries max_charsc t|tr|jdnd}t|tsgS|Dcic]}t|trt|jddk(r`|jdxsgD]H}|jdr5|dt |jdxsijdxsd J}}}g}t |D]}t ||k\rnt|tr|jdd k7r8t|jd xsd }|j|jd xsd d } |j| |d|t|d |j|Scc}}w)ajLast N tool-call results ``{tool, preview, is_error}`` from a child's conversation (the overlay's "Output" section), chronological order. Content blocks are flattened first so a block-wrapped "Error: ..." is still flagged; line structure is preserved (capped at ``max_chars``) so the overlay shows real output rather than a whitespace-collapsed blob.messagesNrole assistant tool_callsidfunctionnametoolrr tool_call_id)r>previewis_error) rrrrrreversedlenrappendr2reverse) resultr4r5r7msgtcname_by_call_idtailr tool_names r_extract_output_tailrL2sr *4FD)Avzz*%tH h %  z#t4K9W'','-2  4#rvvj)/R44V<FGGO "$D!x t9 # #t$6(A )#'')*<*BC#''(?(E2vN  Y7:I3FTlmtTuvwx LLN KsB F>cwddstsrcurlpathurlsendpointnew_pathold_path directory file_path source_path target_pathdestination_path>rPrRrSct|tr$fd|ddDDcgc]}|| }}|xsdSt|tr|sy|dd}tvr t |}|j rj|j r^|j}|syd|vrd|dn|}|j|d|jn|}t|j ||jddfS|S|Scc}w#t$rYywxYw) z.Ts$]$%:3%E$]sNi:r#]r ) rrr_TOOL_INPUT_URL_KEYSrschemenetlochostnameportr rQ ValueError) r^valuercleanedboundedr0rehostrds ` rr]r]Qs%$]RWX[Y[R\$]rDaeaq4rr$ eS !ETlG "" g&F}}!??+./8*Ax4:KK4KD66;;-0QU!6==&&++r2"NOO N7N)s$  s#CC1C! AC!! C-,C-ci}|jD];\}}t|j}|tvs(t ||}|7|||<=|S)zNKeep only known side-effect target keys, each sanitized (URL secrets dropped).)itemsrr._TOOL_INPUT_TARGET_KEYSr])mappingtargetsraw_keyrhr^ris r_sanitize_targetsrrjs] G!--/''l  " ) )+C7G"& ' Nr ct|tr|ddDcgc]}t|ddc}ngt|tr t |dSidScc}w)zT``{argument_keys, targets}`` with bounded, sanitized contents (empty on bad shapes).N@) argument_keysrp)rrrrrr)keysrpr^s r_input_summaryrxus]CMTSWBXD"I>S#c(4C.>^`1;GT1J$W- PR >sAc t|trtj|nd}t|t s tgiSttd|D|S#tt f$rd}YKwxYw)zFSummarize argument names and side-effect targets without raw payloads.Nc38K|]}t|ddyw)Nru)r)rr^s rrz,_summarize_tool_arguments..s BCS$3 Bs) rrrr+ TypeErrorrgrrxsorted) argumentsr0s r_summarize_tool_argumentsr~|sl*4Y*DI&$ fd #b"%% & B6 BBF KK z "s'A!!A54A5c t|tsgSdd}g}|D]}t|tst|j dxsdj }|j d}t|tr|ni}|j t|j dxsdddt|j d|j d ||d ||d |d vr|ndd |S)zXDetached, metadata-only tool history for lifecycle hooks (input summaries re-sanitized).c|j|d}t|ttfr%t|tst dt|SdS)Nr)rrintfloatboolmax)rr^rhs r _byte_countz5_subagent_stop_tool_call_history.._byte_countsAa %/U|%DZX]_cMds1c%j!kjkkr r%unknown input_summaryr>Nrvrp args_bytes result_bytes>okr$)rK tool_input input_bytes output_bytesr%)r^rreturnr)rrrrrr.rDrx) tool_tracerhistoryrr%summarys r _subagent_stop_tool_call_historyrs j$ ' l%'G  $% TXXh'495;;=((?+'6'BTXXf-:;DSA(_)Ew{{S\G]^&t\:KX\^lLm &/ 9fy     Nr i]?icF ddlm}ddl}|dd}|jdd|d|d |jj j d d z }dd lm}|||d t|S#t$r }tjd|Yd}~yd}~wwxYw)u%Write the full summary under ``cache/delegation`` (mounted read-only into remote backends via ``credential_files._CACHE_DIRS``, so the parent's terminal/``read_file`` can page it on any backend). Absolute path, or None on failure — the trimmed head+tail is still returned regardless.r)get_hermes_dirNzcache/delegationdelegation_cacheT)parentsexist_okzsubagent-summary--z%Y%m%d_%H%M%S_%fz.txt)write_text_exclusiveF)privatez,Failed to spill subagent summary to file: %s) hermes_constantsrdatetimemkdirnowstrftimetools.spill_safetyrrr,loggerdebug) task_indexrr_dt cache_dirrQrexcs r_spill_summary_to_filers 3"#57IJ t4.zl!CLL$D D B K# CRy 4BB"s""BFG}' G>/ *PTD$e %$(4y r c t|dd}t|dd}t|tr|dkryt|}|y|t|z tt|ddxsdz }|dkrtSt|t zt d|z}t t|dzS#t$rtjdd YywxYw) uPer-summary char budget from the parent's *remaining* context headroom (context length − the parent's current prompt size − the compressor's output reserve), a fraction of it split across the batch at ~4 chars/token. None when the parent's context state is unknown — caller then uses the static ceiling only. "Current prompt size" is the last API call's ``prompt_tokens`` (``_last_turn_usage``), never ``session_prompt_tokens``: that field is the running SUM over every call in the session, so after a few hundred calls it exceeds any context window and every summary collapsed to the 2,000-char floor (measured: all 1,393 child summaries in one run, each spilled to disk, the orchestrator working from the stub).context_compressorNcontext_lengthr max_tokensrz!Summary budget computation failedTexc_info) rrrr_MIN_SUMMARY_CHARS_SUMMARY_HEADROOM_FRACTIONrr,rr)r n_summaries compressorr used_tokensheadroom_tokensper_summary_tokenss r_parent_summary_char_budgetrs\+?F  -=tD.#..A2E0>  (3{+;;c'*VbdeBfBkjk>ll a % % 3M!MNRUVWYdRee%'9A'=>>  84 Hs"/B& B&3B&41B&& C C c ddlm}|Dcgc];}t|tst|j dt s4|ds:|=}}|sy t |j dt}|t|t|fDcgc] }|s|dkDs |}}|syt|}|D]}} | d} t| |krt| || j dd\} } | | d<d| d <| r| | d <tjd | j dd t| || xsd ycc}w#ttf$r t}YwxYwcc}w)a0Trim subagent summaries in-place so a batch can't overflow the parent's context window (full text spilled to disk). Per-summary cap = MIN(dynamic headroom budget, static ``delegation.max_summary_chars`` ceiling; 0 = disabled); over-cap summaries become head+tail plus a pointer to the spill file.r) _load_configrNmax_summary_charsrTsummary_truncatedsummary_full_pathu9[subagent-%s] summary trimmed %d → ~%d chars (spill=%s)?none)tools.delegate_toolrrrrrrDEFAULT_MAX_SUMMARY_CHARSr{rgrrCminrrr) resultsrrr summariesstatic_ceilingc candidatesrentryr model_textrs r_apply_summary_budgetr sj1#rqz!T':z!%%PYJZ\_?`efgpeqrIr 3\^//0CE^_`-.I,X[\eXf.ghxlmrsvwrw!xJx  j/C   " w<3  !:7CS_acId!e J%i%)!" )3E% & GS_adIegjkrgsux  &   s z "323xs:D3D3D3D3$D8EEE8EEc ddlm}ddl}t5t |j } |di|}||_ ddd_|S#||_wxYw#1swYxYw)zCBuild a child without leaking its resolved toolset into the parent.r)_build_child_agentN)rr model_tools_CHILD_CONSTRUCTION_LOCKr_last_resolved_tool_names_delegate_saved_tool_names)kwargsrrparent_tool_nameschilds r$_build_child_preserving_parent_toolsr,sl6 !F !F!FG F&00E4EK 1 F (9E$ L5FK 1 FFs!AA A AAAc|tSt|dd}||St5t|dd}|"tj} t |d|ddd|S#t $rtcYcdddSwxYw#1swY|SxYw)zRPer-parent lock serializing lifecycle side effects (created once under the guard).N_subagent_finalization_lock)"_PARENT_FINALIZATION_FALLBACK_LOCKr_PARENT_FINALIZATION_LOCK_GUARD threadingRLocksetattrr,)rlocks r_parent_finalization_lockr9s11  ED  (:|%BDI <??$D : &CTJ : K :99::  : : Ks)$A: AA7+A:6A77A::Bc l|r t|ddnd}|sy|D]} |jdd}t|txrd|cxkxrt |knc}|j |r||dnd|jddxsdt|j|dd y#t $rYwxYw) N_memory_managerrrrgoalr r session_id)taskrFchild_session_id)rrrrrC on_delegationr,)r task_listchild_by_indexrmemoryrrin_ranges r_notify_memory_managerr Js?KW\#4d ;QUF   <4J!*c2WqJ7WY7WH  6>Yz*62BuyyYbdfOgOmkm!(););J)GWY!Z !     sB B'' B32B3c ddlm}d}|D]}|jdd}|jdd} |r|t |z }|; |j|jdd}|d t|d dt|d d xsd t|d d||jd |jdt|jdt|jdxsddz |S#t$rd}YwxYw#t t f$rYwxYw#t$rtjddY5wxYw)zPop the model-hidden ``_child_role`` / ``_child_cost_usd`` fields from every entry, fire ``subagent_stop`` per child, and return the summed child cost.r) invoke_hookN _child_role_child_cost_usdrr subagent_stopr_current_turn_idr rr%rduration_secondsi)parent_session_idparent_turn_idr child_role child_summary child_statustool_call_history duration_msz$subagent_stop hook invocation failedTr) hermes_cli.pluginsr r,poprr{rgrrrrrr) rrrr children_cost_totalrr child_costrs r_fire_subagent_stop_hooksrYs^APYY}d3 YY0#6  #uZ'88#    P"&&uyyr'BCE 7<W[3\&|5GLRPR!( d!CPZ#ii 28AT"B599\CZ"[+=!>!C!t KL  P, 3  :&    P LL?$L O Ps5C8D B,D8 DD DD EEc|dkry tt|ddxsd}||z|_t|dddvrd|_t|dd d vrd |_yy#t $rt jd d YywxYw)zzFold the children's spend into the parent's session cost (source/status only set when the parent had none of its own).r Nsession_estimated_cost_usdsession_cost_sourcer>Nr rsubagentsession_cost_statusr>Nr r estimatedzSubagent cost rollup failedTr)rrr r!r#r,rr)rrcurrents r_rollup_children_costr&ysc!C .JCPWTWX295%%,KKw ><Pl,Eg~_k,lm nnKnnsA&A )A&A&&A/cddlm}|||||}|jd|d|i}t|gt |Dcgc]}ddic}|gz|||fg||Scc}w)zFRun one child and apply the same host lifecycle used by delegate_task.r)_run_single_childrrr )rr- setdefaultr+range)rrrrr-rFr_s r_run_child_lifecycler1s{5 z4 EF lJ/ D>DVHU:=N&O|&OSWRX&X\fhlns[tZuxDE M'Ps A )rrrr)rrrr)rFDict[str, Any]r4rr5rrList[Dict[str, Any]])r^rrhrrr)ror2rr2)rwrrprrr2)r}rrr2)rrrr3)rrrrrz Optional[str])rrrrrrrztuple[str, Optional[str]])r Optional[int])rrrr4)rr3rNone)rzthreading.RLock)rr5)rr)rrrr5)rr3rr3r(z%List[tuple[int, Dict[str, Any], Any]]rr5)NN)rrrrrr2)/__doc__ __future__rloggingrrtypingrrrr urllib.parserr getLoggerrrr2rL frozensetrnrbr]rrrxr~rrrrrrrrrLockrrrrrrr rr&r+r1rr rr>s2s" ,,-   0 1$O&HJ\`2$%!!<=2 L4"!&$qL 6 <#1).."2%4Y__%6"*9??, " @ C n ! n.B nNs n  nr