+ lHjjr Rt^RIHt^RIt^RIt^RIt^RIt^RIHtH t ^RI H t H t Ht^RIHtHtHtHt^RIHtHt^RIHtHt^RIHtHtHtHt^R IH t H!t!H"t"H#t#H$t$^R I%H&t&^R I'H(t(]PR!R 4t*] !R R44t+RRlt,RRlt-RRlt.RRlt/RRlt0RR/RRllt1RRRR /t2R!R"lt3R=R#R$llt4R%R&lt5R'R(lt6R)R*R+R,R-R.R/R0/t7R1R2lt8R3R4lt9R5R6lt:R7R8lt;R9R:ltuLBatch execution + background dispatch for delegate_task: ``delegate_task`` builds a ``_Batch`` (children + origin identity) and hands it to ``_run_batch``, which runs it synchronously or as detached async units — one per task ``group`` (ungrouped tasks are a unit each), so a finished review does not wait for the slowest sibling.) annotationsN)FIRST_COMPLETEDwait) dataclassfieldreplace)AnyDictListOptional)begin_delegation_runfinish_delegation_unit)_new_delegation_idrecord_unit_child) _attach_child _detach_child_fabricated_entry_signal_child_stop)SUBAGENT_FAILURE_STATUSES_print_completion_line_quietdescribe_subagent_failureformat_batch_tag) _capture_gateway_steer_authority)_finalize_child_resultsztools.delegate_toolc]tRt^t$RtR]R&R]R&R]R&R]R &R ]R &R ]R &R]R&R ]R&R]R&R]R&R ]R&R ]R&R]R&R]R&R]R&R]R&RtR ]R&RtR ]R&RtR]R&] !] R 7t R]R!&R"R#lt R$R%lt R&tR#)'_BatchzOne delegate_task call's built children plus everything needed to run them and assemble the combined result (shared by the sync path and the background runner).zlist[dict[str, Any]] task_listz list[tuple]childrenr parent_agentdict[str, Any]creds Optional[str]contextstrtop_roleint max_children live_deleg_idlist live_writers live_pathsorigin_wake_sidorigin_ui_session_idorigin_owner_transportorigin_owner_session_recordboolorigin_session_history_deliveryfloat overall_startNgroupunit_id live_home)default_factoryrefusedcV^8dQhRR/#)returnr )formats"A/home/ubuntu/.hermes/hermes-agent/tools/delegate_tool_dispatch.py __annotate___Batch.__annotate__9s  n c bRVP;'gRRVPRVP/#)zKSteer/stop authority of the originating session, passed to every child run.owner_session_idNowner_transportowner_session_record)r-r.r/)selfs&r> owner_kwargs_Batch.owner_kwargs9s8  9 9 A ATCTVZVqVq "D$D$D  rAc(V^8dQhRRRRRRRR/#)r:ir&taskr childrr;r<)r=s"r>r?r@@s.FF3FnFSF^FrAc  l^RIHpV!RRVRVR,RVRVP/VP4B#))_run_single_child task_indexgoalrLrr<)tools.delegate_toolrOrrG)rFrJrKrLrOs&&&& r> run_child_Batch.run_child@s]9 FAFDLFF\`\m\mFqurCrCrEF FrAr<)__name__ __module__ __qualname____firstlineno____doc____annotations__r4r5r6rr)r8rGrS__static_attributes__r<rAr>rrs]$#  M  !$$%))E=!G]!Is$/GT/ FFrArc$V^8dQhRRRRRR/#)r:n_tasksr&r(r"r;Noner<)r=s"r>r?r?Es'xx3x}xQUxrAcV^8d8V'd.R\W 4 RV R2p\V\VRR4W3R7R#R#R#)zPAnnounce the batch tag once so interleaved ``[tag n/N]`` lines are attributable.u 🔀 [z ] delegating z tasks_delegate_spinnerN) console_line)rrgetattr)rr]r(_hdrs&&& r>_announce_batchrdEsH{}*=GH V]U^^de|W\CVX\-]_cw%{rAcV^8dQhRR/#)r:r;ztuple[str, str, Any, Any, bool]r<)r=s"r>r?r?KsQQ8QrAc^RIHpV!4pRpRp\R4;_uu_4^RIHpHpV!RR4pV!4pRRR4W.\ V4OVN5# +'giL!;i)u``(wake_sid, ui_session_id, owner_transport, owner_session_record, session_history_delivery)`` of the ORIGINATING session, captured BEFORE building any child: AIAgent construction clobbers the HERMES_SESSION_ID ContextVar/os.environ with the subagent's id. The wake- capability flag rides the same request-scoped binding and is captured here for the same reason — and fails closed: a binding that never declared it (or a read error) leaves the session treated as non-wake-capable (#98619).)_current_origin_session_idFN)get_session_env"session_history_delivery_supportedHERMES_UI_SESSION_ID)tools.async_delegationrgrgateway.session_contextrirjr)rg_origin_wake_sid_origin_ui_session_id _origin_session_history_deliveryrirjs r>_capture_originrqKszB13',$ _ /0F K+M+O(   Q6VWl6m QpP QQ s A A' cV^8dQhRR/#)r:r;r^r<)r=s"r>r?r?\sHHbfHrAc ,VR,pV\V48d WG,MRV 2pVPRR4p V'dV RV^, RV 2M V^, RV 2p VPR4RJ;'dV R 8Hp V 'dR M V R 8XdR MR p V R V RV RVPR^4 R2p V \9d-\VPR4VPR4^xR7MRpV 'dRpV'd V RV 2, p \ WV 4V'dcV^8dZ\ R4;_uu_4TP RV'dRV,R,MR T RV^8wdRMR R24RRR4R#R#R# +'giR#;i)uPrint one completion line for a finished child and refresh the spinner text. Failed/errored/timed-out children say WHY on the same line — a bare ✗ reads as "silently dropped".rPzTask status?u · / schema_validF completedu⚠u✓u✗z [z] z (duration_secondszs)failure_reasonerror) max_charsrhuFoutput_schema not satisfied — raw text returned (schema_valid=false)u — zSpinner update_text failed: %su🔀 [z tasksz remainingN)lengetrrrr update_text)r spinner_refentrytag task_labelsr] remainingidxlabelrt_slotschema_invalidiconcompletion_line _err_lines&&&&&&& r>_report_child_doner\s  C #c+&6 6K eC5ME YYx %F-0se4Away )Qq 6JEYY~.%7QQFkPRS4T3UUWXO . . "%)),<"=uyy?Q]`a46\ U9+..r?r?rs)00&00d0W[0rAcV'gEVP'd1\V\4'd\VPV4R#R#R#R#)uDetached (background) unit: durably record a child on the unit's own row the moment it finishes, so an owner death before the unit's join — or anywhere before its durable completion write, the whole remaining window for a one-child unit — loses only children still running, never finished work (#116000). Best-effort by construction: ``record_unit_child`` never raises into the join.N)r5 isinstancedictr)rrrs&&&r>_record_finished_childrrs4 "emmm 5$8O8O%--/9Pm !rAc(V^8dQhRRRRRRRR/#) r:rrresultsr)rr0r;r^r<)r=s"r>r?r?zs*=0=0&=04=0TX=0]a=0rAc aaa^RIHpVP\VP4rTVPUu.uFqfR,R,NK pp\ VRR4p\ VPV4p VPU U U u/uFwrqV bK up p p o\VP4p V3RloV!VPR7pRpVPU UU u/uFAwrqP\P!4PVPWV 4V bKC up pp o\S4pV'EdV'd2\ VR R4R Jd!VP!VV3R lV44R pEMf\#VR \$R 7wppVEFGpS!VSV,4pVP'V4\)VVV4\+WHVWW]\V4, 4V'dKZVP,'gKnVP/R4\09gK\V4V 8gK\3RR R7;_uu_4^RIHpVP/RR4p\9V\:4'd9^Tu;8:d\VP<48dMMVP<V,MRpT!VP,/VCV'dRV/M/CVR7RRR4EKJ EKVP?V'*VR7VPARR7R#uupiuup p p iuup pp i +'giEK;i TP?T'*TR7i;i)aRun the batch's children in parallel, appending entries to ``results`` (sorted by task_index on return, one completion line printed per child). Polls futures with a short ``wait()`` timeout instead of ``as_completed()`` so a wedged child cannot block the parent forever after an interrupt; on parent interrupt the still-pending children are reported ``interrupted`` and abandoned (they already got the interrupt signal).)DaemonThreadPoolExecutorrQ:N(Nr`Nc <VP4'g\VRRSPV44#VP4# \d1p\TR\ T4SPT44uRp?#Rp?ii;i) interruptedu9Parent agent interrupted — child did not finish in timer{N)donerrresult Exceptionr$)futurerexc_child_by_indexs&& r> _entry_of)_run_children_parallel.._entry_ofsw{{}}$]$_apatatuxay  W==? " W$S'3s8_=P=PQT=UV V WsA B%A<6B<B) max_workersF_interrupt_requestedTc3D<"TFpS!VSV,4xK R#5iNr<).0frfuturess& r> )_run_children_parallel..sIAyGAJ77s g?)timeout return_whenrtztask failure notice failedexc_info)push_task_failure_noticerPlive_transcript)r])rcancel_futurescVR,#rPr<rs&r>(_run_children_parallel..sqrAkey)!tools.daemon_poolrrrrrbrr(rr'submit contextvars copy_contextrunrSsetextend_cf_waitrappendrrr5rrrrlrrr&r+shutdownsort)rrrrrr]trr_tagrJ_rLn_hereexecutorrpendingrrrr_i_liverrrs&&$ @@@r>_run_children_parallelrzs;!..EOO0D'+0??;?aV9S>>?K;,(;TBK E// >D5:^^D^MQ5%x^DO  FW(E4F4FGH KLw|xFxFGxFhshins??;#;#;#=#A#A5??TUZ_`bccxFGg,g%',@VX]*^bf*fIII" $WcWMD'!&'&/:u%&ue5KL"r?r?s"))&)T)UY)rAc^RIHp.p\VP4^8XdEVP VP !VP^,!4\ WR,V4M \WVR7\W0PVPVP4\\P!4VP, ^4pVFpVPRR4p\!V\"4'gK-^Tu;8:d\VP$48gKQMKUVP$V,fKl\'RRR7;_uu_4VP$V,P)V4RRR4V\VP*48gKVP*V,VR&K VP,'d/VP/VP,4VP1R R 7T!VP2W0P4R 7\7VPW1'*R 7R VRV/p^RIHpVUU u.uFqX!V4FqNK K p pp V 'dWR&VPU U u.uF5wp q\VP*48gK"VP*V ,NK7 p p p V 'dWR&VP<eVP<VR&V# +'giELq;iuup piuup p i)aRun the batch's built children, join, finalize (hooks + cost rollup), return the combined dict. Shared by the sync path and the background runner; a background runner receives a per-group unit (a subset of the call's children) so each group JOINS only on itself. Live transcripts are finalized but retained as the full-fidelity record (retention pruning happens on future dispatches).)update_manifest_statusesrrPNzLive transcript finalize failedTrrcVR,#rr<rs&r>r(_execute_and_aggregate..s1\?rAr)home) backgroundrtotal_duration_seconds)_process_accounting_lines process_noteslive_transcriptsr4r)tools.delegation_live_logrrrrrSrrrrrroundtime monotonicr3rrr&r*rfinalizer+r8rrr(r6r $tools.process_registry_notificationsrr4)rrrrtotal_durationr_idxcombinedrlinerrJr unit_pathss&$ r>_execute_and_aggregatersI CG 5>>auq(9:; ubk3IJuF\]G__enneFXFXY4>>+e.A.AA1ENyyr* dC Q$%HU5G5G1H%H%HUM_M_`dMeMq9DII""4(11%8Jc%**+++0+;+;D+A'(  }}}u}}% 2 3U00'P5??G@Z[ )74Ln]HN'.\we;TUZ;[4T;[TwM\$1!7<~~c~)1aSQVQaQaMbIb%%""1%%~Jc'1#$ {{!KK O+JII]ds#K>K14K7K7 K. no_asyncu8background=true is not available in this session — it cannot receive a detached subagent result after the turn ends (a finite chat using -Q, --oneshot, or non-TTY stdio, `hermes -z`, a cron job, a Kanban worker, or a stateless HTTP endpoint). The subagent(s) ran SYNCHRONOUSLY and the result is included above. at_capacityaThe background delegation pool was at capacity (delegation.max_concurrent_children), so the subagent(s) ran SYNCHRONOUSLY and the result is included above. Raise delegation.max_concurrent_children in config.yaml to allow more concurrent background delegations.c$V^8dQhRRRRRR/#)r:rrreasonr$r;r<)r=s"r>r?r?s!22v2s2s2rAc\V4p\V\4'd\V,VR&\P !VRR7#)zGInline fallback: run the batch now and explain why it was not detached.noteF ensure_ascii)rrr_SYNC_FALLBACK_NOTESjsondumps)rrrs&& r>_run_sync_with_noters8 #E *F&$-f5v ::f5 11rAc$V^8dQhRRRRRR/#)r:r,r$r1r0r;r"r<)r=s"r>r?r?s###S#SW#dq#rAc<^RIHp^RIHpV!4pVRJgVfV!R4R8XdR#^RIHpV!4'dR#T'd!T'd\ PR T4T#T'd\ PR T4R# \ dR#i;i) zDetached result target: empty for push, a resumable API id, or None for inline. API completion only persists a row; this does not authorize a model wake. The continuation must read that row, not an authoritative caller-owned snapshot.ri)finite_turn_requiredTNHERMES_SINGLE_QUERY_SESSION1)async_delivery_supportedrhudelegate_task: session %s resumes server history — detached result will be persisted for the next client turn (no model wake).udelegate_task: session %s has no declared server-history consumer — running the batch synchronously so the result returns in this turn.)rmrigateway.session_finiterrrloggerinfo)r,r1rirfiniters&& r>_resolve_async_wake_sidrs 8< ! #F ~&._=Z-[_b-b  E # % % &:  89H   @AP   sB BBc$V^8dQhRRRRRR/#)r:rrr-r$r;ztuple[str, str]r<)r=s"r>r?r?s'AASAAP_ArAc@^RIHpV!RR7p\\VRR4;'gR4p\ R4;_uu_4^RIHpV!RR4pV!RR4;'gTpVR 8Xd V'dTpRRR4T;'gTV3# +'giL;i) uC``(session_key, origin_ui_session_id)`` the async registry routes completions by. Desktop/TUI: the routable key is the durable AIAgent.session_id — compression can rotate it mid-turn before the TUI-side dict is re-anchored, and a stale approval-context key would orphan the completion. Gateway chats keep the platform conversation key (agent:main:...). The CLI has no bound approval contextvar and no HERMES_SESSION_KEY, so the key resolves empty; its drain is a positive-ownership filter on the durable session_id (empty would fail closed), so stamp the parent's durable id. )get_current_session_keyrh)default session_idNrHERMES_SESSION_SOURCErktui)tools.approval_contextrr$rbrrmri)rr-r session_keyagent_session_idrisources&& r>_resolve_async_session_keyr s?)"5K7<rBHHbI ; !8"= //ErJbbNb U?/*K   * **,@ @@ s1B 5B  B c V^8dQhRRRR/#)r: child_agentsz list[Any]r;tupler<)r=s"r>r?r?4s!! !e!rAcN.pRpVFlpVP4pVPR4pVPVPR^4WTPR434T;'g \V4pKn \ V4V3# \dTPR4Ki;i)aProgress token for the async registry's stale monitor: every child's (api_call_count, current_tool, last_activity_ts). last_activity_ts ticks on streamed chunks, tool transitions and API-call start/completion, so a child streaming a long response counts as alive; a fully frozen token past the threshold means the batch is wedged. ``in_tool`` is True while ANY child is inside a tool so slow tools get the higher ceiling (mirrors the sync heartbeat).F current_toolapi_call_countlast_activity_tsN)get_activity_summaryrrr0rr)rpartsin_toolcsummarytools& r>_batch_progress_tokenr4s EG  ,,.G;;~.D LL'++&6:D++N`Bab c++dG  <    LL  sAB' BB$#B$onea*Subagent is running in the background; its full result re-enters the conversation as a new message when it finishes. Results are delivered only after you END YOUR TURN: do anything that does not depend on it, then stop with a one-line status. Do not poll its transcript or artifacts to wait for it.manyai{n} subagents are running in parallel in the background as {k} completion unit(s); each unit's results re-enter the conversation as their own new message when THAT unit finishes. Results are delivered only after you END YOUR TURN: do anything that does not depend on them, then stop with a one-line status. Do not poll transcripts or artifacts to wait for them. control_hintzWhile a child runs you can orchestrate it live with this same tool: delegate_task(action='list') to see live children, action='steer' with subagent_id + message to redirect one, action='stop' with subagent_id to end one early.live_transcripts_hintzEach subagent streams a human-readable transcript of its operations to the file listed above (append-only, one per task). Read or `tail -f` these paths at any time to watch a child work while it runs.c$V^8dQhRRRRRR/#)r:rrunitszlist[tuple[_Batch, str]]r;rr<)r=s"r>r?r?bs"v.F4rAcVPUu.uF q"R,NK pp\VP4pRRRRRTRVP;'gV^,^,RTR V^8Xd\R ,M&\R ,P V\V4R 7/p\V4^8dMVUUUU u.uF6wrgRTR VP RVPUU u.uFwpqNK up p/NK8 up pppVR&VPU U u.uFwr\V RR4NK p p p \;QJdRV 4F 'gK RM RM !RV 44'dWR&\R,VR&VP'dVPVR&VP'd)\VP4VR&\R,VR&V#uupiuup piuup pppiuup p i)zNModel-facing handle for an accepted background call: one entry per async unit.rQrt dispatchedmodercount delegation_idgoalsrrr)nkr4 task_indexesr! _subagent_idNc3V"TFp\V\4;'dTxK! R#5ir)rr$)rr~s& r>r&_dispatched_payload..qs" 2T:a  # #! #Ts) )TF subagent_idsrr8rr) rrrr(_BACKGROUND_NOTESr=r4rbanyr8r+r)) rr!rr'r(payloadunituidrJrrsidss && r>_dispatched_payloadr5bs % 01vYYE 0 ENNA, gq,,;;a WeAF!%(8I&8Q8X8X[\`cdi`j8X8kG  5zA~# " c7DJJ\`\i\iHj\iyPQSTVW\iHj k" ?Dnn Mn!QGA~t ,nD M s 2T 2sss 2T 222"&"3N"C }}}"]]  &*5+;+;&<"#+<=T+U'( N+ 1Ik  Ns#G7%G G* G G%G c V^8dQhRRRR/#)r:rrr;z list[_Batch]r<)r=s"r>r?r?{sssVs srAc ^RIHpV!4'gV.#/pVPFRwr4pVPR4pVR9dR\ V43MRV3pVP V.4P W4V34KT VP4UUu.uF)wrx\YV^,R8Xd V^,MRR7NK+ upp#uuppi)aPartition the call's children into async units: one per distinct task ``group`` (first-appearance order) and one per ungrouped task. Each unit is a ``_Batch`` sharing the call's task_list/transcripts but owning a subset of ``children``, so a unit joins only on itself and its completion re-enters the conversation on its own. Off by default (``delegation.independent_completions``): the whole call is ONE unit and returns as one message. A per-task flurry of completions (one new turn each) fragmented orchestrators that had no plan for it.)_get_independent_completionsr4NgrJ)rr4)Nrh) tools.delegate_tool_configr8rrr$ setdefaultritemsr) rr8membersrJrrr9rchs & r> _units_ofr?{sH ' ) )w&(G>>a EE'N 2sCFma3#**A!95"cjbobobq rbqW^WZGEQ3s1vD Rbq rr rs/Cc ,V^8dQhRRRRRRRRRR/#) r:r2rr5r"slot_keyroutingrr;r<)r=s"r>r?r?s1-=[_dhrAc!~aa ^RIHpSPUUu.uFwrVVNK uppo V 3RlpT!RRSPUu.uF qR,NK upRSPRRRSP R SP R ,;'g\R S 4R4R V3R lR TRTRTR\SP4\SP48d"SPU Uu.uFwp qYNK upp MRRSPU Uu/uFwp pV \SP48gK#SPV ,fK:SPV ,PfK[\V 4\SPV ,P4bK upp RV 3Rl/ VB#uuppiuupiuupp iuupp i)zSHand ONE unit to the async registry; the runner joins on that unit's children only.)dispatch_async_delegation_batchc2<SFp\VR4K R#)zAsync delegation cancelledN)r)rrs r> _interrupt"_dispatch_unit.._interruptsA q"> ?rAr'rQr#toolsetsNrolemodelc3f"TF'p\VRR4'gK\VRR4xK) R#5i)rJN)rb)rrs& r>r!_dispatch_unit..s+ Z 17TX@Y &WQ & & s11runnerc<\SRR7#)Fr)r)r2sr>r _dispatch_unit..s -d5QrA interrupt_fnr&rAr*task_transcripts progress_fnc<\S4#r)r)rsr>rrOs 1,?rAr<) rlrDrrr#r%r!nextrr*pathr$) r2r5rArBrDrrrFrrJrs f&&& @r>_dispatch_unitrVsF'+}}5})1aA}5L@ + "&..1.Qyy.1 ;?<<   ]]   #'**W"5#b#b Z Z\`:b  R   07 BJ r?r?s00v0$0rAc^VPFwr\VPV4K R#)zRejected children stay owned by the parent: re-attach them (``_attach_child`` replays a stop that arrived while async admission had them detached).N)rrr)r2rrLs& r>_restore_parent_cancellationrYs&}} 1d''/%rAc V^8dQhRRRR/#)r:rrr;r$r<)r=s"r>r?r?s232323323rAc ^RIHp\VPVP4pVf"\ P R4\VR4#VPp\W0P4wrE\WEV\VRR4V!4R7p\V4Uu.uFp\V.R7NK pp.p .p Rp \V4EFzwr\!V4^8Xd VP"M+VP"'dVP" RV ^, 2MRp T ;'g \%4;Vnp VP(Fwr\+W?4K \-W}W4pVP/R 4R 8Xd0T ;'g VR ,p V P1VVR ,34K\3V4V 'g5\ P R VP/R R44\VR4u#\ P5RV ^,\!V4VP/R 44V P7\9V4R,4EK} \;W 4pV 'dV VR&\<P>!VRR7#uupi)afDispatch the call as independent async units (see ``_units_of``) and return the tool result JSON. Every unit of one call shares ONE pool slot (``slot_key``), so grouping never changes capacity accounting. Falls back to running synchronously (with an explanatory ``note``) when the session cannot receive detached completions or the async pool is at capacity.)_get_max_async_childrenNzkdelegate_task: async delivery unsupported on this session runtime; running the batch synchronously instead.rr)r r-origin_session_idparent_session_idmax_async_children)r8-rtr#r&zZdelegate_task: async pool at capacity (%s); running the whole batch synchronously instead.r{rejectedrz?delegate_task: unit %d/%d not accepted (%s); running it inline.rinline_resultsFr) rRr\rr,r1rrrrr r-rrbr?r enumeraterr(rr5rrrVrrrYwarningrrr5rr)rr\wake_sidrr r-rBr2r!r#rbrAr)r5rrLdispatchr1s& r>_dispatch_backgroundrgsK <&u'<'c>cdH B C"5*55%%L(B,@@ w ==KAq , .)!$C << !\ 1<<8O#? @ $T* KKl Wj1 'um< < XZ[^_Z_adejakmumymy{BnC D4T:9EF1$2"%4G$2 ! ::gE 22A EsI3c$V^8dQhRRRRRR/#)r:rrrr0r;r$r<)r=s"r>r?r?s&IIfI$I3IrAc \VP\VP4\ VP R^4^,R7V'd \ V4#\P!\V4RR7#)zPTool result JSON: a dispatch handle (background) or the joined combined results._delegate_depth) subagentsdepthFr) r rrrrbrrgrrr)rrs&&r> _run_batchrms^ 3u~~#6geFXFXZkmn>ors>s#E** ::,U3% HHrA)F)>rY __future__rrrloggingrconcurrent.futuresrrr dataclassesrrrtypingrr r r ,hermes_cli.observability.shared_metrics_loopr r rlrrtools.delegate_tool_child_runrrrrtools.delegate_tool_progressrrrrrtools.delegate_tool_registryrtools.delegate_tool_resultsr getLoggerrrrdrqrrrrrrrr rr/r5r?rVrYrgrmr<rAr>rys(1 #  @11,,eHmmJ?   0 1 %F%F %FPx Q"H,0=0~)D)X u  m 2#JA,!0  _  :   h%.2s"40 23hIrA