+ lHj[BRt^RIHt^RIt^RIt^RIt^RIHtHtH t H t ^RI H t H t ^RIHtHtHtHtHt]P(!R4tRRltR R ltR ^ R R /RRllt]!0R6m4t]!0R7m4tR8RRlltR8RRlltR8RRlltRRltRRlt Rt!Rt"Rt#RRlt$RR lt%R!R"lt&R#R$lt'R%R&lt(R'R(lt)]PT!4t+]PX!4t-]PX!4t.R)t/R*R+lt0R,R-lt1R.R/lt2R0R1lt3R2R3lt4R9R4R5llt5R#):zmSubagent result post-processing: summary budget/spill, tool-trace summaries, lifecycle hooks and cost rollup.) annotationsN)AnyDictListOptional)urlsplit urlunsplit) parent_copyredact_child_resultredact_child_textredact_child_valueredact_summaryztools.delegate_toolc V^8dQhRRRR/#)contentrreturnstr)formats"@/home/ubuntu/.hermes/hermes-agent/tools/delegate_tool_results.py __annotate__rsSScVfR#\V\4'dV#\V\4'dRPRV44#\V\4'd\ P !VR\R7#\V4#)zStable text for tool-result content. Some OpenAI-compatible paths return content-block lists; observability must never crash on them. c3&"TFp\V\4'd/\VPR4\4'd VR,M=\V\4'd\P !VR\R7M \V4xK R#5i)textF ensure_asciidefaultN) isinstancedictgetrjsondumps).0items& r *_stringify_tool_content..sk  'tT22z$((6BRTW7X7XDLFPQUW[F\F\DucBT  sBBFr)r rlistjoinr!r#r$)rs&r_stringify_tool_contentr+sw'3'4  yy     '4  zz'sCC w<rc V^8dQhRRRR/#)rrrrboolr)rs"rrr"sOOcOdOrcj\V4pV'gR#VP4PR4'd\P!V4p\ V\4'd_VPR4'gF\VPR4;'gR4P4P4R9dR#VP4'd4VP4^,P4P4MRpVPR 4# \ dRpLi;i) zConservative error detector for tool-result previews: structured JSON with an ``error`` key or an error/failed ``status``, or a first line starting with a classic error marker. (Substring "error" alone painted normal output red.)FNerrorstatusrT){[>r/failedfailuretimeout)zerror:zfailed:z traceback z exception:) r+lstrip startswithr#loads Exceptionr r!r"rstriplower splitlines)rparsedfirsts& r_looks_like_error_outputr?"s&g.G ~~"":.. ZZ(F fd # # JJw  3vzz(';'A'Ar#B#H#H#J#P#P#RV#7>7I7I7K7KG    # ) ) + 1 1 3QSE   M NN F sD"" D21D2 max_entries max_charsi@c(V^8dQhRRRRRRRR/#)rresultdict[str, Any]r@intrArlist[dict[str, Any]]r)rs"rrr5s*VYeyrc \V\4'dVPR4MRp\V\4'g.#VUUu/uFp\V\4'gKVPR4R8XgK3VPR4;'g.F`qUPR4'gKVR,\ VPR4;'g/PR4;'gR 4bKb K ppp.p\ V4Fp\ V4V8dM\V\4'dVPR4R 8wdKC\\VPR 4;'gR 4R R 7pTPVPR4;'gR R 4p VPR V RVRVR\V4/4K VP4V#uuppi)a^Last 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_callsidfunctionnametoolrrFforce tool_call_idpreviewis_error) r r!r"r)rreversedlenr r+appendr?reverse) rCr@rArHmsgtcname_by_call_idtailr tool_names &$$ r_extract_output_tailr^5s *4FD)A)Avzz*%tH h % % Cz#t4 9<K9W '','--2-B H4#rvvj)//R44V<FFGG-  "$D! t9 # #t$$6(A #$;CGGI<"TFp\SVS4xK R#5iN)_sanitize_tool_target)r%r&rQr`s& rr'(_sanitize_tool_target..Xs!$dYcQU%:3e%L%LYcs:NNNrP:NiN:r2]r) r r)rr _TOOL_INPUT_URL_KEYSrschemenetlochostnameportrpath ValueError) r`rarQr&cleanedboundedr=rmhostrls f&f rrereUs%$dY^_bYc$dy$dD44$dy$ eS ! !U3E:G "" g&F}}}!??+./8*Ax4:KK4KD66;;-0QU!6==&++r2"NOO N7N)z$  s)D)D) .D.<D.AD.. D=<D=c$V^8dQhRRRRRR/#)rmappingrDrQr-rr)rs"rrrns!  ~ d n rc/pVP4FAwr4\V4P4pV\9gK+\ WTV4pVfK=WbV&KC V#)zNKeep only known side-effect target keys, each sanitized (URL secrets dropped).)itemsrr;_TOOL_INPUT_TARGET_KEYSre)rurQtargetsraw_keyrar`rqs&& r_sanitize_targetsr{nsT G!--/'l  " ) )+C>G"& * Nrc(V^8dQhRRRRRRRR/#)rkeysrryrQr-rrDr)rs"rrrys(s4>rc R\V\4'd5VR,Uu.uF p\\V4VR7R,NK" upM.R\V\4'd \ W4/#//#uupi)z``{argument_keys, targets}`` with bounded, sanitized contents (empty on bad shapes). ``force=False`` for the parent's own tool_trace copy (honours the opt-out); lifecycle hooks re-sanitize with ``force=True``. argument_keys:N@NrP:NNry)r r)r rr!r{)r}ryrQr`s&&& r_input_summaryrys| blmqswbxbxTXY\T]^T]S+CHEB4HHT]^A 7D8Q8Q$W4 WY ^s&A3c V^8dQhRRRR/#)r argumentsrrrDr)rs"rrrsSSSSrc\V\4'd\P!V4MRp\V\ 4'g \./4#\\RV44VRR7# \\ 3dRpLUi;i)zFSummarize argument names and side-effect targets without raw payloads.Nc38"TFp\V4xK R#5ird)r)r%r`s& rr',_summarize_tool_arguments..s .__annotate__sllslslrcVPV^4p\V\\34'd,\V\4'g\ ^\V44#^#))r"r rEfloatr-max)r&r`ras&& r _byte_count5_subagent_stop_tool_call_history.._byte_countsGa %/U|%D%DZX]_cMdMds1c%j!kjkkrr0unknown input_summaryr]rO:NN tool_inputrry input_bytes args_bytes output_bytes result_bytes>okr/)r r)r!rr"r;rWr)rrhistoryr&r0summarys& r _subagent_stop_tool_call_historyrs j$ ' ' l%'G$%% TXXh'4495;;=((?+'66'B TXXf-::;DA ._)Ew{{S\G]^ ;t\:NKX\^lLm / 9fy    Nri]?ic$V^8dQhRRRRRR/#)r task_indexrErrr Optional[str]r)rs"rrrs!sS]rcj^RIHp^RIpV!RR4pVPRRR7VRV RVPP 4P R 4 R 2, p^R IHpV!V\VR V4R R7\V4# \d"p\PRT4Rp?R#Rp?ii;i)uWrite 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.)get_hermes_dirNzcache/delegationdelegation_cacheT)parentsexist_okzsubagent-summary--z%Y%m%d_%H%M%S_%fz.txt)write_text_exclusiveforcedF)privatez,Failed to spill subagent summary to file: %s) hermes_constantsrdatetimemkdirnowstrftimetools.spill_safetyrgetattrrr9loggerdebug)rrr_dt cache_dirrorexcs&& r_spill_summary_to_filers3"#57IJ t4.zl!CLLZacgimKnF' ;JF0< 'G cFJ z#9&z#R SU_ __rc(V^8dQhRRRRRRRR/#)rrrrrErrrr)rs"rrrs/eeCece}eQTerc \V4p\VR,4pW, pVRVW)RrvVPR4pWR,8dVRVpVPR4p^Tu;8:dVR,8dMM Wx^,RpRRR\V4R R\V4R RVR R 2.p V'dMV P R V 24V P R V R VP \ ^ 44^, R 24MV P R4V P R4VR,V,RPV 4,#)g?NrrrzShowing ,z chars (head) + z chars (tail) of u: total — trimmed to protect the parent's context window.zFull subagent output saved to: z,To read the omitted middle: read_file path="z " offset=zV limit=200 (the file is the complete summary; raise/lower offset to page through it).zWFull output could not be stored to disk; the head+tail above is all that was preserved.u+ [... middle omitted — see footer ...] uE──────── [SUMMARY TRUNCATED] ────────uo─────────────────────────────────────)rVrErfindfindrWcountchrr*) rrr original_len head_budget tail_budgetheadr\nl footer_liness &&& rrrsZw$ D B # CRy 4BB"s""FG} ; 3t9Q-/D !}=1 W YL =j\JK::,GjjR)A-./? @ uv # C Cd JTYYWcMd ddrcV^8dQhRR/#)rr Optional[int]r)rs"rrrs   rcX\VRR4p\V\\34'dV^8d \V4#\VRR4;'g/p\V\4'dVP R4MRp\V\\34'dV^8d \V4#R#)a&The parent's current prompt size: the aggregator's own last ``prompt_tokens`` (pre-MoA-fold), else the last provider usage. ``None`` when no request has completed yet: the caller then applies the static ceiling only. Treating "no usage yet" as zero handed a 190K/200K parent a 384K-char budget._last_prompt_size_tokensN_last_turn_usage prompt_tokens)rr rErr!r") parent_agentsize last_usageuseds& r_parent_prompt_size_tokensrs >/ *PTD$e %%$(4y rc V^8dQhRRRR/#)r n_summariesrErrr)rs"rrrs3=rc\VRR4p\VRR4p\V\4'dV^8:dR#\V4pVfR#V\V4, \\VR^4;'g^4, pV^8:d\#\V\ ,4\ ^V4,p\ \V^,4# \d\PRRR7R#i;i)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_length max_tokensz!Summary budget computation failedTexc_info) rr rEr_MIN_SUMMARY_CHARS_SUMMARY_HEADROOM_FRACTIONrr9rr)rr compressorr used_tokensheadroom_tokensper_summary_tokenss&& r_parent_summary_char_budgetrs\+?F  -=tD.#...A2E0>  (3{+;;c'*VbdeBfBkBkjk>ll a % % 3M!MNRUVWYdRee%'9A'=>>  84 Hs#7CC AC=C"C43C4c V^8dQhRRRR/#)rresultsrFrNoner)rs"rrrs  #7 $ rc B^RIHpVUu.uFUp\V\4'gK\VP R4\ 4'gKBVR,'gKSVNKW ppV'gR#\ V!4P R\44pV\V\V443Uu.uFqf'gK V^8gKVNK ppV'gR#\V4pVFp V R,p \V 4V8:dK\WV P RR 44wrWR&RV R&V 'dWR&\PR V P RR 4\V 4TT ;'gR 4K R#uupi \\3d \pELi;iuupi) a(Trim 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.) _load_configrNmax_summary_charsrTsummary_truncatedsummary_full_pathu9[subagent-%s] summary trimmed %d → ~%d chars (spill=%s)?none)tools.delegate_toolrr r!r"rrEDEFAULT_MAX_SUMMARY_CHARSrrprrVminrrr) rrrr summariesstatic_ceilingc candidatesrentryrrrs && r_apply_summary_budgetrsq1#rGqz!T':z!%%PYJZ\_?`efgpeqeqGIr 3\^//0CE^_`-.I,X[\eXf.ghxhlm!rsvwrw!!hJx  j/C " w<3  !:7S_acId!e %i%)!" )3% & GS_adIegjkrgsux  & s z "323xs:E9"E9 E9 E93$E>0 F>FF>FFc ^RIHp^RIp\;_uu_4\ VP 4pV!R/VBpW2nRRR4XXnV# Y2ni;i +'giL$;i)zCBuild a child without leaking its resolved toolset into the parent.)_build_child_agentNr)rr model_tools_CHILD_CONSTRUCTION_LOCKr)_last_resolved_tool_names_delegate_saved_tool_names)kwargsrrparent_tool_nameschilds, r$_build_child_preserving_parent_toolsr ;s`6 ! ! !F!FG F&00E4E 1 " (9E$ L5F 1 " !s!AAAAA A+ cV^8dQhRR/#)rrzthreading.RLockr)rs"rrrHsrc2Vf\#\VRR4pVeV#\;_uu_4\VRR4pVf\P!4pWnRRR4V# \ d\uuuRRR4#i;i +'giT#;i)zRPer-parent lock serializing lifecycle side effects (created once under the guard).N_subagent_finalization_lock)"_PARENT_FINALIZATION_FALLBACK_LOCKr_PARENT_FINALIZATION_LOCK_GUARD threadingRLockrr9)rlocks& r_parent_finalization_lockrHs11  ED  ( (|%BDI <??$D :;?8 ) K :99 ) (  : ) ( Ks)'BA$$B5BBB B cV^8dQhRR/#)rrrr)rs"rrrYsPTrc V'd\VRR4MRpV'gR#VFpVPRR 4p\V\4;'d ^Tu;8*;'d\ V48MupTP V'dW,R,MR\ VPRR4;'gRRR7\VPV4RR4R 7K R# \dKi;i) _memory_managerNrgoalrrTrP session_id)taskrCchild_session_idr)rr"r rErV on_delegationr r9)r task_listchild_by_indexrmemoryrrin_ranges&&&& r_notify_memory_managerr!Ys?KW\#4d ;QUF  <4J!*c2WWqJ7W7WY7WH  6>Y*62B(9b)A)G)GRtT!(););J)GWY!Z !     s#7C! #C!-C!2)C!! C0/C0cV^8dQhRR/#)rrrr)rs"rrrisrc^RIHpRpVEFpVPRR4pVPRR4pV'dV\ V4, pTfKITPTPRR44pT!R\TRR4\TR R 4;'gR \TRR4T\TPR 44TPR 4\TPR 44\TPR4;'g^R,4R7 EK V# \dRpEL*i;i \ \ 3dLi;i \d\PRRR7EKgi;i)zPop the model-hidden ``_child_role`` / ``_child_cost_usd`` fields from every entry, fire ``subagent_stop`` per child, and return the summed child cost.) invoke_hookN _child_role_child_cost_usdr subagent_stopr_current_turn_idrrr0rduration_secondsi)parent_session_idparent_turn_idr child_role child_summary child_statustool_call_history duration_msz$subagent_stop hook invocation failedTrr)hermes_cli.pluginsr$r9poprrrpr"rr rrErr) rrrr$children_cost_totalrr- child_costr s &&& r_fire_subagent_stop_hooksr6isk2YY}d3 YY0#6  #uZ'88#    P"&&uyyr'BCE 7<W[3\&|5GLRRPR!( d!CPZ091EF"YYx0"B599\CZ"[+=!>!C!C!t KL  . 5  :&    P LL?$L O O Ps5D"D6CE " D32D36E  E  "E43E4c V^8dQhRRRR/#)rr4rrrr)rs"rrrs C CU Ct Crc.VR8:dR#\\VRR4;'gR4pW!,Vn\VRR4R 9dRVn\VRR4R9d R VnR#R# \ d\ PR R R 7R#i;i)zvFold 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_sourcersubagentsession_cost_statusr estimatedzSubagent cost rollup failedTr>Nrr>Nrr)rrr9r:r<r9rr)rr4currents&& r_rollup_children_costr?sc!C .JCPWWTWX292O / 5,(KE^// ,0GHJceijFii *G#GZ-E-`-`[`I`bfgF LL,U%H I'3''Juyy7KS,Q,Q#.uY/?#Hi  g4w>Pl,Eg_k,lm 1 0K 1 0 0s)E E BE  "E 1AE E  E c$V^8dQhRRRRRR/#)rrrErrrrDr)rs"rrrs"SWerc^RIHpV!WW#4pVPRV4RV/p\V.\ V4Uu.uFpRR/NK upV.,WV3.V4V#uupi)zFRun one child and apply the same host lifecycle used by delegate_task.)_run_single_childrrr)rrL setdefaultrIrange)rrr rrLrCr_s&&&& r_run_child_lifecyclerPsz5 z EF lJ/ D>DVHU:=N&O=N|=N&OSWRX&X\fns[tZuxDE M'Ps A >cwddstsrcurlrourlsendpointnew_pathold_path directory file_path source_path target_pathdestination_path>rTrUrV)T)NN)6__doc__ __future__rloggingr#rtypingrrrr urllib.parserrtools.delegation_redactionr r r r r getLoggerrr+r?r^ frozensetrxrjrer{rrrrrrrrrrrrLockrrrrr rr!r6r?rIrPrrrrgss" ,,-   0 1$O&r\`4$%!!<=2 S4"!*`"e: 6 <#,.."2%.__%6"$??, " B Cn*r