߲j#Y dZddlZddlmZddlmZdZdddZed d Gd d Zd Z de de fdZ d2dZ defdZdefdZd3dZdZdedefdZd2dZdede de de deddf dZded e de fd!Zdeddfd"Zded e de de fd#Zd$edefd%Zdede fd&Zdede fd'Zd(Zde fd)Zd*ede fd+Z Gd,d-e Z!dedd.fd/Z"dede fd0Z#dedd.fd1Z$y)4aHuman-readable rendering of ``ProcessRegistry.completion_queue`` events (completion, watch_match, watch_disabled, watch_overflow_*, async_delegation) into the ``[IMPORTANT: ...]`` / ``[ASYNC DELEGATION ...]`` text the CLI drain loop, gateway and TUI inject into the agent conversation.N) dataclass)suppress) completedsuccessz3marked lost because the process backend disappearedzfailed to start)lost failed_startT)frozenslotscZeZdZUdZeeeefdfed<defdZ dedzfdZ defdZ y) ProcessNotificationBatchzBKeep completion identity until the owning surface starts its turn.. notificationsreturnc |jDcgc]*\}}|j|jdds||f,c}}Scc}}w)N session_id)r is_completion_consumedget)selfregistryeventtexts I/home/ubuntu/.hermes/hermes-agent/tools/process_registry_notifications.py_livezProcessNotificationBatch._livesL151C1CU+%66uyyr7RS U UUs/ANc|j|Dcgc]\}}| }}}|syt|dk(r|dSdt|d}dj|g|Scc}}w)Nr [IMPORTANT: z background processes completed. Treat these results as one batch and give one consolidated response; preserve failures and actionable results.]z )rlenjoin)rr_eventrmessagesheaders rrenderzProcessNotificationBatch.renderst-1ZZ-AB\VTDBB x=A A;  X0??{{F.X.//Cs Acht|j|Dcgc]\}}| c}}Scc}}wN)process_completion_display_textr)rrr_texts r display_textz%ProcessNotificationBatch.display_text#s).$**U]J^/_,%/_``/_s . ) __name__ __module__ __qualname____doc__tupledictstr__annotations__listrr"r'rr r sJLtSy)3.//UU 0#* 0aar2r c#Kg}|D]F\}}|jdddk(r|j||f/|rt|g}||ffH|rt|yyw)zIGroup consecutive completions only; watches and delegations are barriers.type completionN)rappendr,)r batchrrs rgroup_process_notificationsr8'st E$# t 99V\ *l : LL% 'El"4=" "# El sAA!secondsrc ttd|}|dkr|dSt |d\}}|dkr|d|r|dzSdzSt |d\}}|d|r|dzSdzS#ttf$rYywxYw)z5Human-friendly elapsed string ('18m', '2h3m', '45s').r?<smrh)intmax TypeError ValueErrordivmod)r9r=r>r?s r _format_agerE7s Aw  2vAw !R=DAq2vAwQQCq'//B// !R=DAqS71g ++ ++ z "sA&&A87A8 list[str]cL ddlm}t|S#t$rgdcYSwxYw)uModel-not-found phrases from ``agent.error_classifier`` (the failover path's own list, so nothing drifts); a minimal built-in set if the import fails. Imported from ``agent.error_classifier`` so the batch renderer applies the SAME classification the failover path consumes — no hand-copied pattern list to drift. Fails open to a minimal built-in set so a classifier import problem never hides the per-task blocks. See #97667. r_MODEL_NOT_FOUND_PATTERNS)zis not a valid modelzmodel not foundmodel_not_found)agent.error_classifierrIr0 ExceptionrHs r_model_not_found_patternsrMFs.ND-.. NMMNs  ##cH ddlm}|xsiS#t$ricYSwxYw)zLActive delegation config; ``{}`` on any error. Lazy: delegate_tool is heavy.r) _load_config)tools.delegate_toolrOrL)_cfgs r_delegation_configrRUs*<v|  s  !!ct|xsijdxsdjsytd|xsgD}t fd|DS)zTrue when a result reflects a config-level model_not_found rejection: needs a model-not-found phrase AND the currently-configured model name in the same text, so a stale task failing on a removed model is not mis-attributed to the config.modelrFc3K|]J}djd|jd|jdfDjLyw) c38K|]}|st|ywr$)r.).0xs r z8_delegation_model_not_found...fsNAc!fNserrorsummaryN)rrlower)rXrs rrZz._delegation_model_not_found..fs? n[\SXXNquuW~quuY7G&HN N T T V nsAAc3TK|]vxrtfdD yw)c3&K|]}|v ywr$r1)rXprs rrZz8_delegation_model_not_found...gs$A1Q$Y$AsN)any)rXrrTpatternss @rrZz._delegation_model_not_found..gs(Tdu}A$A$A!AATs$()r.rr]rMrb)resultsconfigtextsrTrcs @@r_delegation_model_not_foundrg^s\ 2""7+1r 2 8 8 :E (*H n`g`mkm nE TeT TTr2c(t}t||sy|jdxsd}|jdxsd}d|d|dd d g}tt5d d lm}||s|jd ddd|S#1swY|SxYw)uRConfig-level model_not_found notice lines, or None (fail-open) — once per batch.NrTr;providerzconfigured provideru<⚠ SUBAGENT MODEL REJECTED: the configured Subagent Model "z" was rejected by provider "z#" (HTTP 400: not a valid model ID).zFEvery task in this batch failed for this reason before doing any work.uXCheck Settings → Advanced → Subagent Model (or: hermes config get delegation.model).r)get_fallback_chainz>No fallback chain is configured, so no failover was attempted.)rRrgrrrLhermes_cli.fallback_configrjr6)rdrerTrilinesrjs r"_delegation_model_not_found_noticermjs  !F &w 7 JJw  &3Ezz*%>)>H 7.xj9, , Qb  dE ) [A!&) LLY Z[ L [ Ls  BBu[TRUNCATED — subagent hit its iteration cap; the summary below may be incomplete. Verify before relying on it, or re-dispatch the unfinished part.]entrycbt|jdxs|jddk(S)N truncated exit_reasonmax_iterations)boolr)rns r _is_truncatedrts*  +&V%))M*BFV*V WWr2c*t|}|rdg|SgS)zKBlank + model_not_found notice block, or [] when the notice does not apply.r)rm)rdnotices r _notice_linesrws / 8F"B==**r2evttitleintro completed_at with_goalc ||dg}|jd}t|ttfrMt j dt j |}|jd|dt||z d|r(|jd|jddxsd|jd r|jd |d |jd r&|jd d j|d |jd|jdxsdd|jdxsd|S)zZShared preamble: title, intro, blank, dispatch time, [goal], context/toolsets, role+model.r dispatched_atz%Y-%m-%d %H:%M:%Sz Dispatched:  (z ago)zOriginal goal: goalcontextzContext you provided: toolsetsz Toolsets: , zRole: roleleafz Model: rTr;) r isinstancer@floattimestrftime localtimer6rEr)rxryrzr{r|rlr~tss r _preamblers  E2 EGGO,M-#u. ]].}0M N |B4r+l]6R*S)TTYZ[ swwvr':'@b&ABC wwy -c)n-=>? wwz z$))C O"? LL6#''&/3V4Jswww?O?VSV>WXY Lr2deleg_idc |jdxsigddxsig\}|jdxsg|jdd|jdxst|jdxsg}}}|t|kr||n|jdd }t|jd xsd jj d d dd }d|d|dzd|dd|rd|nd d|jddd|jddd|rd|nd zg}|jdr|j d|dd j d|DS)zXOne child of a still-running fan-out failed: say which, why, and that the batch goes on.rdNrgoals task_indexrn_tasksrrr[ rViu"[ASYNC DELEGATION TASK FAILED — z, task /]a One subagent in a background fan-out you dispatched has failed while its siblings are still running. The batch's consolidated results will still arrive when the last sibling finishes; this is an early warning so you can re-dispatch or investigate now instead of then.zTask: Status: statusr; Duration: duration_secondsr=z Error: live_transcriptzLive transcript: c3&K|] }|s| ywr$r1)rXlines rrZz._format_task_failure_notice..s4dtT4s)rrr.stripreplacer6r) rxrr^ridxnrerrrls r_format_task_failure_noticers GGI  &2$ + 3tDQGGG$*AEE,,BCGGIDVDuZ]^a^e^efm^n^trtZu3Es5z)5:quuVR/@D aeeGn" # ) ) + 3 3D# >t DC ,XJgcAgYas!L M &R 1553'( aee?@ 994e4 44r2c|jdsgSd|ddg}|jdxsi}|jdxsijD]=\}}|jd|d||j|s/|d|d ||d gz }?|jd r|jd |d |S) zOwner-died recovery diagnostics (``recover_abandoned_delegations``): last persisted status, per-task transcript paths, their verbatim tails and the owner's git state.last_known_statuszLast persisted unit status: z~ (before owner exit; not current liveness). Unrecorded outcomes remain unknown; inspect evidence before retrying side effects.transcript_tailstask_transcriptsz Task index z! transcript (may be incomplete): z--- last lines of task z transcript ---z --- end ---git_state_hintz Owner working tree at recovery: )ritemsr6)rxrltailsindexpaths r_recovery_linesrs 77& ' +C0C,D+EFbb cE GG& ' -2E 239r@@Be t {5')J4&QR 99U  /woFe Vcd dEe ww  7z*_format_batch_delegation..s155q+Ar2)keyrrrr\rru⚠u✓u✗z--- z TASK rr: z (status= api_callsz , api_calls=ru:, TRUNCATED: hit max_iterations — work may be incompletez) ---()Partial output:u(no summary — status=rz6Full live transcript (complete tool/assistant trace): ) rrrrrrwsortedrt_DONEr6_TRUNCATED_SUMMARY_NOTE_process_accounting_lines)rxrr{rdrrn_unitrunitrlr^r r_truncatedr_status r_summaryr_errorr_goaliconr!s r_format_batch_delegationrsHWWY'-2swww/?/E2UGE *c'lCL,FCJvA GGG E8=8IWUG3vhm 4RXQYYeOfD  /z; ?vF? ?  'E "I&sww/GQcehIi'j&kklmmI _S !!E www /%NsSZ|n#]^^yy ]7 ##E G!A B.55q1=3C['(uuXs';QUU9=MquuU\~W)"SZ/sQUU625F#u8u3D%%fS1WIQqc2v6(mSUV[efneoYpp89k8J|AkN#34PRT67ee.sY!I{|AEE,$7#8155B;OPTQT;U:VVYZ[Z_Z_`qZrYssu!v!IsAAz4. Re-launch in this session anything you still need.unread_completionszChild's process rrz` finished (exit code exit_codez4) but the child never read its result; output tail: output_tail)rr6rr)r^rlr?orphansus rrrs E UU) * 0bP *155+>*?r!%% SUBVW[X[B\A]]cdedidijprtducvwOO PPee()/RG {3w<.1DDyy!IAH!IIINN OUU' ( .B} 'l(;'ZZpk*++`abafafgtvxay`z| }} Lr2c |jdd}|jdxstj}|jdr t||S|jdst|jdtr t |||S|jdxsd|jd |jd }}}t |}t|d |d d |d}|t|gd|d|jddd|jddd|rdndzdgzz }|tvr+|r)|r|jt|j|nW|dk(r|jd|rd|ndzn-|jd|d |rd!|ndz|t|z }|r|d"|gz }d!j|S)#zSelf-contained re-injection for an async-delegation completion: the FULL original task source (goal, context, toolsets, role, model), dispatch time, status and result, so an agent deep in unrelated context can act on it or re-dispatch. delegation_idunknownr{task_failure_noticeis_batchrdrrr\r[u[ASYNC DELEGATION COMPLETE — rzA background subagent you dispatched earlier has finished. You may have moved on since dispatching it; the full task source is below so you can act on the result or re-dispatch if things have changed.Trrz API calls: rrrrr;r=u; [TRUNCATED: hit max_iterations — work may be incomplete]rz--- RESULT --- interruptedz.The subagent was interrupted before completingr.z3The subagent did not complete successfully (status=z).rr)rrrrr0rrtrrwrr6rrr)rxrr{rr\r[rprls r_format_async_delegationrsww 2H77>*9diikL ww$%*399 wwzj);TB'X|DD WWX.=+swwy?QSVSZSZ[bScUGFc"I  )(15 K   &E ]C5 ! 6(.a)@(AswwWiknOoNppqrLU H[] _%E7  LL0 1 W ] " LLI]brRWQX\hkl m LLEfXRPdiVXY^X_T`oqr t _S) )E  '1 1E 99U r2c |jd}t|tr!|Dcgc]}t|ts|c}ng}|xs|g}|jdxsg}gg}}ddddddddd }|D]}|jd xs|jd rd nd } | tvrt |rdndn|j| d} |j | |jdd} d| cxkrt|krnn|| n|jdd} |j djt| xsdjt|dk(rd|dd|dStt|dk(r|dnd} djt|jdxsdjxsdj|}d| d|dt|dScc}w)zLCompact UI title; the separate model notification retains all task evidence.rdrFailed Cancelled Interruptedz Timed OutStalledUnknown)failedr[ cancelledrtimeoutstalledrrejectedrr[rr Incomplete CompletedrrrrrVzBackground taskrzSubagent Task rzFinished with IssuesrrzSubagent Tasks rz tasks)) rrr0r-rrtr6rrr.splitset)rx raw_resultsr^rdrlabelstitles status_labelsresultrlabelrroutcomerys rasync_delegation_display_textr.s'')$KAKKY]A^+=QAt)s G1G1process_completecdjt|xsdj}t|dkDr|dddzS|S)NrVrPM...)rr.rr)rcmds r_short_commandrJsB ((3w}"%++- .C"3x"}3s8e 5#5r2eventscdt|dk7rt|dS|d}|jdxsd|jdd}}|dk(rd }n|tvr |d k(rd nd }n |dk(rd nd}t|jd}|dgtvr |dk7rd|dnd}|r d||d|Sd||S)z[Compact UI title for one or more process completions; the model text keeps the full output.rz Background Processes Finishedrcompletion_reasonexitedrr;killed TerminatedrLostzFailed to StartFinishedrrz (exit rrzBackground Process r)rr_REASON_STATUSr)rrxreasonrrrdetails rr%r%Os 6{af+<== )C 34@#''+WZB[IF  > !"f,&2C )Q*H + ,C'-h5P5P'PU^bcUcwyk #ikF=@  &C5 9mH[\c[dekdlFmmr2c teZdZUdZeed<eed<eed<d dedededeffd Zedededdfd Z xZ S) TimelineNotificationzQueued model text that stays string-compatible, plus the display kind and compact human title the surface paints instead of the raw notification wall.r' display_kindnotification_categoryrcRt|||}||_||_||_|Sr$)super__new__r'r r )clsrr'r r instance __class__s rrzTimelineNotification.__new__hs07?3- , ,)>&r2rrcRddlm}||t|d||rdSdS)Nr)diagnostic_process_eventasync_delegation_complete diagnosticr)agent.notification_presentationrr)rrrrs rfor_delegationz#TimelineNotification.for_delegationos:L46u=?Z#;E#B<R RHPR Rr2)r) r(r)r*r+r.r/r classmethodr-r __classcell__)rs@rr r `snF3c]`R#RdR7MRRr2r z str | Nonect|jdxs|jdxsd}|jdsyd}tt5ddlm}||}ddd|sd|d St|jd xsdj|jd }}t|d kDr|dd dzn|}d||rd|ndzdz|rd|dzSdzS#1swYxYw)u One-line provenance for a subagent-owned process event, else None. Such a process outlives the child and lands in the PARENT conversation, which would otherwise see an anonymous output wall. Keyed on ``owner_task_id`` — ``task_id`` may be the session key. owner_task_idtask_idrzsa-Nr)get_subagent_attributionzStarted by subagent z (delegate_task).rrrurz of delegation rz Task: "") r.r startswithrrLrPrrr)rxrinforrdelegs r_delegation_attribution_liner$vs#''/*Fcggi.@FBGG   e $ D ) 1@'01 %gY.?@@dhhv&,"-335txx7P%D!$TS4: dD"7) ,U/%0IXZ [^a a%)$q! 34/1 3411s C((C1c|jdxsd}|dk(rd|jdxsdStj|xs|jddd k(rd SdS) Nrrrzterminated by termination_sourceHermesrr;rzcompleted normally)rr)rxrs r_completion_statusr(sl WW( ) 5XF (< = IJKK   f % o#''+WZB[_`B`*>ofnor2c|jdd}|dvrd|jdddS|dk(r t|S|jd d |jd d }}t|}|jd rd |d }|r|dnd}|dk(rr|jdxsd}d|d|jdddtt |jdxsdd|jddd|d|d|dS|dk(rV|jdd}d |d!|jd"dd#|d|d$|jdd |r d%|d&zdzSdzdzS|jd'd}|jdd}|d(vrd)nd} |r't |t rt|d*kDr d+|d,d-z}n|jd.rd/|d.d0|d1|}d |d2t|d3|| d4|d|d5|dS)6zEFormat a completion_queue event into an ``[IMPORTANT: ...]`` message.r4r5)watch_disabledwatch_overflow_trippedwatch_overflow_releasedrmessagerrasync_delegationrrr handoff_notez=Handed off to you by a subagent before it finished. Purpose: r heartbeatoutputz((no new output since the last heartbeat)z[Background process z heartbeat #seqr;u — still running after elapsedrz (next in intervalz)s; you will also be told when it exits). z Command: z Output since last heartbeat: watch_match suppressedz[IMPORTANT: Background process z matched watch pattern "patternz". z Matched output: z (z/ earlier matches were suppressed by rate limit)r>-15143z , SIGTERMiXue...(output trimmed — subagent-owned process; see the delegation's live transcript for full output) iN output_cutz ...(first u6 characters cut — process(action="log", session_id="z") has the full output) rVz (exit code z). z Output: ) rrr$rErrr.rr() rxevt_type_sid_cmd _attribution attribution_out_sup_exit_signals rformat_process_notificationrFswwv|,HZZcggi45Q77%%',,y13779i3P$D/4L ww~VWZ[iWjVkl )5\N"%2K;wwx N$N"4& SWWUC5H4IIb5!3!8q9:;:cggjZ]F^E_`6m9TF*J4&PQ S T = ww|Q'-dV3LSWWU^`cMdLeejm9TF*=cgghPR>S=T VNRTFIJ \^a b cY[ \^a b c GGK %E 778R D"&>>kBG 4-#d)c/ >45k    S./0 $v%?vG *$q1CC1H0IV[U\]d\eei -yk$q :;r2)rrF)rzlist[str] | None)%r+r dataclassesr contextlibrrrr r8rr.rErMr-rRrsrgrmrrtrwrrrrr0rrrPROCESS_COMPLETE_DISPLAY_KINDrr%r r$r(rFr1r2rrJs+  ! Oars $d#aa$a0  , ,3 , ND UD U* XX$X+ 4CuTX]h"5T5S5S5&+".$.#.U.s.b$&$$$3$NGtGG2!36s6 nDnSn"R3R,4d4|4(pDpSp,;T,;l,;r2