+ jHjRt^RIHt^RIt^RIt^RIt^RIt^RIt^RIt^RI H t ^RI H t H t HtHt^RIHt^RIHt^RIHtHt^RIHtHt^R IHtHt^R IHtHtH t ^R I!H"t"H#t#H$t$H%t%H&t&^R I'H(t(^R I)H*t*]PV!R4t,RRlt-RR/RRllt.0R&mt/R't00R(mt1]2!0R)m4t3^t4^R#).aLProcess/completion/update notifications, media delivery and async-delegation delivery for GatewayRunner. Split out of ``gateway/run.py``; bound onto ``GatewayRunner`` via the MRO. ``gateway.run`` internals are imported lazily inside method bodies (import cycle), so ``patch("gateway.run.X")`` keeps intercepting them at call time. ) annotationsN)Path)AnyDictOptionalcast)t)jittered_backoff)Platform_BUILTIN_PLATFORM_VALUES)BasePlatformAdapter_mark_notify_metadata) MessageEvent MessageType) SessionEntry SessionSource SessionStore)_delivery_target_key_log_suppressed_notice_target_key _send_error _send_failed)GatewayUpdateNotificationsMixin)!GatewayNotificationOwnershipMixinz gateway.runc$V^8dQhRRRRRR/#)profile Optional[str]platform_valuestrreturntuple)formats">/home/ubuntu/.hermes/hermes-agent/gateway/run_notifications.py __annotate__r%!s'bb}bcbbgbc:\VfWV4#V RV 2W#4#)a1Notice-dedupe key for one SERVED profile's home channel. A secondary uses the ``:`` key convention the runtime status already stamps in ``gateway_state.json``; the launch profile keeps the bare platform value so a marker written before this change still matches its delivered targets. :)r)rrchat_id thread_ids&&&&r$_served_notice_target_keyr+!s: !/W` bb29!N;K/Lg bbr&rcV^8dQhRR/#)rrrr")r#s"r$r%r%,s  ] r&c ^RIHpV!WV4# \d<p\P RT'dT R2MR\ TRT4T4Rp?R#Rp?ii;i)z``resolve_delivery_transport`` isolated to one target: ``None`` (logged) on failure. The fan-out spans every served profile, so one profile's broken adapter must not abort the pass and starve every profile after it in dict order. resolve_delivery_transportz/Home-channel transport unavailable for %s%s: %sr(valueN)gateway.deliveryr/ Exceptionloggerdebuggetattr)platformconfigadaptersrr/excs&&&$ r$_safe_delivery_transportr;,sY <)(HEE  =$wiqM"gh.RTW Y s A0AAg@c V^8dQhRRRR/#)rstepintr floatr")r#s"r$r%r%KsKKCKEKr&cd\P!4\V\\RR7,#)zVWhen a refused queued notice is next offered: exponential from the drain base, capped. base_delay max_delay jitter_ratio)time monotonicr !_WATCH_INJECTION_RETRY_BASE_DELAY%_COMPLETION_INJECTION_RETRY_MAX_DELAY)r=s&r$_refusal_retry_atrJKs, >> . :7cK KKr&dropreleasedefercompleteu[INTERNAL NOTIFICATION — generated by the Hermes gateway, not written by a human user. Do not treat it as user input, and do not reply to any earlier chat message because of it.]c V^8dQhRRRR/#)rtextrr r")r#s"r$r%r%`s 8 8c 8c 8r&cVP4pVP\4'dV#VR,\,#)uBAppend unambiguous machine provenance to model-facing notification text (#52694). A process notification re-enters the conversation as a role=user turn on every wake path (push ``handle_message`` and the api_server self-post alike); without this footer the model has read it as something the human said — including "replying" to the message the watch was armed from. Appended, not prepended, so start-anchored consumers (session timeline, memory gating, desktop notification detection, the SYSTEM prefix) keep matching. Idempotent so a retried delivery never stacks footers.  )rstripendswithINTERNAL_NOTIFICATION_FOOTER)rPs&r$_mark_internal_notificationrV`s4 ;;=D }}122 &=7 77r&c V^8dQhRRRR/#)revtdictr rr")r#s"r$r%r%psJJtJJr&c4a\SPR4;'gR4P4p\SPR4;'gR4P4P4pVP R4'gVR 9dR#V'gC\ ;QJdV3RlR 4F 'gK RM RM!V3RlR 44'dR#\SPR4;'g T;'gR4P4#) zKRecognize API routes, not malformed structured or partial messaging routes. session_keyr0r7agent:c3F<"TFpSPV4xK R#5iN)get.0fieldrXs& r$ 0_raw_process_event_session_id..vs^8]uCGGENN8]s!TForigin_session_id>r0 api_server)r) chat_typer*)rr_striplower startswithany)rXr[r7sf r$_raw_process_event_session_idrlpscggm,22399;K377:&,,"-335;;=Hh''8;M+M ^8]^^8]^^^ sww*+@@{@@b A G G IIr&c V^8dQhRRRR/#)rrXrYr zdict[str, str]r")r#s"r$r%r%{sr&c^RIHpHpHpVP RR4pVR8Xd'RTRVP R4;'g V!V.4/#VR8Xd RRRV!V4/#VR 8Xd^R IHp^R IHpRVRV!V4/#/#) aHThe card of a local process notice: the async-result card the in-process TUI wrote for a completion or async delegation (a gateway-side ``/review`` reports as one), and a liveness tick's one-line receipt. The claim's ``message.start`` carries it, and an idle classic CLI only opens a turn that has one. ``{}`` for a watch match.)PROCESS_COMPLETE_DISPLAY_KINDasync_delegation_display_textprocess_completion_display_texttype completion display_kind display_text _display_textasync_delegationasync_delegation_complete heartbeat)"INTERNAL_NOTIFICATION_DISPLAY_KIND)heartbeat_display_text)$tools.process_registry_notificationsrorprqr_gateway.response_filtersrzr{)rXrorprqevt_typerzr{s& r$_local_completion_cardr{s ggwwv|,H< = 8 b b<[]`\a>B?EEG):%& ww'((,/0H,I() (..( .s34CGG$78>>B?EEG0A,-!122~2-1.-A)* Or&c]tRt^t$RtRyt.RzO]R,O5t]P!RR44t RRlt R{RR llt R|R R llt R{R Rllt RRltRtRtRtRRltRtR]R&RRltRR/RRlltRRltRR ltR!R"lt]R#R$l4tR%R&ltR'R(ltR)R*ltR{R+R,lltR-R /R.R/llt ]R0R1l4t!R2R3lt"R4R /R5R6llt#R}R7R8llt$R}R9R:llt%]R;R<l4t&R=R>lt'R?R@lt(RARBlt)]*PVRCRDl4t,RER~/RFRGllt-RER~/RHRIllt.]RJRKl4t/]RLRMl4t0RNROlt1RPRQlt2]RRRSl4t3RTRUlt4RVRWlt5RXRYlt6RZR[lt7R\R]lt8R^R_lt9R`Ralt:RbRclt;RRdRellt<]RfRgl4t=]RhRil4t>RjRklt?RlRmlt@]RnRol4tARpRqltBRrRsltCRtRultDRvRwltERxtFR#)GatewayNotificationsMixinzhProcess/completion/update notifications, media delivery and async-delegation delivery for GatewayRunner.NNc~]tRt^t$RtRtR]R&RtR]R&RtR]R&R t R ]R &Rt R]R &Rt R]R &Rt R]R&Rt R #)*GatewayNotificationsMixin._CompletionClaimz/Pre-flight outcome for one completion delivery.r0r delegation_idclaim_idTboolproceedNOptional[bool] early_resultowner_session_idrFrMr")__name__ __module__ __qualname____firstlineno____doc__r__annotations__rrrrrrM__static_attributes__r"r&r$_CompletionClaimrsM= s#'+ n+ "#"!#3#tr&rc V^8dQhRRRR/#)rcontentrr Noner")r#s"r$r%&GatewayNotificationsMixin.__annotate__s G Gc Gd Gr&c "^RIHpVPV4pV'gR#\VRR4p\VRR4pV'dH\VRR4\P 8Xd(V!WVV4'd\ PRV4R#\VRR4p\VRR4p\V\4'd*RV9d#^R I H p V !VPR4R R 0R 4p M7V'd.\VR 4'dVPVP4MR p VP!V4p V R 8Xd\VR R4'd\#\$P&R\VRR4RR7;_uu_4VP)VP*VP,W+R7GRjxL p \V RR4'd RRR4R#RRR4VP/VP*W+R7GRjxL R#LR +'giL9;iL5i)zIDeliver a setup/operational notice using platform-specific privacy rules.)_is_slack_ignored_channelNr8r)r7z@Skipping Slack platform notice for configured ignored channel %sextranotice_delivery)_normalize_choicepublicprivateget_notice_deliveryuser_idz7[%s] send_private_notice failed, falling back to public?Texc_inforsuccessF) gateway.runr_delivery_adapter_forr6r SLACKr4info isinstancerYgateway.configrr_hasattrrr7_thread_metadata_for_sourcerloggingDEBUGsend_private_noticer)rsend) selfrrradapterr8r)adapter_config adapter_extrarrrresults &&& r$_deliver_platform_notice2GatewayNotificationsMixin._deliver_platform_notices9,,V4 x.&)T2 gfj$78>>INghnzAOBOB KKZ\c d !(D9> mT * */@M/Q 8/ 0A0ABS0TW_ajVkmuvO@F'RXZoJpJp**6??; 33F; i 'GFIt,L,L  X C04 '::6>>6>>[b:vv69e44  5 ll6>>7lFFFw  GsIC+H.B H8,G9$G7%G9= H(H0H 1H7G99 H  HNc(V^8dQhRRRRRRRR/#) rresponsereventrthread_metadataOptional[dict[str, Any]]r rr")r#s"r$r%rs2;b;b;b$0;bLd;b ;br&c xa"^RIHp\\PR4;_uu_4RV9o^RIHpHpVPV4wrVP!V4pVPV 4Ve \V4M*VPVPVPV44p VPPp RV3Rllp VU Uu.uFwrV !W4'gKV NK pp pVU Uu.uFwrV !W4'dKW3NK pp pV'd:VU u.uFp RV!V 4 2R 3NK pp VP!V VV R 7GRjxL VFwpp\+V4P,P/4pV!VPP0VVR 7'd VP3V VV VR 7GRjxL KnV\49dVP7V VV R7GRjxL KVP9V VV R7GRjxL K RRR4R#uupp iuupp iuup iL \"d-p\$P'R TP(T4Rp?ELRp?ii;iLLLc \"d.p\$P'RTP(T4Rp?EKGRp?ii;i +'giR#;i5i)u-Deliver explicit MEDIA: tags from an already-streamed response (text already delivered). EXPLICIT-ONLY, unlike the non-streaming path in ``gateway/platforms/base.py``: a bare local path in a streamed reply is shown text or stale inspected content, and promoting it sent files the model never asked for. MEDIA tags are NOT deduped against prior turns (a final-reply directive is a deliberate attach); stale auto-appended tags are deduped upstream. Only ``MEDIA:`` directives — the explicit attachment contract — trigger post-stream uploads. See #20834. )quotez'Post-stream media extraction failed: %sz[[as_document]])r should_send_media_as_audioNc$V^8dQhRRRRRR/#)r media_pathris_voicerr r")r#s"r$r%LGatewayNotificationsMixin._deliver_media_from_response..__annotate__s& ^ ^c ^T ^d ^r&c<\V4PP4pV\9;'dV'*;'dS'*#r^)rsuffixri _IMAGE_EXTS)rrextforce_document_attachmentss&& r$ _is_photoIGatewayNotificationsMixin._deliver_media_from_response.._is_photos=:&--335k)]](l]]C]?]]r&zfile://r0)r)imagesrz0[%s] Post-stream image batch delivery failed: %s)r)r) audio_pathrr)r) video_pathr)r) file_pathrz*[%s] Post-stream media delivery failed: %s) urllib.parserrrWARNINGgateway.platforms.baser r extract_mediafilter_media_delivery_pathsextract_imagesrYrr_reply_anchor_for_eventr)send_multiple_imagesr3r4warningnamerrrir7 send_voice _VIDEO_EXTS send_video send_document)rrrrr_quoter r media_filescleaned _thread_metar)rpv image_pathsnon_image_mediarerrrrs&&&&& @r$_deliver_media_from_response6GatewayNotificationsMixin._deliver_media_from_responses 1 W__.W X X):h)F & ^#*#8#8#B K-II+VK  " "7 +#._%55ellDD`D`afDgh  ll**G ^ ^*5H !11KH2=U+$!Yq_vv+OUhCNO;a 4b9;FO!66wv`l6mmm)8$ H bz*11779C1%,,2G2GW_``%00$+ \dl1 +%00Zbn0ooo%33Gzdp3qqq)8EY X4IUPm hNN#UW^WcWcefggh pq bNN#OQXQ]Q]_`aab[Y X Xs)J:B"J&H %H +J&3H H  J&H+!H$7H+H)H+J&A I+>I% ?I+J&"I+'I' (I+,J&.I+I) I+ J& J: J&$H++ I"6!IJ&I""J&%I+'I+)I++ J# 6!J J&J# #J&& J7 1 J:Fc<V^8dQhRRRRRRRRR R R R R RR RRR / #)rrrrrrrevent_message_idrtext_already_deliveredr deliver_mediar[inbound_message_idr r")r#s"r$r%rslIII%2I*IERI!%I>BI# I@M I  Ir&c "^RIHp V'gV !W4p V 'dRp \VRR4pV'dVR8wd\VRR4'gVPVPWRR7GRjxL p\VR R4'dRp \ P R V4M,^R IHpV!V4'd\ PR 4R#V 'g2VPW2WWYV 4GRjxL p\VR R4'gR#V'gR#VPV\RW%R7VVR7GRjxL R#L \d!p\ PR T4Rp?LRp?ii;iL}L85i)uDeliver a queued response using the normal text+attachment split. ``session_key`` lets the text send record a delivery-ledger obligation like the normal final send does, keyed on ``inbound_message_id`` (the raw inbound id, distinct from the ``event_message_id`` reply anchor); see ``_send_queued_final_text``. Without a key the send stays unledgered. Returns whether the caller may treat this turn's final as delivered. True: the stream had already delivered it, the reconcile edit landed, the send succeeded, or there was nothing textual to send. False: the send was REFUSED (flood control, dead transport) — the caller must leave the normal completion send as the fallback, or the user gets nothing. A connector DECLINE returns True: that destination is not approved and must not be re-sent.)+_strip_response_attachments_for_direct_sendF message_idN __no_edit___turn_split_deliveryT)r)r rfinalizerzPQueued-lane final reconciled by editing message %s in place (no duplicate send).) declined_sendzQueued-lane reconcile edit DECLINED by the connector's egress guard; not falling back to a send (the destination is not approved).z=Queued-lane reconcile edit failed (%s); falling back to send.r0)rPrr )r)rrr6 edit_messager)r4rgateway.relay.egressr rr3r5_send_queued_final_textrr)rrrrrrrrstream_consumerr[rr text_content _reconciled _sc_msg_id _edit_resr _qe_sents&&&&&&&&&&& r$_deliver_queued_first_response8GatewayNotificationsMixin._deliver_queued_first_responsesz$ L%FxYL$ $_lDI "m3#O5KUSSk*1*>*>$*NNzjn+?+% #9i??*.K"KK r *K,Y77 &%S!" (, 8#"&">">AQ*#,,E#5)U;; %// l6WY`$0   S%,%k %dfijjk, s~AE2!E4D>5/E$E2%E9E E2E20E.1 E2%E27E08E2>E E+ E&!E2&E++E20E2c 0V^8dQhRRRRRRRRR RR R/#) rrrrrrrrrr[rr")r#s"r$r%rjs>,V P$'g,\P'R V4VPR R 7R#VP)WWZP*4p VPR4R JdK\-T ;'g/4p RF/p VPV 4'gK\/W],4W&K1 V P1V \/V4\3R4V!WR7R7GRjxL p\5V4'd6\P7RWg\9V44VPR R 7R#\P'RWg4\/V4\/V4V'd \/V4MR3VPR R 7#L \:d4p\P7RT4Rp?TPR R 7R#Rp?ii;i TPR R 7i;i5i)zANotify the chat that initiated /restart that the gateway is back.r.) _hermes_home_non_conversational_metadataz.restart_notify.jsonN utf-8-sigencodingr7r)r*T missing_okz6Restart notification skipped: no live transport for %szJRestart notification suppressed: %s has gateway_restart_notification=falsedelivered_via_upstream_relayzgateway.startup.restartedr7rz3Restart notification to %s:%s was not delivered: %sz"Sent restart notification to %s:%szRestart notification failed: %s)rscope_id)r2r/rr$r%existsjsonloads read_textr_unlinkr r8_adapters_for_profile_marker_profiler4r5 platformsgateway_restart_notificationr_pending_marker_metadatarrYrrrrrrr3)rr/r$r% notify_pathdata platform_strr)r*r7 transport platform_cfgrrbrrs& r$_send_restart_notification4GatewayNotificationsMixin._send_restart_notifications?J"%;; !!##, 0::k33[3IJD88J/Lhhy)G-IwL   $  /K -H3++t'A'A$BVBVW[B\']_I  UWcd<   $  /; ;;0044X>L' 0Y0Y0Y `bn0   $  //44XN_N_`Hxx674?B/4Exx*-dk*:5%>>#g,*E(F5hR*F F##IK  K &AK .K /5K %L%9?K 8L% K L L.L2L%L  LL""L%c# "VPPP4FYwrVPpV'dVP'gK-\ WPVP 4pVfKSWW43xK[ R#5i)zaYield ``(platform, platform_cfg, home, transport)`` for every home channel with a live transport.N)r8r5items home_channelr)r;r9)rr7r<homer;s& r$_home_channel_transports2GatewayNotificationsMixin._home_channel_transportssg&*kk&;&;&A&A&C "H,,Dt|||0;; VI $9 9'Ds AB4Bc# ""VPPP4F wrRW3xK \VRR4;'g/P4F.wr4VPP4F wrW1V3xK K0 R#5i)a``(profile, platform, platform_cfg)`` for every SERVED profile's configured home channel. ``self.config`` is the launch profile's alone, but one host process multiplexes every profile, so a host-wide notice built from it silently skips the others' channels. The secondary configs are the ones ``_load_secondary_profile_config`` already cached at adapter start; ``profile`` is ``None`` for the launch profile. N_profile_configs)r8r5r@r6)rr7r<r profile_cfgs& r$_served_home_channel_configs6GatewayNotificationsMixin._served_home_channel_configss'+kk&;&;&A&A&C "H. .'D%,T3Et%L%R%RPR$Y$Y$[ G*5*?*?*E*E*G&55+H%\s AB ABc # "VP4F wrr4RWW43xK \VRR4;'g/P4FwrV\VRR4;'g/PV4;'g/pVPP4FGwrVP pV'dVP 'gK-\WWuR7pVfK@WQW#V3xKI K R#5i)u``(profile, platform, platform_cfg, home, transport)`` for every served profile's home channel with a live transport — the launch profile's (``profile`` ``None``) first.NrF_profile_adaptersr)rCr6r@r_r5rAr)r;)rr7r<rBr;rrGr9s& r$_served_home_channel_transports9GatewayNotificationsMixin._served_home_channel_transportss8<7T7T7V 3HD? ?8W%,T3Et%L%R%RPR$Y$Y$[ G&94@FFBKKGTZZXZH*5*?*?*E*E*G&#004<<<4XHf $YFF+H%\s5C)AC);AC)&C)c$V^8dQhRRRRRR/#)rmessager failure_fmtr rr")r#s"r$r%rs$SVehmqr&c |"^RIHpVPWPVPVP R7pVP 'dX\T;'g/4pVP'dVPVR&VP'dVPVR&V!WqR7pVfVP 'd1VPV\VP4WHR7GRjxL p M7VP P\VP4V4GRjxL p \V 4'd7\PWQPVP\!V 44R#R #LLO \"d7p \PYQPTPT 4Rp ? R#Rp ? ii;i5i) z\Best-effort send to one home channel; True on success, failures logged with ``failure_fmt``.r%)rrr-r,NrFT)rr%_thread_metadata_for_targetr)r*ris_relayrYrr-rrrr4rr1rr3) rr7rBr;rPrQr%r send_metadatarr:s &&&&&& r$_send_home_channel_message4GatewayNotificationsMixin._send_home_channel_messagesC< 77,,PTP^P^hqhyhy7zH!!!B/<<<*.,,HY'===+/==HZ(8UM(I,>,>,>(~~hDLL8I7~kk(0055c$,,6GQQF##{NNDLL+V\J]^ lQ   NN; c J slF<AE8E85 E8-E8*E8.E4/7E8&E6'A E80F<4E86E88 F9+F4.F<4F99F<zOptional[asyncio.Lock]_planned_restart_notice_lockcV^8dQhRR/#rr rr")r#s"r$r%rs%^%^D%^r&c "^RIHp^RIHpVPf\ P !4VnVP;_uu_4GRjxL V!4pVP4'gRRR4GRjxL R#\P!VPRR74pVPR.4Uu0uFp\V4kK ppVP4UUU u0uFwrxp V P'gKV PP'gK8V P 'gKL\#WxP$V PPV PP&4kK p ppp Y`P)VR7GRjxL ,pW8:d&VP+RR 7RRR4GRjxL R#VUu.uFp\-V4NK upVR&V!W4RR 7RRR4GRjxL R#ELELuupiuup ppiLLTuupi \.d\0P3R RR 7LQi;iLI +GRjxL 'giR#;i5i) a3Send the planned-restart online notice to every home channel still owed one; clear ``.restart_pending.json`` only once all of them were reached. Runs from the boot pass and again from ``_install_reconnected_adapter``, so a home whose platform was down at boot gets its notice when the platform comes back (#112109). Delivered targets are recorded in the marker so neither a later replay nor the next process (if this one restarts first) notifies a home twice. The lock serializes a boot pass that outlived the restore gate against a concurrent reconnect replay. )"_planned_restart_notification_path)atomic_json_writeNr&r'delivered_targets) skip_targetsTr))indentz,Planned-restart notification remains pendingr)rr]utilsr^rYasyncioLockr.r/r0r1r_r!rHrAr)r6r+r1r*(_send_home_channel_startup_notificationsr2rr3r4r) rr]r^pathr9target deliveredrr7cfgoweds & r$,_replay_pending_planned_restart_notificationFGatewayNotificationsMixin._replay_pending_planned_restart_notifications C+  , , 407 D -444457D;;==544 ^zz$..+."FG9=BUWY9Z[9ZvU6]9Z [ 372S2S2U3V.3''g-0,<,<,D,DgJMIiIig-1A1A1I1I3K[K[KeKeg2U #P#P^g#P#hhh $KK4K0%544&IR,R fT&\ ,R()!$T:)544 \ i5&-S ^MX\] ^+5444sA I%HI%I2 I%=H>I%:H?H H)H H #H 7AH :HH "H7 I%HI% H H!H1 I%<I=I%I% HI%H"IIIII%I" I I" I"  I%r`c V^8dQhRRRR/#)rr`z-Optional[set[tuple[str, str, Optional[str]]]]r z#set[tuple[str, str, Optional[str]]]r")r#s"r$r%r"s))L) ,)r&c "\4pT;'g \4p\R4p\VP44pVUUUU U u0uFfwrgrp \ WgP V P V P4V9gK9\VP V P V PVR7kKh p p pppp VEF+wrgrp V P'g#\PRVP 4K<\ WgP V P V P4pW9gW9dKu\VP V P V PVR7pW9dVPV4KVPWyWR4GRjxL 'gKV PV4VPV4\PRVP V P 4EK. V#uup p pppiLi5i)uNotify EVERY served profile's configured home channels that the gateway is back online. Best-effort, once per home CHAT — several served profiles can share one chat (a single Telegram group for the whole host), and one host process restarting once owes that chat one notice. Accounting stays per profile so the marker's owed set still discharges. ``skip_targets`` lets startup avoid duplicate messages when a more specific restart notification is queued for the same chat. zgateway.startup.onlinerLzWHome-channel startup notification suppressed: %s has gateway_restart_notification=falsez6Home-channel startup notification failed for %s:%s: %sNz/Sent home-channel startup notification to %s:%s)setrrrMr+r1r)r*rr6r4raddrW)rr`rhskippedrPtargetsrr7_cfgrB _transportnotified_chatsr<r;rgchats&$ r$reBGatewayNotificationsMixin._send_home_channel_startup_notifications"s:= ''#%,-t;;=>>E =D94z(..$,,PTP^P^_cjj ` t~~W^ _=D  AH  6G3 1G3 9CG>G<G>AG>cV^8dQhRR/#r[r")r#s"r$r%rMs5#5#d5#r&c aaaaa"\SRR4pV'gR#\SRR4e<SP4SPpV'g\P R4R#^RIHpHp^RIH pH pV!V4pV!4pVR8Xd%V!4pV!4R, p \R WxV R 7oMiVR 8Xd\R VR 7oMT^RI H p V !V4p V Pp V P\ 9d\RWR7p \RV P"V R7o\P%RV4^RIHp SP+4F"wopooV !VVVVV3RlSR7GRjxL K$ R#L 5i)uBroadcast a state.db failure warning to all home channels. When SessionDB init fails at gateway startup, messages may flow but nothing is persisted — /resume, /history, and session_search all silently break. Best-effort: failures are logged, not raised. See #88235. _session_db_init_errorN_session_db_handle_cachezMstate.db recovered before the home-channel warning went out; not broadcasting)get_default_hermes_rootprofile_cli_selector)_default_db_pathclassify_persistence_errorcorruptbackupszgateway.startup.db_corrupt) profile_argdb_path backups_dir fts_indexzgateway.startup.db_fts_corrupt)r)describe_storage_failurezgateway.startup.db_then_restart)actionrzgateway.startup.db_unavailable)causerz:Broadcasting state.db failure warning to home channels: %spresent_notificationc.<SPSSSSR4#)z2state.db warning notification failed for %s:%s: %s)rW)rBrPr7rr;sr$RGatewayNotificationsMixin._send_session_db_warning_notifications..s77dIw8lnr&r,)r6!_open_session_db_for_active_scoperzr4rhermes_constantsr|r} hermes_stater~rrhermes_state_user_copyrrr_SELF_CLEARING_STORAGE_CAUSESglossrgateway.warning_notificationsrrC)rrr|r}r~rrrrrrfailurerr _platform_cfgrBrPr7r;sf @@@@r$&_send_session_db_warning_notifications@GatewayNotificationsMixin._send_session_db_warning_notificationsMsS6=  43T : F  2 2 4//E klRM*51+, I &(G13i?K4+lwxG k !8kRG G.u5G ^^F}}$AA\S4'dR#\P!R W9WSPR R 44R#\#V 4p V P$\&9d5^RIHp V P-V P$4'g \/V 4hMRV3RllpV!R4pVfV R9d\P!RWV 4\1WW!R4V!R4V!R4WR7# \d"p\PRY64Rp?EL^Rp?ii;i \d \/T 4hi;i \d\P!RT 4R#i;i)zResolve the canonical source for a synthetic background-process event. Prefer the persisted session-store origin; the active foreground event causes cross-topic bleed. _parse_session_keyr[r0originNz>Synthetic process-event session-store lookup failed for %s: %srr7rgr)zcSynthetic event source unresolvable: session_key=%r platform=%r chat_type=%r chat_id=%r evt_type=%srrr)platform_registryz9Synthetic process event has invalid platform metadata: %rc V^8dQhRRRR/#)rrbrr rr")r#s"r$r%KGatewayNotificationsMixin._build_process_event_source..__annotate__s = = =  =r&c|<\SPV4;'gR4P4;'gR#r0N)rr_rh)rbrXs&r$_optCGatewayNotificationsMixin._build_process_event_source.._opts/swwu~++,224<< >JJ(77K> = = #   1A A NNHIVaj  )tT_O`OtK/@8  _ q ]_jpp q:!4$]334  NNVXe f sIAK' #K'= L0&L L' L2LLL--L00!MMcV^8dQhRR/#r[r")r#s"r$r%rs'I'ID'Ir&c x"^RIHpHpV!V4pVEFLpVPR4pVe.V\P !48dVP V4KFVPV4;_uu_4GRjxL ^RIH pV!V4'gRRR4GRjxL KVP4R8XdRRR4GRjxL KVPR4R8Xd^RI H pV!W4GRjxL p M>V!V4p V 'gRRR4GRjxL EKVPW4GRjxL p RRR4GRjxL X R JgEK;VP#W4EKO R#LLLLzLZL? \d\P!R 4R p Lai;iLY +GRjxL 'giLp;i5i) uConsume queued watch events and inject them when notifications are enabled. The queue is ALWAYS drained (so watch events don't rot or requeue-spin) but injection is skipped when the OWNING profile's ``display.background_process_notifications`` is ``off`` — one shared queue carries every served profile's events, so the gate is evaluated per event inside its profile scope, never once for the ambient (launch) profile. See #9290. )_drain_gateway_watch_events$_format_gateway_process_notification_watch_next_retry_atNshould_surface_notificationoffrrry)deliver_heartbeatz"Watch notification injection errorF)rrrr_rFrGput_completion_event_scoper|r#_load_background_notifications_modegateway.session_automationr_inject_watch_notificationr3r4 exception_requeue_refused_watch_event) rcompletion_queuerr watch_eventsrX next_retry_atrrrh synth_texts && r$_drain_watch_notifications4GatewayNotificationsMixin._drain_watch_notificationssd b23CD CGG$:;M(]T^^=M-M!$$S)33C888\2377988;;=F 988 776?k1L&7&B BI!Ec!JJ% 988**.*I*I**Z$Z 98&E!112BH7 9!C9%[$*(()MN$) *9888sA6F:8E( 9F:<F F:E*F:$F: F:E,F: 'F3E. 4F F F:E0F:E42E2 3E47 F:FF:F:*F:,F:.F0F:2E44"F FF FF:F7 $F'% F7 0F7 2F:c V^8dQhRRRR/#rrXrYr rr")r#s"r$r%rs""D"T"r&c  4\VPR4;'g^4^,pW!R&VPRR4'd\VPR4;'g^4^,pW1R&V\8dx\P RVPR4;'gRVPR4;'gRVPR 4;'gRVPR R 4V4R #\ V4VR &VPV4R #)aRetry a refused watch event on a bounded backoff, never on every 2 s tick (#140899). Only a refusal proven permanent (``WakeNotAccepted.permanent``: the route has no session, or the payload is invalid) counts toward the cap that drops it. A transient one (a restart's after-turn wait, a parked profile, a full owner FIFO) or one whose owner may still appear (an unowned or foreign-pinned notice) waits it out however long it lasts. _watch_retry_step_refusal_permanentF_watch_injection_attemptszWatch notification for %s chat=%s (type=%s session_id=%s) was refused %d times; dropping the queued event (output remains available via process(action='log'))r7rr)rr session_idunknownNr)r>r_pop"_MAX_COMPLETION_INJECTION_ATTEMPTSr4rrJr)rrXr=refusalss&& r$r6GatewayNotificationsMixin._requeue_refused_watch_events377./44159#'  77' / /377#>?DD1EIH/7+ ,==-GGJ'..3 0B0I0IcGGFO**sCGGL),Lh &7&= "#S!r&cV^8dQhRR/#rrrr")r#s"r$r%r sr&c vVPP4Fwr#VPV8XgKVu# R#)zYLiteral ``p.value == platform_name`` scan over connected adapters (native adapters only).N)r9r@r1)rrras&& r$_adapter_by_platform_value4GatewayNotificationsMixin._adapter_by_platform_value s1MM'')DAww-'*r&c(V^8dQhRRRRRRRR/#)rrrraw_sidrXrYr rr")r#s"r$r%rs*%%s%S%W[%`d%r&c Baaaaa a aa"^RIHo Ho\P!4pSP R4R8XdRpRpVVVVV3RlpMRpRp^R IHo \P!VPSS4GR jxL oS'd:^R IHp \!\"P$SSR 7p T !TP'T 44pTT T TTTT3Rlp\P)VS4T;_uu_4GR jxL V!4GR jxL R R R 4GR jxL R#L \d#p \PTST 4R p ? R #R p ? ii;iLWLJL< +GR jxL 'giR#;i \*d#p \PTST 4R p ? R #R p ? ii;i5i)uNDeliver to a non-push (api_server) session by raw session id. Async-delegation completions are persisted as a durable delivery row — after the parent turn's event.complete the CLIENT owns the next turn on this stateless surface, so never self-post them as a new role=user prompt. Other watch events wake the session via self-post. ) deliver_wakepersist_delegation_deliveryrrrwu`Async delegation completion — persisting delivery row for api_server session %s (no wake turn)z;Async delegation delivery persist failed for session %s: %sc<S!SSSSR7#))rPrrXr")rrXrrrsr$rAGatewayNotificationsMixin._self_post_api_server..s9' _flopr&uIWatch pattern notification — waking api_server session %s via self-postz;Watch notification self-post wake failed for session %s: %srNF_async_profile_runtime_scoper7r)rc Z<S!S\S4SSS!S4'dRR7#RR7#)rr)rPrrr)rV)rrrrXrservedrsr$rr,s6l79TU_9`mtE6Ns6S6SlcYacr&T) gateway.wakerr contextlib nullcontextr_rrrc to_thread_served_api_server_wake_profile LookupErrorr4rrrrr API_SERVER _resolve_profile_home_for_sourcerr3)rrrrrXscoperfaildeliverrrrrrrrs&ffff @@@@r$_self_post_api_server/GatewayNotificationsMixin._self_post_api_servers@ K&&( 776?0 0uDPDppG^DPD P &001U1UWZ\cddE&0C0CW^de4T5Z5Z[a5bcccG  KKg &uuiu!e tWa0 uuu  NN4! , sA F%D=D>DF AF$E/4E 5E/8 EEE E/EE/FD E 'E>FE  F E/EE/E, E E, $E, &E/*F,E// F:FFFFc$V^8dQhRRRRRR/#)rrXrYrrr rr")r#s"r$r%r7s&ii4i#i-ir&c aaaa\SPRR4'gR#^RIHp^RIHo\SRR4;'gRo\ \SPV4RR4;'gR 4P4pV'd4VS8wd-S!SPVS4'dV#\R V: R 24h\VVVV3R lV!SP44R4#) uUThe served (non-primary) profile whose own session store holds *raw_sid*, else ``None`` (the default profile's HTTP self-post). Blocking: reads served ``state.db`` files. A served profile's ``api_server`` turn binds the RAW session id as its session key, so its completion event names no profile: the only ownership proof is the served profile's own store, exactly the rung the Kanban notifier applies. An event whose source DOES name a served profile (structured key / persisted origin) must be owned by that profile or it raises ``LookupError`` — never a wake in the default profile's store. multiplex_profilesFN)_multiplex_profile_homes)session_owned_by_profile_primary_profile_namedefaultrr0z!session is not in served profile z 's own storec3v<"TF.wrVS8wgKS!SPVS4'gK*VxK0 R#5ir^)r8)rar_homeprimaryrrrs& r$rcLGatewayNotificationsMixin._served_api_server_wake_profile..Ks;b-Rkd,DT[[RVX_,`T-Rs 99 9) r6r8rrrrrrrhrnext)rrXrrhintedrrsf&f @@r$r9GatewayNotificationsMixin._served_api_server_wake_profile7st{{$8%@@89$ 7>KK)WT==cBItTZZXZ[aac f'' VWEE  A&<XY Yb-Edkk-Rbcgi ir&cV^8dQhRR/#rr")r#s"r$r%rNsXXXr&c a^RIHpVeYVPV4pVe V^,#\VRR4RJd*VPP \ P4#VP\VRR44pV!\ S4VPV4pVe VP#\V3RlVP44R4# \dRpLCi;i)aAdapter for a synthetic-event platform: alias-aware transport resolver first (one Platform.RELAY adapter fronts N logical platforms; native wins), literal ``p.value`` scan as fallback for minimal runner stubs / exotic platform strings when the resolver can't run.r.Nr+FTrc3R<"TFwrVPS8XgKVxK R#5ir^)r1)rarrrs& r$rcGGatewayNotificationsMixin._resolve_injection_adapter..bs"P#341qww-7OQQ#3s' ')r2r/_transport_ownerr6r9r_r RELAYr3r8r3rrr@)rrrr/ownerr9rts&f& r$_resolve_injection_adapter4GatewayNotificationsMixin._resolve_injection_adapterNs @  ))&1E Qxv=uEM}}((88--gfi.NO 3H]4KT[[ZbcJ  !%% %P8>>#3PRVWW  J sC C"!C"raise_not_acceptedc(V^8dQhRRRRRRRR/#) rrrrXrYrrr rr")r#s"r$r%rds2fff$(fAEf fr&c  "^RIHpHpHp\P !VP V4GRjxL pV'g\V4pV'dnVPP\P4p V e)V!V 4'gVPWW4GRjxL #\PRV4R#\PRVPRR44R#\!VP"R4'dVP"P$M\'VP"4p VP)W4p V 'g\V \PP$8Xd=\+VR R4'd*VPP\P4p V 'gR#V!V 4'gt\'VPR 4;'gR 4P-4;'g \'VP.;'gR 4pVPWW4GRjxL #\1V4p\3W'4p \'VPR 4;'gR 4P-4;'gRp V 'dWR &\+VR R4'd^RIHp V !VRR7p\9V\:P<VRV R7p\P?RWP.VP@4\+V RR4p\CV4'd V!V4^RI"H#pV!V4pVe#^RI$H%p^RI&H'pV!VVWV4GRjxL R#V!W4GRjxL R#EL2ELELBL! Td$pT!\'T4TPPR7ThRp?ii;iL> Tdp^RIH)pTPUT\'T4T'*R7GRjxL pT;'gTPPT9Tn+T'dT'gRp?R#T'gTPVTR&\PRYP.T4T'dhRp?R#Rp?i\Xd"p\P[RT4Rp?R#Rp?ii;i5i)aInject a watch/completion notification as a synthetic message event. Routing comes from the queued event, never the active foreground message. Returns ``True`` on adapter acceptance, ``False`` on retryable adapter failure, ``None`` with no gateway route or a refused notice pinned to a permanently-gone session (``_watch_pin_gone``). Not transactional: a crash after acceptance can replay (at-least-once). )WakeNotAcceptedadapter_supports_pushadmit_internal_eventNz[Deferring watch notification for raw session %s: no api_server adapter to self-post throughFzCDropping watch notification with no routing metadata for process %srrr1rrer0r original_trigger_message_id)replace_source)r T)rP message_typerinternalruAWatch pattern notification — injecting for %s chat=%s thread=%sprime_routing_cache)active_authority)admit_process_notice)RuntimeStoreError)reason)PERMANENT_REFUSAL_REASONS)logrz2Watch notification not admitted for %s chat=%s: %sz&Watch notification injection error: %s).rrrrrcrrrlr9r_r rrr4r5rrr7r1rr r6rhr)rVrgateway.session_identityrrrTEXTrr*callablegateway.session_authoritiesrrrhermes_state_runtimerrr_watch_pin_gone permanentr3r)rrrXrrrrrrrrrtrigger_message_idr synth_event_primer authorityrrr:rpin_goners&&&$ r$r4GatewayNotificationsMixin._inject_watch_notificationds ^](()I)I3OO3C8G--++H,?,?@&/DW/M/M!%!;!;GQX!^^^ q NNU i0 18'1R1R--X[\b\k\kXl 11-H=H,?,?,E,EE'RXZceiJjJjmm''(;(;.>vX\!K KKS~~v/?/?  W&;TBF{# D(.I$KBP.tYVYZZZ +7@@@QP_.WJ[(P)#c(3::FCOPA  ?!11#s3xI[E[1\\\H$OO 6O(OCM 2%,/MM() NNO(..# ?"  LLA1 E s /RM# RA R R!M&"DR)R9RR2R R'M)(R-AN< NB4N<M. M, M.R NNN!R&R)R,M..N5NNNQ?$+QO QQ;QR Q9Q R Q?Q?Q:4R:Q??Rc V^8dQhRRRR/#)rrXrYr z!Optional[tuple[str, str, object]]r")r#s"r$r%rs44Ur&c \VPR4;'gR4pVR8Xd\VPR4;'gR4pV'gR#VPR4'dEVPR4;'g/.^,;'g/PRR4pWR V 23#WR3#VR9d=VPR 4'd&V\VR ,4\VR ,43#VR 8XdF\VPR 4;'gR4pVPR 4pV'd VeWV3#R#)a?Return a producer-stable identity when one is available. Delegation UUIDs identify one producer completion. Process session IDs include the persisted spawn epoch so a reused ID is a distinct incarnation; legacy events without ``started_at`` are delivered undeduplicated rather than risk suppressing a real completion. rrr0rwrNtask_failure_noticeresults task_indexz task_failure:event_idrrs started_at>ry watch_matchwatch_disabledrr_)rXr~ producer_idtask_idxr3s& r$_completion_delivery_identity7GatewayNotificationsMixin._completion_delivery_identitys+swwv,,"- ) )cggo6<<"=Kww,--!WWY/77B4;AArFF|UWX xj/IJJ2. . E E#''R\J]J]c#l"34c#j/6JK K | #cggl399r:K.Jz5 z::r&cV^8dQhRR/#r[r")r#s"r$r%rsFFFr&c VF-pVPPV4RVPV&K/ \VP4VP8dVPP RR7KBR#)zeMove identities inflight -> delivered and trim retention. Caller holds ``_completion_delivery_lock``.NF)last)_completion_deliveries_inflightdiscard _completion_deliveries_deliveredlen_completion_delivery_retentionpopitem)r identitiesidentitys&& r$"_mark_completions_delivered_lockedBD 1 1( ;#$7784;^;^^  1 1 9 9u 9 E_r&claimc V^8dQhRRRR/#)rrHrr r")r#s"r$r%rs  D T r&c VP;_uu_4WP9;'gWP9pV'd$V'gVPPV4VuuRRR4# +'giR#;i)zTrue when ``identity`` is inflight or already delivered this gateway lifecycle. With ``claim`` an unseen identity is atomically marked inflight (same lock hold). N)_completion_delivery_lockr>r@rp)rrErHseens&&$ r$_completion_identity_seen3GatewayNotificationsMixin._completion_identity_seensf  + + +@@@EEDDD T4488B, + + +s,A1A1 A11 B c$V^8dQhRRRRRR/#)rrrr[r r")r#s"r$r%rs(ZZ3ZUXZbeZr&c N"VPW4GRjxL ^,#L 5i)usClassify an async-completion target before adapter acceptance: ``"deliver"`` (spawning session live or compression-rotated with a live continuation; the resolver still retargets), ``"terminal"`` (parent gone for good — unknown / user boundary like /new; drop the durable row rather than falsely ack), ``"retry"`` (DB unavailable / rotation mid-flight; defer the claim).N)_classify_completion_owner)rrr[s&&&r$_classify_completion_target5GatewayNotificationsMixin._classify_completion_targets% 556GUUWXYYUs %# %c$V^8dQhRRRRRR/#)rrrr[r ztuple[str, str, str]r")r#s"r$r%rs(%R%R#%RTW%Rau%Rr&c @"^RIHp\VRR4pVfR #RpV'd_\\V4P p\ P!VP4GRjxL VPPV4pTPY'd VPMR4GRjxL wrqpTp VP!WEW4GRjxL p V 'dRT rMtVR8XdnVejVPR 4'dS\#VPR 4;'gR4p V R 8wd W9dR MRpMVP%WEV4GRjxL wryVR8wdVRR3#YqT ;'gT3#EL \d\PRTRR7R u#i;iLLLR5i)z``_classify_completion_target``'s verdict and, on ``"deliver"``, the owning session it proved (a delegate child's pin resolved through ``model_config._delegate_from``) and the session delivery reaches (the owner, or its compression tip).)_USER_BOUNDARY_END_REASONS _session_dbNr0z%Completion route lookup failed for %sTrrended_at end_reason compressionterminal)retryr0r0)rrVr6rrrrcrrrr_r3r4r5_lookup_completion_ownerr_closed_local_targetr#_resolve_compression_lineage_target) rrr[rV session_dbrrverdictparenttarget_session_id closed_tiprYs &&& r$rQ4GatewayNotificationsMixin._classify_completion_owners ;T=$7  " "  '.23o.K.K '' (D(DEEE%..22;?483P3P 5u//b4 . *F.44ZHYbb )2J&  !f&8VZZ =S=SVZZ 5;;F.F F F&F*E--%FFFFFFc(V^8dQhRRRRRRRR/#)rkindrrrr rr")r#s"r$r%r/s.jjCjjsjtjr&c \V,wr4^RIHp\WS4!W4R# \dB\ P TR8Xd\PM\PTRR7R#i;i)z?Best-effort ``drop``/``release`` of a durable completion claim.NrNTr) _DURABLE_CLAIM_OPStools.async_delegationrwr6r3r4rrrr)rgrrfn_namefail_msg_ads&&& r$_settle_durable_claim/GatewayNotificationsMixin._settle_durable_claim.s]/t4 j 0 C !- : j JJ$**rKzBackground process %s completion targets permanently-gone session %s (user boundary such as /new); dropping notification (output remains available via process(action='log')).rz r\T)rr_rtrrrrrjrxid __import__uuid4hexrr3r4rrhrQrrrnrM)rrXrHr~rxr:rras&& r$_preflight_completion_delivery8GatewayNotificationsMixin._preflight_completion_deliveryWs%%'776? ) )8W8WX[8\2\2\05u -EM5-L ) )#'':O2P2P"%cggo&>&D&D""EE """ !P'/4z:f;M;S;S;U;Y;Y:Z%[EN4U5H5H%..YY(- $ Z # %L (; < B BCIIK L JNIhIh s377=#9#?#?R@JBDB@')@ j --_''55:7H >>>..vu7J7JENN[iGGL)88[:K  "EM  =BE4 :EM5-u{ g3]!!NN#TV[ViVikno8=u5EM5#5 L!DBs=K I9 K  .K 9K K 5A(I<(K K #*K K KAK K 9AK  1K < K1J>8K9K >KK cV^8dQhRR/#rr")r#s"r$r%rs::4:r&c ^RIHp^RIHpVP V4pVe\ VRR4'gP\ V4pV'd0\ \ VRR4RR4'dVPW4#^RIH pV!4#VPV4pV!4\V48Xd\P!4#V!V4#) uvProfile runtime scope of the session a completion event targets (a no-op context when the event is the default profile's or the scope is already installed). The pre-flight (``_classify_completion_target`` → ``_session_db``) and every durable-ledger op (``tools.async_delegation`` → ``get_hermes_home()/state.db``) resolve from the ambient scope. The supervised ``_async_delegation_watcher`` and startup-recovered process watchers run under the ROOT scope, so a secondary profile's completion was looked up in the DEFAULT profile's state.db — classified ``terminal`` and dropped, its ledger row stranded ``pending`` forever.r)get_hermes_home_overrideNrr8rF)async_launch_profile_scope_if_multiplexed)rrrrrr6rl_served_api_server_event_scope!tui_gateway.launch_profile_policyrrrrr)rrXrrrrr profile_homes&& r$r1GatewayNotificationsMixin._completion_event_scopes ==11#6 >D!A!A3C8G7744#@BVX]^^::3HH d<> >< Csibling_claimsc$V^8dQhRRRRRR/#rrrrXrYr rr")r#s"r$r%rs) @ @ @$( @  @r&c "VPV4;_uu_4GRjxL VPWVR7GRjxL uuRRR4GRjxL #L1LL +GRjxL 'giR#;i5i)zAcknowledge one admitted batch, refund refusals, or release failed deliveries. True means adapter admission, not model execution; None means deduplicated or terminal. False remains retryable. Claims are settled together for every sibling. Nr)r'_deliver_completion_notification_scoped)rrrXrs&&&$r$ _deliver_completion_notification:GatewayNotificationsMixin._deliver_completion_notificationsZ//444EEF@@544@5444sYA5AA5AAA A5 A A5AA5A2 A! A2 *A2 , A5c$V^8dQhRRRRRR/#rr")r#s"r$r%rs)8k8k8k$(8k 8kr&c ("^RIHp^RIHpV!V4'gR#VP V4pVP 4pR;p;rVP V4GRjxL pVP'EgVPV 'dAV'g9VP;_uu_4VPPV4RRR4V'dRMV 'gVP'dRMRp VP'd'VPWPVP4VF(wrV 'gKVPWR,V 4K* V'd0V'd'TP!VUUu.uFwrVNK upp4###\#VR R4Ee&^R IHpV!W4EeR pV 'dAV'g9VP;_uu_4VPPV4RRR4V'dRMV 'gVP'dRMRp VP'd'VPWPVP4VF(wrV 'gKVPWR,V 4K* V'd2V'd(TP!VUUu.uFwrVNK upp4R #R #R #VEe/VP)VR R 7'EdV 'dAV'g9VP;_uu_4VPPV4RRR4V'dRMV 'gVP'dRMRp VP'd'VPWPVP4VF(wrV 'gKVPWR,V 4K* V'd2V'd(TP!VUUu.uFwrVNK upp4R#R#R#R p VP*'d/VCR VP*RVP,/CpVP'dVP.M.pTVU U u.uFwrV 'gKV R,NK up p , p/VCRV/CpVP/WR R7GRjxL pVR JEdTV 'dAV'g9VP;_uu_4VPPV4RRR4V'dRMV 'gVP'dRMRp VP'd'VPWPVP4VF(wrV 'gKVPWR,V 4K* V'd0V'd'TP!VUUu.uFwrVNK upp4###R pVe0VP;_uu_4VP1V34RRR4V 'dAV'g9VP;_uu_4VPPV4RRR4V'dRMV 'gVP'dRMRp VP'd'VPWPVP4VF(wrV 'gKVPWR,V 4K* V'd2V'd(TP!VUUu.uFwrVNK upp4R #R #R #EL +'giELA;iuuppi +'giEL);iuuppi +'giEL;iuuppiuup p iEL +'giELx;iuuppi +'giEL;i +'giELb;iuuppi TEdGpTP2'*p Rp?T 'dUT'gMTP;_uu_4TPPT4RRR4M +'giM;iT'dRMT 'gTP'dRMRp TP'd'TPYPTP4TF(wrT 'gKTPYR,T 4K* T'd9T'd/TP!TUUu.uFwrTNK Muuppiupp4R#R#R#Rp?ii;i T 'dUT'gMTP;_uu_4TPPT4RRR4M +'giM;iT'dRMT 'gTP'dRMRp TP'd'TPYPTP4TF(wrT 'gKTPYR,T 4K* T'd7T'd.TP!TUUu.uFwrTNK Muuppiupp4iii;i5i))rrNFrNrMrLrsession_authoritycompletion_admissionT)rHrrr)r)rrr|rr9rr~rrrKr>r?rMrrnr%_record_coalesced_completion_siblingsr6rrrMrrrrFr&)rrrXrrrrErHacceptedidentity_claimedrefused operationsiblingrr _claim_idrrinjection_resultr:s&&&$ r$rAGatewayNotificationsMixin._deliver_completion_notification_scopeds 1T*3//55c:%%'0555#. k==cBBE===))B 33388@@J4&. w%+++G[dI~~~**96I6I5>>Z%3!8..y/:RT\]&4N::Zh;iZhFVeEZh;ij+xSt0$7CK'2>#H8 33388@@J4&. w%+++G[dI~~~**96I6I5>>Z%3!8..y/:RT\]&4N::Zh;iZhFVeEZh;ij+xI#11($1GG2 33388@@J4&. w%+++G[dI~~~**96I6I5>>Z%3!8..y/:RT\]&4N::Zh;iZhFVeEZh;ij+xC$( %%%EE153I3I*E,C,CE7>Z%3!8..y/:RT\]&4N::Zh;iZhFVeEZh;ij+x+H#333;;XKH4 33388@@J4&. w%+++G[dI~~~**96I6I5>>Z%3!8..y/:RT\]&4N::Zh;iZhFVeEZh;ij+xYCH433>Z%3!8..y/:RT\]&4N::Zh;iZhFVeEZh;ij+x!  33388@@J4333&. w%+++G[dI~~~**96I6I5>>Z%3!8..y/:RT\]&4N::Zh;iZhFVeEZh;ij+xsAh^[2^2 ^=h h![5=h hh)h?2h6$hh#h3 \ h #^/h?h\/h? h hh12h($h hh% \# 2h^ h0h\) h0 h:h h"2h$h>hh \= #h1^/^5^ ] ]((^]  ^h-h] h- h7h h2h$h;hh ] h+^]&^!h1h]:!h1 h;h h#2h$h?hh ^ $h2^5 \ h \ h) \: 4h^ ] h& ]7 1 ^: ^ hc"c-c%1hh_:1 h: ` h hh1h2h>$h#h+h; c hc""c%%h6h d/ & h/ d? :h hh&h<2h3$hh h0 g>=hhc$V^8dQhRRRRRR/#)rrXrYfieldstuple[str, ...]r r")r#s"r$r%rs&DDdDODDr&c ha\;QJd.V3RlV4FNK 5#!V3RlV44#)c3l<"TF)p\SPV4;'gR4xK+ R#5irr6r`s& r$rc=GatewayNotificationsMixin._event_route_key..s)CF5S--2..Fs!44)r!)rXrsf&r$_event_route_key*GatewayNotificationsMixin._event_route_keys%uCFCuCuCFCCCr&c V^8dQhRRRR/#)rentriesz&list[tuple[str, dict, asyncio.Future]]r rr")r#s"r$r%r s  7] be r&c  ^RIHpR\V4 R2R.pVR,pVFwrEp\VP R4;'gR4pVP R4p\VP R 4;'gR 4p T!\VP R 4;'gR 44P 4p \V 4R 8d RV RR 2p VP RV RV RV 24V 'gKVP V 4K \V4\V4, p V 'dVP RV R24VP R4RPV4#)zDBuild one bounded synthetic event from several redacted completions.#_redact_gateway_user_facing_secrets [IMPORTANT: z1 background processes completed for this session.zcTreat these results as one completion batch and send at most one consolidated user-facing response.:N Nrr exit_codecompletion_reasonexitedoutputr0i u[… truncated …] Nz - z : exit_code=z , reason=u - … and zV more completion(s); inspect them with the process tool if they affect the conclusion.zHIf a result does not change the current conclusion, absorb it silently.] i)rrrArr_rhappendjoin) rrlinesshown_textrX_futurerrrromitteds & r$%_format_coalesced_process_completions?GatewayNotificationsMixin._format_coalesced_process_completionssR D3w<.(Y Z 1   #( ESWW\2??i@J ,I!45AABF9SWWX=N=T=TRT9UV\\^F6{S 0@ LL4 |< {)F8T Uv V$$)g,U+  LLwi(BB   _`yyr&c V^8dQhRRRR/#)revents list[dict]r rr")r#s"r$r%r's@@J@4@r&c \VPV4Uu.uF q"fKVNK ppVP;_uu_4VPV4RRR4R#uupi +'giR#;i)zCExtend a successful primary delivery claim to its batched siblings.N)mapr9rKrF)rrirDs&& r$r?GatewayNotificationsMixin._record_coalesced_completion_siblings'sY!$T%G%G!Pb!PAaa!P b  + + +  3 3J ?, +c + + +sAAA  A1 c V^8dQhRRRR/#)rkeyrr rr")r#s"r$r%r-s4I4I4IT4Ir&c n"\P!4p.pRp\P!VP4GRjxL VPP V.4pVP PV4VJdVP P VR4V'gRVPW44VP PV4VJdVP P VR4R#R#\VRR4e^RI H pH pVUu.uFqu!W^,4eKVNK ppV'gTRpVPW44VP PV4VJdVP P VR4R#R#MTp\V4^8XdV^,^,MVPV4p ^RIHp T !VU U U u.uFwrqNK up p p 4pRpVFjwrp \#WR7p\VRR4e+\#TVU U U u.uFwrp X!W 4NK up p p R7pVP%W4GRjxL pVfKjM VRJd8\V4^8d(TP'VU U U u.uFwrqNK up p p 4TPY44TP PT4TJdTP P TR4R#R#ELuupiuup p p iuup p p iLuup p p i \P(d)RpT'gTPP T.4ph\*d\,P/R 4RpLi;i TPY44TP PT4TJdTP P TR4ii;i5i) zBDeliver one short-window completion batch and resolve its waiters.FNr)rproducer_identityT)rq)rvrz,Coalesced process completion delivery failed)rc current_tasksleep%_completion_notification_batch_window _completion_notification_batchesr$_completion_notification_batch_tasksr__settle_batch_waitersr6rrrrArr|rqrYrrCancelledErrorr3r4r)rrrrrhrritementries_to_deliverrrqrrXrru candidate_evts&& r$_flush_process_completion_batch9GatewayNotificationsMixin._flush_process_completion_batch-sz++- :<$) / I-- J JK K K;;??RHG88<%nwtBVW[bc]dBeddw"%n) $I>  & &w :88<.scr&rcR#)Fr"r"r&r$rrs%r&_background_tasksFrre)rr|rrYrorsetattrrr_COMPLETION_BATCH_KEY_FIELDSrcget_running_loop create_futurer setdefaultrr create_taskr_retain_background_task_track_task_inr) rrrXrattrrrrrs &&& r$(_enqueue_process_completion_notificationBGatewayNotificationsMixin._enqueue_process_completion_notification}s//444 X.s3354444 0 69_ae8f 93 ? 4k B 8- HK^`cJd  MD 4&&GI.   9 9 9## _444_6I_K^_ ))+99; --88bAHH*[aIbc ?? ?&&t'K'KC'PQD=A 5 5c :  ( ( .    O OQU V|9544448stGF0GF9 GF3GF6=G&GC*G+G,G3G6G9G ?G G G Gc V^8dQhRRRR/#rr")r#s"r$r%rs33D3T3r&c d^RIHpVPR4'dR#T!VPRR4;'gR4pV'gR#VPRR4VR&VPRR4VR&VPRR4VR&VPR4'dVR,VR&R#R#) zFill platform/chat_id/thread_id/chat_type on an async-delegation event. Such events only carry ``session_key`` (the daemon worker lacks per-message routing metadata). Best-effort: a CLI-origin event (empty session_key) is left as-is and won't route. rr7Nr[r0rgr)r*)rrr_)rrXrparseds&& r$ _enrich_async_delegation_routing:GatewayNotificationsMixin._enrich_async_delegation_routings 3 77:   #CGGM2$>$D$D"E  **Z4J!::k26KIr2I ::k " "%k2C  #r&c V^8dQhRRRR/#rgrouprr rr")r#s"r$r%rsLL:L.Lr&c "VPV^,4;_uu_4GRjxL VPV4GRjxL uuRRR4GRjxL #L/LL +GRjxL 'giR#;i5i)a`Deliver a same-session batch of async completions as ONE turn: the primary carries the consolidated text of every sibling THIS runner claimed (siblings owned elsewhere are excluded; their claims are acked only after adapter acceptance). True after acceptance, False to requeue the group, None when nothing is deliverable here (retry siblings requeued).N)r&_deliver_async_delegation_group_scoped)rrs&&r$_deliver_async_delegation_group9GatewayNotificationsMixin._deliver_async_delegation_groupsL //a999DDUKK:99K:999s\%A:AA:AAA A:AA:AA:A7 #A&$ A7 /A7 1 A:c V^8dQhRRRR/#rr")r#s"r$r%rsHH*HQ_Hr&c "^RIHp^RIHpV'doV^,P R4'dQ.pVF=pV!V4pV'gKTP VP We4GRjxL 4K? RV9dR#R#.pRpVEF%pV!V4p V 'gK\VRR4e8^RIH p V !W4e(VP W4GRjxL RJ;'gTpK\\VP R 4;'gR 4p V 'd]TPT \VP R 4;'gR 44GRjxL R 8XdVP W4GRjxL KVPV4p V eVPV 4'dEKVP WY34EK( V'g V'dR#R#\V4^8Xd%V^,wrYVP W4GRjxL #VF'wr]VPV4GRjxL 'dK&R# ^R IHpV^,wppV.p.pVR,FDwrYV!VR\%V4 24pVfK VP VV34VP V 4KF V'gVP VV4GRjxL #R\V4 R2pRP'V.VO4p\VRR4e5^RIHp\+TV.RV4OUu.uF pV!VV4NK upR7pVP VVVR7GRjxL pVf(VF!wppVP,P/V4K# V#ELELELELELwELZLuupiLJ5i)r)rprocess_registryreNFTrrrr0r[r[)claim_event_deliveryrzgateway-batch:rz background subagent delegations completed for this session. Treat these results as one completion batch and send at most one consolidated user-facing response. If a result does not change the current conclusion, absorb it silently.]rR)rc3*"TF wrVxK R#5ir^r")rarr s& r$rcSGatewayNotificationsMixin._deliver_async_delegation_group_scoped..sKcZbRVRSAZbsrr)rrtools.process_registryr r_rrr6rrrrRr9rMrArtrjrrzrrrYrr)rrr_proutcomesrXrP deliverable acknowledgedrrrbrErr primary_evt primary_textblockssiblingsrheader consolidatedrrrhrs&& r$r@GatewayNotificationsMixin._deliver_async_delegation_group_scopedsrDB U1X\\"566H;C@4OO$*O*OPT*Z$Z["X-5 74 7.0  C=cBJt0$7CK'2>)-)N)Nz)_#_cg#g#w#wkwL!45;;H#(F(Fx(P(P   0 1!"'4 1T 1 { q )!nOC>>zOO O&JC88====& @$/N! \+-*2OC+C>"T(1LMH OOS(O , MM* % />>|[YY Y3v;-(a a  {{F#4V#45 4,d 3 ? D{=HZDf s2M>M>M>-M# .A&M>M& M>"!M>M>(M><M> M) M>(M,)1M>!M>=M>3M>8M/9M>M2M>%A4M>M>/M50AM>M7 M>1M<22M>&M>)M>,M>/M>2M>5M>7M>cV^8dQhRR/#r[r")r#s"r$r%rs00d0r&c Raa^RIHo^RIHoVP VVV3RlR4R#)zRe-queue undelivered async completions from every SECONDARY profile's ledger. The process registry's ``restore_completions()`` covers only the launch profile's ``state.db``; a secondary's rows would otherwise never be replayed after a restart.)restore_undelivered_completionsr c(<S!SP4#r^r)rrsr$rQGatewayNotificationsMixin._restore_secondary_completion_ledgers.. s;Z[^[o[o;pr&RestoredN)rjrrr _each_secondary_ledger)r profile_homesrrs&&@@r$%_restore_secondary_completion_ledgers?GatewayNotificationsMixin._restore_secondary_completion_ledgerss" KB ##M3p$. 0r&cV^8dQhRR/#r[r")r#s"r$r%r s ; ;D ;r&c baa^RIHo^RIHoVV3Rlp\ \ P R4;_uu_4V!4;p'd\PRV4RRR4TP\VRR4;'g/P4VR4R# +'giLH;i) zOffer completions whose owner process died while this gateway runs (#97202): the launch ledger in the launch scope, each served secondary under its own. Startup replay only covers owners that were already gone when the gateway started.)sweep_orphaned_completionsr c(<S!SP4#r^r!)rr*sr$rNGatewayNotificationsMixin._sweep_orphaned_completion_ledgers..s233G3GHr&z*Orphaned async completion sweep failed: %sz*Re-offered %d orphaned async completion(s)N_served_profile_homeszRe-offered orphaned) rjr*rr rrrr4rr$r6r@)rsweepcountrr*s& @@r$"_sweep_orphaned_completion_ledgers*7 &L& +D,>CCDED u RTXamn+8DC RT`kop s.BA5B5 B BB#B/.B/c V^8dQhRRRR/#)rintervalr?r rr")r#s"r$r%r*s5*5*5*5*r&c "\P!^4GRjxL ^RIHp^RIHpRpVP 'Ed\\PR4;_uu_4Ve"\P!4V, V8d>\P!4p\P!VP4GRjxL VPVP4GRjxL .p.pVPP!4'gGVPP#4pTP'R4R8XdTMTP)T4KfVFpVPP+V4K /pVFNpVP-V4VP/VP1WpP24.4P)V4KP VP54Fp \6;QJdRV 4F 'gK RM R M !RV 44'd'V FpVPP+V4K KcVP9V 4GRjxL p V R Jd8VP;V 4V FpVPP+V4K KK RRR4\P!V4GRjxL EKR#ELELEL \$dEKi;iL \$dGp T FpTPP+T4K \<P?R T 4Rp ? EKSRp ? ii;i +'giL;iL5i) zDrain async completions and pattern notifications even while sessions are idle. Background subagents and process pattern events have no per-process notification consumer; both must progress without a later foreground turn. N)ORPHAN_SWEEP_INTERVAL_Sr z"Async delegation watcher error: %srrrwc3p"TF,qPR^4\P!48xK. R#5i)rN)r_rFrG)rarXs& r$rcFGatewayNotificationsMixin._async_delegation_watcher..Qs)b\aUX77#91=@PP\as46TFz$Async delegation injection error: %s) rcrrjr<rr _runningrrrrFrGrr0rrempty get_nowaitr3r_rrrrr_ASYNC_GROUP_KEY_FIELDSrrkr_back_off_refused_completionsr4r) rr:r<rlast_orphan_sweeprequeue async_eventsrXgroupsrrhrs && r$_async_delegation_watcher3GatewayNotificationsMixin._async_delegation_watcher*s mmABB mmm 0TUU$,0@CT0TXo0o(,(8%!++D,S,STTT55c6J6JKKK! ..4466!22==?&)WWV_8J%J\PW__`cd"C((,,S1#=?'C99#>%%d&;&;CA]A]&^`bcjjkno($]]_Esb\absssb\abbb#(C0044S9$)  P*.*N*Nu*U$U $- >>uE', # 4 4 8 8 =(-.-7VT--) ) )W UK%(%V %P#(C0044S9$) %KQOOPMVUT *sMK$M"M$AL9K "L9%K &'L9K)CL9L9&L9K%K# ?K%L9!M=M > M L9 L9 K L9K  L9#K%% L6 0:L1 *L91L6 6L99 M  Mc V^8dQhRRRR/#)rrrr rr")r#s"r$r%rbsBBZBDBr&c VF@p\VPR4;'g^4^,pW!R&\V4VR&KB R#)aSpace out an undelivered async group's retries instead of re-offering it every 2 s pass. The backoff only paces; the durable ledger decides when a row gives up (a permanent refusal spends a delivery attempt there, so the count survives restarts) (#141153).rrN)r>r_rJ)rrXr=s& r$rC7GatewayNotificationsMixin._back_off_refused_completionsasH Csww2388q9A=D'+# $*;D*AC& 'r&c V^8dQhRRRR/#)rlimitr>r rr")r#s"r$r%rlsccr&c  <^RIHp^RIHp^RIHpVP 'dV!VP V)R4MRpV'dX^RIHp\VRR4;'gRpT!YWVP\VRR4;'gRR 7pV!WW4pV!V4pV#) zZLast ``limit`` chars of process output through the secret redactors (unconditional floor).r strip_ansitransform_process_outputNr0redact_terminal_outputcommandtask_idrV returncoderW) rrtools.ansi_striprQrrS output_buffer agent.redactrUr6r)sessionrNrrQrS new_outputrU_commands&& r$_redacted_output_tail/GatewayNotificationsMixin._redacted_output_tailks D/CCJCXCXCXZ 5 5ufg >?^`  ;w 26<<"H1*[b[l[l:A'9VX:Y:_:_]_aJ/ EJ=ZHJr&c$V^8dQhRRRRRR/#)rrrwatcherrYr rr")r#s"r$r%r}s'QQ#QQQUQr&c ."\VPR4;'gR4P4pV'gR#\P!VP V4GRjxL pVP W4pT\VRR4;'g/9#L/5i)zWhether the session that launched *watcher*'s process is still inside a turn on its adapter (``_active_sessions`` is the base adapter's busy guard).r[r0FN_active_sessions)rr_rhrcrrr r6)rrrcr[rrs&&& r$_launching_turn_active0GatewayNotificationsMixin._launching_turn_active}s'++m4::;AAC (()I)I7SS11-Hww0BDIOORPPTs:B&B#B$)BBc(V^8dQhRRRRRRRR/#)rrr message_textrcrYr rr")r#s"r$r%rs+   `c nr w{ r&c "^RIHp\P!VPV4GRjxL pVP W4pV'dhV'd^\ \PR4;_uu_4V'dRV/MRp VPW$V!WR7R7GRjxL RRR4R#R#R#LL +'giR#;i5i)rrSNzWatcher delivery error: %sr*r,r) rr%rcrrr rrERRORr) rrr)r*rircr%rr send_metas &&&&&& r$_send_watcher_message/GatewayNotificationsMixin._send_watcher_messages<(()I)I7SS11-H w 0LMM8A[)4t ll4PQZ4s#NM7T NMMs?+C B4$C "C 5,B8!B6"B8&C 6B88 C  C c$V^8dQhRRRRRR/#)rrcrYrrr r")r#s"r$r%rs"( ( ( C( TX( r&c ^RIHp^RIHp^RIHp^RIHp\VRR4;'gRpVP'dV!VP4MRpV'd+T!YVP\VRR4;'gRR7MTpV!W4pR p \V4V 8d=W)R p V PR 4p V R8wd W^,R MT p R \V 4 R V 2p MTp RRRV/\U u/uFqVPV R4bK up CR\VRR4;'gRR\VRR4;'gRR\VPR4;'gR4P!4;'gR R\VRR 4RV!V4RVPR\VRR4R\VRR4RV!V 4RVPR4;'g\VRR4;'gR/ C#uup i)zEBuild the synthetic ``completion`` event for an agent-notify watcher.rrTrPrRrVr0rWrXiNru'[… output truncated — showing last z chars] rrrsr owner_task_idr r3rrrtermination_sourcerr)rrr\rUrZrQrrSr6r[rrAfind_WATCHER_ROUTE_FIELDSr_rrh)rcr]rrrUrQrSr__raw_LIMIT_tail_nl_outks&&& r$_build_process_completion_event9GatewayNotificationsMixin._build_process_completion_events D7/C7Ir288b4;4I4I4Iz'//0rZ^(7K\K\07B0O0U0USUWdh %d5 t9v NE**T"C'*byE'(OeEDDFNN$ ''<> :8D ** 2Ex!P ''3G"L 9$?  /0ccGGEXZ\4]ccac  Es/G-c$V^8dQhRRRRRR/#)rrr notify_moder r")r#s"r$r%rs( @ @ @SV @[^ @r&c ^RIHpHpVPVR4p\ VRR4p\ V\ \34'd'\R\P!4V, 4MRpT!\ VRR4;'gR4p VR8XdV!WVPVVR 7#V!WVPRVR 7p VP4'd\R WP4R 7#T #) uHuman-facing completion message. Every mode shares the one-line status header; the raw-output modes (all/result/error) append the bounded output tail under it instead of the old bracketed ``[Background process proc_… finished~ …]`` debug wrapper (#54266).)$_format_concise_process_notificationrir3NrArVr0concise)duration_secondszgateway.background.final_outputrr) rrrr`r6rr>r?maxrFrrhr) rrr]rrrr^_started_durrVrs &&&& r$_format_process_final_message7GatewayNotificationsMixin._format_process_final_messages j//> 7L$73=he 3U3Us3 h./[_5ggyRT6U6[6[Y[\ ) #7 WM^M^`jIMO O5j7K\K\^`swxakaqaqasasq26JZJZJ\]yr&cV^8dQhRR/#)rr rr")r#s"r$r%rsAA#Ar&c  "^RIHpHpVPVR4pT!T!\ VRR4;'gR44p\ R4V'dRV R2MR,pVP 4'd\ RWdP 4R 7#T#) r)r_shorten_command_for_displayirVr0z gateway.background.still_runningu — ``z gateway.background.recent_outputr)rrrr`r6rrh)rr]rrr^ short_cmdrs&& r$_format_process_running_message9GatewayNotificationsMixin._format_process_running_messagesa//= 01TU\]dfoqsUtUzUzxz1{| 56S\F9+Q:Obdeblbrbrbtbtq3FK[K[K]^ A{A Ar&c V^8dQhRRRR/#)rrcrYr rr")r#s"r$r%rs""4"D"r&c \VRR4p\VRR4'dVeVP4'gR#^RIHpV!VP V4V\ RR7pVRJ#)a}Start ``_run_process_watcher`` for a watcher registered mid-turn, from the agent's tool thread. Waiting for the post-turn drain leaves a process that finishes while its launching turn is still running with no watcher at all (#112033). False = the gateway is not serving (startup, shutdown): the caller keeps the descriptor in ``pending_watchers`` for the startup / post-turn drain. _gateway_loopNr?F)safe_schedule_threadsafez"Live process watcher arming failed)r4 log_message)r6 is_runningagent.async_utilsr_run_process_watcherr4)rrclooprrs&& r$arm_process_watcher-GatewayNotificationsMixin.arm_process_watchersc t_d3tZ//4)  % %g .V< T!!r&c V^8dQhRRRR/#)rrcrYr rr")r#s"r$r%rs"x_x_$x_4x_r&c aaaaaa"^RIHp^RIHpHpSR,pSR,pSP RR4oSP RR4oSP RR4oSP R R 4pSP S4;_uu_4GR jxL SP4pR R R 4GR jxL \PR WVXV4VR 8H;'dV'*p ^p ^p Tp \P!V 4GR jxL VP V4p V fEMgSP S4;_uu_4GR jxL V!R\V RR4R\V RR4/4pR R R 4GR jxL X'gV P'dEMKV 'dV P'dEMK\V P4pW8pTp V P'Ed[V'EdVP!V4'EgySP#SW4pV!V4pV'gEMdSP%SS4GR jxL pSP'VV4GR jxL pVR JdYV'dOVR!9gVR8XdAV P(R"9d0SP+W]R4oSP-SSSSS4GR jxL EMV ^, p V \.8d(\1V \3V^4^,\4RR7p EK\SRR 4ebSP7V4eO^RIHpSP V4;_uu_4GR jxL V!SV4R JpR R R 4GR jxL X'dEM'\P?RW[V4VP!V4'd\PRV4MVR!9gVR8XdV P(R"9dtSP+W]V4o^RI H!pSP S4;_uu_4GR jxL V!VVVVVV3RlSV P(R"9R7GR jxL R R R 4GR jxL MOV'gEKYVR8XgEKcV'dEKnSP-SSSSPEV 4S4GR jxL EK\PRV 'dR MRV4R #ELEL +GR jxL 'giEL;iELELELd +GR jxL 'giEL|;iELELELKELEL +GR jxL 'giEL;i \<d\PRTRR7R pELi;iELREL,EL +GR jxL 'giEL7;iL5i)#a Poll a background process and push updates until it exits. Mode (``display.background_process_notifications``): concise (default one-liner; failures append the output tail) / all (running updates + final raw) / result (final raw) / error (final raw if exit != 0) / off.r )format_process_notificationrrcheck_intervalr7r0r)r*notify_on_completeFNzCProcess watcher started: %s (every %ss, notify=%s, agent_notify=%s)rTrqrWrallrrArBrrz0Process watcher: admission recheck failed for %srzbProcess watcher: completion for %s was refused %d times; falling back to the notify_mode=%s noticeugProcess watcher: completion for %s already consumed via wait/log — skipping raw notification (#65379)rc.<SPSSSSS4#r^)rm)r)rirrr*rcsr$r@GatewayNotificationsMixin._run_process_watcher..RsD$>$>}gW`bnpw$xr&)r7rzProcess watcher ended%s: %sz (silent)>rrr>Nr)#rr r|rrr_rrr4r5rcrr6rrAr[is_completion_consumedr|rfrrrrmrr rrIr9rrr3rrrr)rrcr rrrr: agent_notifyrsilentlast_output_lencompletion_attemptsretry_intervalr]surfacecurrent_output_lenhas_new_outputcompletion_evtr turn_busyrhr committedrr)rirr*sff @@@@r$r.GatewayNotificationsMixin._run_process_watchers <q\* +, J3 ++i,KK R0 {{#7? //888BBDK98 Z K G%::l*:!--/ / /&**:6G33G<<<5#WWor%Jww 2>7=< >>>>>>!$W%:%:!; /AN0O~~~ <(8(O(OPZ([([%)%I%I'SZ%gN!<^!LJ%'+&A&A-QX&Y YI&*&S&ST^`n&o oI - %+9U*U'72w7H7HPY7Y+/+M+Mjcl+mL"&"<"<]GU^`lnu"vvv(1,'*-OO)9/C! R ^S.'+'C'CN'S'S'S,@~,V^b,b (T'S%!NN01;R] $:::FFLLNOY">>7*w/@/@ /Q#'#E#Ej[f#gLR#;;GDDD2xx%2w?P?PXa?accc ED K5$800!7It7[7[\c7dfm  26KrS]^S9888 0=<<<8!Z ow(T'S'S'S(."LL)[]g26)8(-I .0 Ec EDDDsBU.R%U.R+# U..R(/'U.(U.?S8U.8S 9U.<#S U.*S+ U.7U. U.U.':U."U.:9U.3S.4U. S1U. A U.)S4*A)U.T1S72T5 S= T S: TU./U. A+U.4U5U.8%UU U" U.-U . U.>U.U.'U.:U,;U. U.(U.+S 1R42 S =S ? U. U.U.S+ S S+ #S+ % U.1U.4U.7T:T=T T T T TU.T%U?U.UU. U U.U) U U) !U) # U.)rrY)r[r7rgr)r*r)r[rr/r^)NNFTNNN)r0r")g@)GrrrrrrrB dataclasses dataclassrrrrrr=rCrHrMrWrYrrkrerrr staticmethodrrrrr rr9rFrMrRrQrnrtr~rrasynccontextmanagerrrrrrrrrrrrrrr&r0r$rHrCr`rfrmr|rrrrrr"r&r$rrs_r$o |[wxz[{|    GD;b|IV230j : 6G 0<@ "8?%^N)OS)V5#n@ D'IR""2%Ni.X,fHMfP:F 5 Z%RNjj><|:4## $  @<> @8k<>8ktDD  <@ 4Il** S( D3$LHT0 ;o 5*nBB"Q ( ( T @A" x_x_r&r>.3gp.avi.mkv.mov.mp4.webm)r[r7rgr)r*rr>.gif.jpg.png.jpeg.webp> turn_leaserZcompression_closed)drop_completion_deliveryz'Could not drop durable completion claim)release_completion_deliveryz*Could not release durable completion claim)defer_completion_deliveryz+Could not defer unadmitted completion claim)complete_completion_deliveryz.Could not acknowledge durable completion claim)?r __future__rrcrrr/rrFpathlibrtypingrrrr agent.i18nragent.retry_utilsr rr r rr r gateway.platforms.eventrrgateway.sessionrrrgateway.run_shutdownrrrrr gateway.run_notifications_updater#gateway.run_notifications_ownershipr getLoggerr4r+r;rrur frozensetrrrIrHrJrirUrVrlrrrr"r&r$rs#  ,,.=M=EEuuLQ   = )b UY  @ p8 !**] ^%&"(*%%(!K S \ Yb b 8 J,6o_ ?Abo_r&