+ Wj(Rt^RIHt^RItRtRtRRltRtRR ltR R 0t R R lt RRlt Rt RRlt RtR#)uBackground-process notification turns the gateway admits for this CLI's session (W11). On main the classic CLI drained ``tools.process_registry`` itself, queued a ``ProcessNotificationBatch`` into ``_pending_input`` and ran the ``[IMPORTANT: Background process ...]`` turn. Over the session authority the process runs in the gateway: the gateway drains the completion, admits the notification turn (``authority.admit_automation``) and runs it. The CLI neither drains the registry nor claims delivery (IPS-086) — it only watches its session's stream. The claim's ``message.start`` carries the admission's async-result card (``display_kind`` / ``display_text`` / model ``text``; ``gateway.session_automation.admission_display``). The idle tick turns it into main's ``TimelineNotification``, so main's input path paints the same ``◈ Background Process Finished: ...`` header, and ``GatewayAgent.run_conversation`` pumps that already-admitted turn (no ``prompt.submit``) through the same callbacks as a typed turn. ) annotationsNcR^RIHp\VRR4p\W!4'dV#R#)zPThe CLI's gateway session store, or None (a test double / an unavailable store).)GatewaySessionStore _session_dbN) hermes_cli.gateway_session_storergetattr isinstance)clirstores& SC:\Users\johnn\AppData\Local\hermes\hermes-agent\hermes_cli\gateway_tools_notify.py gateway_storer s(D C -Eu::5DDcdVPR4p\V\4'gR#VPR4VPR4VPR4rCpV'dK\V\4'd5VP 4'd\V\4'd V'gR#V#)payloadN display_kind display_texttext)getrdictstrstrip)paramsrkinddisplayrs& r _cardrs|jj#G gt $ $!++n5w{{>7RT[T_T_`fTg4D z'3//w}}jY]_bNcNcko Nr cV^8dQhRR/#returnNone)formats"r __annotate__r"%s55t5r c  ^RIHpVP\VRR4rCVP V4p\ W4'dR#RVnVPpVP4p\T\4'd6^RIHpT!T\TRR44'dKJTP!T4R#\T\"4'dTP%R4MRp \T \"4'dT P%R4T8wdKT P%R4R8Xd:^R IHp T !T P%R 44p T 'dTP+T 4EKT P%R4R 8wgT P%R 4'gEK3TP,P%T R ,4p T e0^R IHp \3YR T R ,RT P%R4/T 4R#\5T 4pTfEKR T R ,RTR,RT P%R4/Tn\7TP8T!TR,TR,TR,TP%R4;'gR44R# \Pd\Y4R#i;i)aIdle tick: find a gateway-admitted notification turn's ``message.start`` for this session and queue main's ``TimelineNotification`` for it. Frames before it are the between-turn leftovers ``run_conversation`` would discard anyway; frames after it stay queued for the pump.)TimelineNotification session_idN) lost_beforeepochrtypezreview.summary)review_summary_liner message.start admission_id_SeededQueryMessageexecution_generationrrrnotification_categoryresult)$tools.process_registry_notificationsr$ connectionrstate_adoption_waiting admitted_turnevents get_nowaitqueueEmptyrecover_queuedr Exceptionhermes_cli.gateway_connectionr&putrrhermes_cli.gateway_agentr)_agent_status_print queued_inputsr r-_adoptr _put_first_pending_input)r r r$r2r%r3r6framer&rr)line queued_textr-cards&& r queue_admitted_turnrH%s4J"--wsL$/O   Z (E$$E   F  %%'E eY ' ' A5'*gt"DEE JJu  (25$(?(?8$T&$''6::l+Cz+Q  ::f !1 1 D&vzz)'<=D''-  ::f  0 >8R8R ))--f^.DE  " 0 3~0F 6 CY8Z \]h j V} < -vn/EvtTZ|5vzzBX7Y[3%%'; L$~.^0D HH, - 9 9(; < O{{  3 &  sI)) J  J c^RIHpVPPVR,4W!PVR,&\ VP V!W2R,R74R#)r,r+)r+N)r r-misseddiscardadoptedrBrC)r r3rMrr-s&&&& r rArA]sI' LL01-4MM'.)*s!!#6tR`Ja#bcr cV^8dQhRR/#)rrboolr )r!s"r r"r"ds  T r c VP'gR#\VRR4pVfR#VP;_uu_4VPUu0uFp\VRR4kK ppRRR4XP VP 4VPUu.uF qUV9gK VNK upFpVPP VR4K! \VP4#uupi +'giL;iuupi)z[An adopted item is still in ``_pending_input`` (one ``/queue clear`` dropped is forgotten).FrCNr+)rMrmutexr8addarmed_admissionpoprO)r r3pendingitemwaitinga admissions&& r r4r4ds ===c+T2G CJ==Q=4746=Q  KK%%&!&CA72BaaC  )T*D   R Ds)C' C"!C'C:!C:"C'' C7 cancelledrejectedcV^8dQhRR/#rr )r!s"r r"r"vs++$+r c^RIHpVPP\ VRR44pVP 'd.VP VP8XdVP'gR#VPVnVP;'gRUu/uF<p\V\4'gKVPR4VPR4bK> pp\VP P44EF/wrgWcP9g'WcP9dVPV4R8XdK>VP!RVP"VRR 7;'g/pTPR4p T R8XdTPP%T4KT R 8XdTTPR 4\&9d:TP P)TR4TPP%T4KT R9dEKRTR TPR 4R R/p T R 8XdYR&\+YY4R# R#uupi Td RTnEKMi;i)asIdle tick, after the stream had no ``message.start`` for them: this viewer's ``/queue`` admissions the owner started or settled without this viewer painting the turn (a local turn's drain or pump dropped the start, or it ran across a reconnect, which replays no frames). Read on a new published pending list or a dropped start only, never every tick. Still running: adopted and pumped live, its reply completed from the receipt (``recovered``). Settled: adopted with its saved result, painted without a pump. One that never ran (cancelled, rejected) is forgotten: the only point where ``queued_inputs`` drops a row unpainted. )GatewayClientErrorr%Nr+statusqueuedzprompt.receiptT)r%r+include_resultterminaloutcomer. recoveredreceiptr )startedrb)hermes_cli.gateway_clientr^r2r3rr@ recovered_seq pending_seqrKrUrrrlistitemsrMcallr%rL _NEVER_RANrTrA) r r r^r3rowlistedrYrrer_rMs && r r:r:vs =    " "73 d#C DE    5#6#6%:K:K#KTYT`T`T`++EDIMMDWDWUWDW qDWS[efiko[p8cggn%swwx'88DWF q 3 3 9 9 ;<  %)<<*GFJJW`LaemLm  jj!1cnn[d04!6<<9;  X& X  LL  +  Z GKK $:j$H    # #It 4 LL  +  0 0 !9.DgkkRhFi& Z !(I s7)7=r" "$E   s$H44%H4=%H9#H99I  I cV^8dQhRR/#rr )r!s"r r"r"s1141r cVPR4R8XdGVPR4VP9d%VPPVR,4R#R#R#)zA frame dropped outside its turn: a ``/queue`` admission's ``message.start`` is remembered so the idle tick paints that turn from its receipt instead of losing it.r(r*r+N)rr@rKrR)r3rs&&r missed_startrssKzz&_,N1KuObOb1b /02c,r cVP;_uu_4VPPV4V;P^, unVPP 4RRR4R# +'giR#;i)zAhead of anything already queued: the gateway is running this turn NOW (typed inputs the post-turn path re-queued are admitted behind it), and a typed turn run first would drop it.N)rQr8 appendleftunfinished_tasks not_emptynotify)rUrVs&&r rBrBsN    &  A%   " s AA.. A? cV^8dQhRR/#rr )r!s"r r"r"s]]d]r c\VRR4pV'd \V4MRpVe-W#PP\VRR44nR#R#)zThe input loop took ``item``: when it is an adopted ``/queue`` admission, the next ``run_conversation`` pumps exactly that admission (``take_admitted_turn``).r+Nr%)rr r2r3rS)r rVrYr s&& r arm_adoptedr{sKnd3I"+M# E S\wsL$?@Pr cFVP4p\VRR4Ruq2nV'dVPP VR4MRpVeVP P VR4V#\VRR4pRVnV'dVPR4V8wdR#V#)zThe admitted turn ``run_conversation(text)`` replays instead of submitting; None (and the stale notification adoption dropped) for any other turn. A ``/queue`` admission is matched by the id ``arm_adopted`` recorded, a notification turn by its model text.rSNr5r)_staterrSrMrTr@r5r)agentrr3armedrMs&& r take_admitted_turnrs LLNE#*52CT#JD E 05emmt,4G t,e_d3GE gkk&)T1 Nr )__doc__ __future__rr8r rrHrAr4rnr:rsrBr{rr r r rsU # E5pd : & +\1#]r