+ lHj<a0t$Rt^RIHt^RIt^RIt^RIt^RIt^RIH t H t H t H t ^RI Ht^RIHt]P"!R4t]P&!4tRsR]R &]P&!4t/tR ]R &^t/tR ]R &R RltRRltRRltRRltRR/RRlltRRlt RRlt!RRlt"RRRRR R/R!R"llt#R#R$lt$]%!0R3m4t&R%R&lt'R4R'R(llt(]%!0R5m4t)R+R,lt*R-R.lt+R/R0lt,R1R2lt-R*R6R)R7/t.R#)8zXLive-subagent registry + model-facing control plane (list/steer/stop) for delegate_task.) annotationsN)AnyDictListOptional)request_hard_interrupt) tool_errorztools.delegate_toolFbool _spawn_pausedzdict[str, dict[str, Any]]_active_subagents_recent_subagentsc V^8dQhRRRR/#)task_id Optional[str]returnzOptional[dict[str, Any]])formats"A/home/ubuntu/.hermes/hermes-agent/tools/delegate_tool_registry.py __annotate__rs n nm n8P ncRV'd\V\4'gR#\;_uu_4\P V4;'g\ P V4pRRR4XfR#RVRVP R4RVP R4/# +'giL<;i)z``{subagent_id, goal, delegation_id}`` for a process task_id that belongs to a live or recently-finished child (children run their terminal sessions under ``task_id == subagent_id``), else None.N subagent_idgoal delegation_id) isinstancestr_active_subagents_lockr getr )rrecords& rget_subagent_attributionr s *Wc22  "&&w/QQ3D3H3H3Q  ~ 7FFJJv,>QWQ[Q[\kQl mm s 3B B& c V^8dQhRRRR/#)rpausedr rr)rs"rrr'sTdrc~\;_uu_4\V4s\uuRRR4# +'giR#;i)zfGlobally block/unblock NEW delegate_task spawns (active children keep running). Returns the new state.N)_spawn_pause_lockr r )r"s&rset_spawn_pausedr%'s%  V     s+ < cV^8dQhRR/#rrr r)rs"rrr.srch\;_uu_4\uuRRR4# +'giR#;i)N)r$r rrris_spawn_pausedr).s      s  1 c V^8dQhRRRR/#)rrdict[str, Any]rNoner)rs"rrr2s((~($(rcVPR4pV'gR#VPRR4\;_uu_4V\V&RRR4R# +'giR#;i)rNaccepting_steerT)r setdefaultrr )rsids& r_register_subagentr12sG **] #C  '.  !'#   s A A! agentc$V^8dQhRRRRRR/#)rrrr2rrr,r)rs"rrr:s& G Gc GS GD Grc 2\;_uu_4\PV4pVeVe!VPR4VJg RRR4R#\PVR4VPR4pV'g RRR4R#RUu/uFqDVPV4bK up\V&\ \4\ 8d/\P\\\44R4KFRRR4R#uupi +'giR#;i)z[Drop the live record (exact agent identity when given) and keep a bounded attribution stub.Nr2r)rrowner_agent_session_id) rr rpopr len_RECENT_SUBAGENTS_CAPnextiter)rr2rr0ks&$ r_unregister_subagentr<:s  "&&{3 >%-6::g3F%3O   k40jj'  =p!pVZZ0= %* !5t<  gG%Wc22w}}wD   LL> Q    sA0C0 $C08B9?+C0+C09 C-C(C0(C--C00 D c V^8dQhRRRR/#)rrrrr r)rs"rrr\s  C D rcT\;_uu_4\PV4pRRR4X'dVPR4MRpVfR#\\ VRV R244# +'giLK;i \ d"p\ PRY4Rp?R#Rp?ii;i)zRequest that one running subagent stop at its next iteration boundary (cooperative: the flag propagates to in-flight tools and recurses into grandchildren via AIAgent.interrupt()). True iff a matching subagent was found.Nr2FzInterrupted via TUI ()z!interrupt_subagent(%s) failed: %s)rr rr rrBrCrD)rrr2rHs& rinterrupt_subagentrM\s "&&{3 #)FJJw tE }*54I+VW2XYZZ   8+Ks#A(A;( A8 ; B'B""B'cV^8dQhRR/#r'r)rs"rrrksddddrc(^RIHpVPR4fR#VPR4p\V\4'dVPR4MVPR4pWAJ;'g%\WB4;'dVP V4#)aAuthority follows the owning session's LIVE transport slot, read at check time. ``owner_transport`` on the record is only the capture-time marker that a gateway session commissioned the child (``None`` = no RPC authority ever). The slot is authoritative because every reattach path (prompt.submit, queued drain, resume, activate, viewer failover) already mutates it; a per-record copy needed a matching registry sync at each of those sites and two were missed (#106663). Records whose owner is not a session dict keep the exact-object rule.)FanoutTransportowner_transportFowner_session_record transport)tui_gateway.transportrPrrdictcontains)rrSrPownerbounds&& r_subagent_transport_matchesrYksw6 zz#$, JJ- .E&0&=&=EIIk "6::N_C`E   c c*U"D"b"bXaIbcrowner_session_idrQrRc 0V^8dQhRRRRRRRRRRR R /#) rrrtextrZrrQrrRrr r)rs"rrr|s>!!!!6C!]`!! !rcV'dVP4'gR#\;_uu_4\PV4pV'dVPRR4'g RRR4R#VePVPR4V8wg/Ve+\ WS4'dVeVPR4VJd RRR4R#VPR4pVf RRR4R#\ VP V44uuRRR4# \d*p\PRY4Rp?RRR4R#Rp?ii;i +'giR#;i)ukQueue steering text into a running subagent without stopping it. AIAgent.steer() appends the text to the child's last tool result at its next iteration boundary — the current tool call is never cut. True iff the text was QUEUED while the child still accepted work; False for unknown/closed id, ownership mismatch, no live agent, or empty text. ``owner_session_id=None`` keeps the in-process helper contract; gateway callers must pass exact authority. Acceptance and completion are linearized by the registry lock: if acceptance wins but no delivery boundary remains, the text lands in the entry as ``missed_steer``. Fr.NrZrRr2zsteer_subagent(%s) failed: %s) rErr rrYr steerrBrCrD)rr\rZrQrRrr2rHs&&$$$ rsteer_subagentr_|s tzz||  "&&{3VZZ(95AA   ' JJ) *.> >&.vGG#+zz019MM  7# =   D)*! "  LL8+ K' " #  sB5D?%D?0A D?D?$D D<D7)D?7D<<D?? E c V^8dQhRRRR/#)rrZrrztuple[Any, Any]r)rs"rrrs  }  rcZV'gR#^RIHpV!V4# \dRu#i;i)uExact request transport + live session generation, if any — an in-process bridge, not a serializable capability. Non-gateway hosts get ``(None, None)``.) _current_session_steer_authority)NN)tui_gateway.serverrbrB)rZrbs& r _capture_gateway_steer_authorityrds6 G/0@AA s  **cV^8dQhRR/#)rrzlist[dict[str, Any]]r)rs"rrrsss3src "\;_uu_4\P4UUUu.uF3qP4UUu/uFwrV\9gKWbK uppNK5 upppuuRRR4#uuppiuupppi +'giR#;i)zCopy of the running subagent tree ({subagent_id, parent_id, depth, goal, model, started_at, tool_count, status, ...}); safe from any thread.N)rr valuesitems_PRIVATE_RECORD_KEYS)rr;vs rlist_active_subagentsrlsc WhWoWoWqrWqRS'')M)$!q8L/L)MWqr Mr  s3A=A6 A0A0A6 !A=0A6 6A== B c(V^8dQhRRRRRRRR/#)r child_agentr parent_agentmax_hopsintrr r)rs"rrrs)3cSQUrcVeVfR#Tp\V4F;p\VRR4p\V4'dV!4MRpVfR#WaJdR#TpK= R#)uTrue when *child_agent* sits below *parent_agent* in the spawn tree (walks the ``_delegate_parent_ref`` weakref chain stamped at build time). Identity only — a parent may steer/stop its own children and grandchildren, never a sibling tree owned by another conversation.NF_delegate_parent_refT)ranger@rA)rnrorpcur_refancestors&&& r_is_descendant_ofrysal2 C 8_c148$SMM35t    # rr^stopc$V^8dQhRRRRRR/#)r session_idrrorrrr)rs"rrrs!   c c rc\T;'gR4p\VRR4pV'dVfV#VPV4pV'd \V4#T# \dTu#i;i)zTip of a session id's compression lineage via the parent's live SessionDB (best-effort; input unchanged when unavailable) so a delegation dispatched before a compression rotation still matches the rotated parent. _session_dbN)rr@resolve_resume_session_idrB)r|ror0dbresolveds&& r_resolve_session_lineagersj jB C }d 3B "* //4 (s8}1c1  sA AA A('A(c$V^8dQhRRRRRR/#)rrr+rorrr r)rs"rrrs&AA.AAArc6\VPR4V4'dR#\VPR4;'gR4p\\VRR4;'gR4pV'd V'gR#W#8XdR#\ W!4V\ W1409#)uTrue when *parent_agent*'s conversation owns this live-child record. Tier 1: identity — the ``_delegate_parent_ref`` weakref chain reaches *parent_agent* (fast path while the parent AIAgent survives the run). Tier 2: durable lineage — the record's ``owner_agent_session_id`` matches the caller's ``session_id`` after resolving compression-rotation lineage on both sides. Tier 2 exists because the identity chain is BRITTLE across parent rebuilds: the CLI sets ``self.agent = None`` mid-session (route change, credential refresh, /model, MoA one-shots) and builds a NEW AIAgent while the child keeps a weakref to the old one. Delivery routes by durable session id; control must use the same spine or running children go invisible/unsteerable. r2Tr5r~r|F)ryrrr@r)rro owner_sid parent_sids&& r_owns_subagent_recordrsG,l;;FJJ78>>B?IW\<<BBCJ J #I <MefpMAA AArc V^8dQhRRRR/#)rrorrr+r)rs"rrrsrc\;_uu_4\\P44pRRR4.pXEF p\ W04'gKVP R4pTP RVP R4RVP R4RVP R4RVP R4RVP R4R\V\\34'd'\\P!4V, ^4MRR\VP RR 44R \VP R 4R R4/4EK R RR\V4RV/pV'gRVR&V# +'giELC;i)N started_atr parent_idrmodelstatusrunning_secondsr.Flive_transcriptr2_live_transcript_pathactionlistcount subagentsuNo live subagents right now. Children that already finished have delivered (or will deliver) their results as normal completion messages — there is nothing to steer or stop.note)rrr rgrrappendrrqfloatroundtimer r@r7)rorecordsentriesrjstartedpayloads& r _list_payloadrs9  (//12 G $Q55 %% % 155/ {+ AEE&M QUU7^ aeeHo *WWZ\aVbBcBcuTYY[7%:A>im tAEE*;U$CD wquuW~7NPTU   (#g, U\]G  I  N1  s E'' E8 c ,V^8dQhRRRRRRRRRR/#) rrrrrmessagerorrr)rs"rrrs1//3/]/]/jm/ru/rc VR8Xd"\P!\V4RR7#T;'gRP4pV'g\ RV R24#\ ;_uu_4\ PV4pRRR4Xe\WS4'g\ RV R 24#VR 8Xd,T;'gRP4'g \ R 4#\PV4pVf\ R V R 24#Vwrxp VR8Xd \V4M\WBP44p V 'd!\P!RVRVRVRV/RR7#\ V PVR74# +'giEL;i)zSynchronous control plane for delegate_task: list/steer/stop. Runs in-turn (never backgrounded) over the same registry the TUI overlay drives, scoped so a conversation can only control its own spawn tree.rF) ensure_asciir~zaction='zK' requires subagent_id (from the spawn dispatch response or action='list').NzNo live subagent 'z' in this conversation's spawn tree. It may have already finished (its result arrives as a normal completion message). Use action='list' to see live children.r^zOaction='steer' requires a non-empty 'message' describing the course correction.zUnknown action 'z#'. Use spawn, list, steer, or stop.rzrrrr)r0) jsondumpsrrErrr rr_CONTROL_OUTCOMESrMr_r) rrrror0routcomerrfailureoks &&&& r_handle_control_actionrsezz- 5EJJ   " # # %C HVH,wxyy  "&&s+  ~26HH &K K  '--R!6!6!8!8kll##F+G,VH4WXYY#F'$*f$4 C .mmo:^B zz8V]C6SY[_`otuu gnnn- ..#  s (E77 F >r2r.rQrZrR)>rrzr^)interrupt_requesteduThe subagent stops at its next iteration boundary (in-flight tool calls are asked to cancel). Its partial result still re-enters the conversation as a completion message — do not wait or poll.uyCould not interrupt '{sid}' — it likely finished in the last moment. Its result arrives as a normal completion message.)queueduSteering text queued. The subagent sees it appended to its next tool result — the current tool call is never cut. If the child finishes before a delivery boundary remains, the text is reported back as missed_steer in its completion entry.zSubagent '{sid}' is no longer accepting steering (finishing or already finished). Its result arrives as a normal completion message; re-delegate a follow-up task if more work is needed.)/__conditional_annotations____doc__ __future__rloggingr threadingrtypingrrrragent.interrupt_compatrtools.registryr getLoggerrCLockr$r __annotations__rr r8r r r%r)r1r<rIrMrYr_rd frozensetrirlry_CONTROL_ACTIONSrrrrr)rs@rrs*^"  ,,9%   0 1NN$ t")02,1 /1,1 n( G4 GQ( d"!FJ!cg! $!F !!|}s &67 A06/>   r