+ jHjRt^RIHt^RIt^RIt^RIt^RIt^RIHtH t ^RI H t ^RI Ht^RIHt]P"!R4tRt!R R 4tR#) zTransport layer of GatewayStreamConsumer: native frames, drafts, edit/send. Mixin methods use only ``self`` state; see gateway/stream_consumer.py for the state model and the drain loop that calls into these.) annotationsN)AnyOptional)BasePlatformAdapter)ensure_closed_code_fences)stops_reply_clockzgateway.stream_consumerg>@c]tRt^tRt^tRR/RRlltRR/RRllt]RR/R R ll4t R R lt R Rlt RRlt RRlt RRltRR/RRlltRRRRRR/RRlltRR ltR!R"ltR#R$ltR%R&ltR'R(ltR)R*ltR+R,ltR-R.ltR/R0ltR1R/R2R3lltR4R5lt]RRR1R/R6R7ll4tR8R9ltR:R;ltR<R=lt R>R?lt!R@RAlt"RBRClt#RDt$R#)EStreamTransportMixinzGSend/edit/frame primitives and the transport-ordered ``_send_or_edit``.finalizeFc$V^8dQhRRRRRR/#) message_idstrcontentr bool)formats"F/home/ubuntu/.hermes/hermes-agent/gateway/stream_consumer_transport.py __annotate__!StreamTransportMixin.__annotate__s! 9 9 9s 9d 9c "\VPWVR7pVP'd\P!VP P 4PpRV9gW\;QJd*RVP44F 'gK RM RM!RVP444'dVPVR&VP P !R/VBGRjxL # \\3dL7i;iL5i)z>Edit via the adapter, passing routing metadata when supported.)chat_idr rr metadatac3l"TF*qP\PPJxK, R#5i)N)kindinspect Parameter VAR_KEYWORD).0params& r 5StreamTransportMixin._edit_message..'s'/^M\EJJ'"3"3"?"??_s24TFNr) dictrrr signatureadapter edit_message parametersanyvalues TypeError ValueError)selfr rr kwargsparamss&$$$ r _edit_message"StreamTransportMixin._edit_messagesdllz') ===  **4<<+D+DEPP'33/^MS]]_/^333/^MS]]_/^,^,^)-F:&\\..8888z*  8sG+D AC24C2(C2?C2D -D .D 2DD DD exc_infoc$V^8dQhRRRRRR/#r fail_logrr1rreturnr)rs"rrr.s'HHcHHQUHrc "VPPRVPVPVPR7pVP W1VR7GRjxL #L5i)zOpen a native stream with an empty seed frame (typing indicator before any token) as a bool; a raise logs ``fail_log`` at DEBUG (error formatted in, or the traceback when ``exc_info``) and reads as False.)rreply_toturn_idr1N)r%send_stream_framer_initial_reply_to_id_turn_id _try_frame)r,r4r1seeds&&$ r_try_seed_frame$StreamTransportMixin._try_seed_frame.sT||--  t/H/HRVR_R_.a__Th_GGGGsAAAAc$V^8dQhRRRRRR/#r3r)rs"rrr7s!   4 D rc "\VGRjxL 4#L \dApT'd\PTRR7M\PY4Rp?R#Rp?ii;i5i)zTAwait a frame send as a bool; a raise logs ``fail_log`` at DEBUG and reads as False.NTr:F)r Exceptionloggerdebug)coror4r1es&&$ rr>StreamTransportMixin._try_frame6sJ d # #   X 5 X)  s6A' A' A$5AA'A$$A'c V^8dQhRRRR/#)r textrr rr)rs"rrrBs##c##rc "VPPWVPVPVPR7GRjxL #L5i)zNOne native-stream frame; every frame carries the same chat/reply/turn routing.)r rr8r9N)r%r;rr<r=)r,rKr s&&$r _send_frame StreamTransportMixin._send_frameBsC\\33 T\\DD]D]MM4## ##sAA AA cV^8dQhRR/#r r5Noner)rs"rrrHs))T)rc "RVn^VnR#)zDMark the native stream closed (next content re-seeds or falls back).FN)_native_stream_opened_native_last_pushed_lenr,s&r_close_native_state(StreamTransportMixin._close_native_stateHs%*"'($rc V^8dQhRRRR/#)r r4rr5rQr)rs"rrrMs,,,,rc "VPVPRRR7V4GRjxL VP4RVnR#L5i)zRBest-effort empty finalize frame to close an open typing bubble, then mark closed.r7Tr NF)r>rMrV_reopen_seeded_eagerly)r,r4s&&r_close_empty_native_bubble/StreamTransportMixin._close_empty_native_bubbleMsCood..rD.A8LLL   "&+# Ms'A AA cV^8dQhRR/#rPr)rs"rrrSs$$$$rc VRVnVP4RVPnR#)zLeave native mode; buffer_only so post-boundary output is ONE send() at got_done (mid-stream flushes would create multiple messages on non-editable platforms).FTN)_use_native_streamingrVcfg buffer_onlyrUs&r _degrade_native_to_buffered_send5StreamTransportMixin._degrade_native_to_buffered_sendSs$&+"   "#rcV^8dQhRR/#)r r5z dict | Noner)rs"rrrZsrc VP'd\VP4M/pVP'dVPRVP4T;'gR#)zDraft-frame metadata: same reply_to_message_id as the final send, because the relay adapter keys draft/seal state on it (flat DMs have no thread metadata).reply_to_message_idN)rr#r< setdefault)r,mds& r_draft_metadata$StreamTransportMixin._draft_metadataZsI%)MMMT$-- r  $ $ $ MM/1J1J KzzTr segment_onlyc V^8dQhRRRR/#)r rlrr5setr)rs"rrrbs$3rc \V'd VPM VP4pVP'dJVPR8wd9TP V'd\ VP4M VP4V#)zPPreview ids a fresh final replaces; ``segment_only`` spares finalized preambles. __no_edit__)rn_segment_preview_message_ids_preview_message_ids _message_idaddr)r,rl stale_idss&$ r_stale_preview_ids'StreamTransportMixin._stale_preview_idsbs_\99!668     0 0M A MM<#d../TEUEU VrskipNretry_on_false skip_sentinelTc(V^8dQhRRRRRRRR/#)r labelrryrrzr5rQr)rs"rrrjs1WWSW/3WLPW\`Wrc "\VPRR4pVfR#VFpV'dWr8XgV'd VR8XdK"V!VPV4GRjxL pV'dDVRJd<\P!R4GRjxL V!VPV4GRjxL KKK R#LUL+L \ d#p \ PRY7T 4Rp ? KRp ? ii;i5i)zMBest-effort delete of stale previews; never the message just sent (``skip``).delete_messageNrpFg?z"%s preview cleanup failed (%s): %s)getattrr%rasynciosleeprDrErF) r,rurxr|ryrz delete_fnstale_iddeletedrHs &&$$$$ r_delete_previews%StreamTransportMixin._delete_previewsjsDLL*:DA   !Hx/MhR_F_ W )$,, AA!g&6 "--,,,#DLL(;;; '7> "B -; W A5TUVV Wsp8C' C'B7B1 B7(B7B3B7"B5#B7' C'1B73B75B77 C$CC'C$$C'cV^8dQhRR/#r r5rr)rs"rrrs$rc VPP;'gRP4pVR 9g!\VP\ 4'gR#\ VPP;'gRVPR7pVPP!R RVP/VBpT'g=TR 8Xd6\PR TPTPP4\T4# \d TPP!R /TBpLxi;i \d\PRRR7RpLi;i) ucfg.transport "draft"/"auto" → the adapter's supports_draft_streaming probe ("draft" logs the downgrade); "edit"/"off" → False.editFN chat_typerrz%supports_draft_streaming probe raisedTr:draftuUDraft streaming requested but unsupported (chat=%s, type=%r) — falling back to edit)roffr)ra transportlower isinstancer%_BasePlatformAdapterr#rrsupports_draft_streamingrr*rDrErFr)r,r probe_kwargs supporteds& r_resolve_draft_streaming-StreamTransportMixin._resolve_draft_streamings"XX''11688:  'z$,,H\/]/]dhh&8&8&@&@D4==Y   R!LLAAR$,,RDPR Y'1 LL015txx?Q?Q SI R LLAAQLQ  R  LL@4L PI s*(D'D0-D3/D00D33$EEcV^8dQhRR/#rr)rs"rrrs  4 rc \VP\4'd'\\ VP4RR4'gR#\VPRR4pVfR#\ T!VP P;'gRVPR74# \d\PRRR7R#i;i) zNative streaming (send_stream_frame for ALL frames): a BasePlatformAdapter with class-level SUPPORTS_NATIVE_STREAMING and a truthy supports_native_streaming probe.SUPPORTS_NATIVE_STREAMINGFsupports_native_streamingNrz&supports_native_streaming probe raisedTr:) rr%rrtyperrarrrDrErF)r,probes& r_resolve_native_streaming.StreamTransportMixin._resolve_native_streamings4<<)=>>D.0KUSS &A4H = (:(:(B(BdT]][\ \  LLADL Q s'#B" B"""CCc V^8dQhRRRR/#r rKrr5rr)rs"rrrs""C"D"rc H"VPf RVnR#VPPVPVPVVP 4R7GRjxL p\ VRR4'd WnR#^RIH pV!V4'd\PR4RVn \PR\ VR R 44V;P^, unRVnR#L \d!p\PR T4Rp?LJRp?ii;i5i) zEmit one draft frame; any failure permanently disables drafts for this run. Drafts have no message_id and clear on the client when the final send lands.NF)rdraft_idrrsuccessT declined_sendzsend_draft DECLINED by the connector's egress guard; suppressing every later send for this run (the destination is not approved for this connection)z@send_draft returned success=False, disabling draft transport: %serrorunknownz=send_draft raised, disabling draft transport for this run: %s) _draft_id_use_draft_streamingr% send_draftrrjr_last_sent_textgateway.relay.egressrrEwarning_egress_declinedrFrD_draft_failures)r,rKresultrrHs&& r_send_draft_frame&StreamTransportMixin._send_draft_frames >> !(-D % ><<22 t~~t--/311F vy%00'+$ ;V$$; )-% LL[ )< > !$)!51 ] LLXZ[ \ \ ]sHD"AC4C2 C4$.D"AD"2C44 D?DD"DD"cV^8dQhRR/#rPr)rs"rrrs K Kd Krc "VP'gR#\\VP4RR4fR#VPP VP VP ;'gVPVP4VP4R7GRjxL R#L \d"p\PRT4Rp?R#Rp?ii;i5i)zSeal an orphaned draft stream on turn death (stale exit / cancel): else the live indicator stays forever and armed interception state leaks into the next turn. Never sets delivery flags.Nabandon_open_draftrz+abandon_open_draft failed (best-effort): %s) rrrr%rrr_clean_for_display _accumulatedrjrDrErF)r,rHs& r_abandon_native_stream+StreamTransportMixin._abandon_native_streams(((  4 %';T B J  K,,11 d22``d6M6MdN_N_6`--/21 1 1 K LLF J J KsF9C2B+/3B+"B)#B+'C)B++ C6C CCCcV^8dQhRR/#rr)rs"rrrsLL4Lrc Z\VP4;'dVPR8g#)z=A real (editable, deletable) preview message id is on screen.rp)rrsrUs&r_has_real_preview&StreamTransportMixin._has_real_previews&D$$%KK$*:*:m*KKrcV^8dQhRR/#rr)rs"rrrsHH$Hrc \VPRR4;'gRpV^8:g%VP4'dVPfR#\P !4VP, V8#)uzTrue when fresh-final is enabled and a real preview has been visible ≥ threshold. Ported from openclaw/openclaw#72038. fresh_final_after_secondsgF)rrar_message_created_tstime monotonic)r, thresholds& r_should_send_fresh_final-StreamTransportMixin._should_send_fresh_finals_ DHH&A3GNN3 >!7!7!9!9T=U=U=]~~$":"::iGGrc V^8dQhRRRR/#)r r z Optional[str]r5rQr)rs"rrrs>>M>d>rc V'dMVR8wdD\V4pVPPV4VPPV4R#R#R#)z:Record a real preview message id for finalization cleanup.rpN)rrrrtrqr,r s&&r_track_preview_id&StreamTransportMixin._track_preview_idsD * 5ZJ  % % ) )* 5  - - 1 1* =6:rc V^8dQhRRRR/#)r rrr5rQr)rs"rrrs((S(T(rc \VRR4;'g/p\V\4'dVPR4MRp\VRR4.\VRR4;'gROT;'gROFpVP V4K R#)zHRecord the primary id plus any continuation ids from an oversized split. raw_responseN message_idsr continuation_message_idsr)rrr#getr)r,rrawraw_idsmids&& r_track_preview_ids_from_result3StreamTransportMixin._track_preview_ids_from_resultsfnd399r,6sD,A,A#''-(tFL$7bf&@$GMM2bRYR_R_]_bC  " "3 'brc V^8dQhRRRR/#rr)rs"rrrsrc \VPRR4pVeVP4'gR#V!WPVPR7pVRJ# \ d2T!YPR7pM \ d T!T4pMi;ii;iTRJ# \ d"p\PRT4Rp?R#Rp?ii;i)zAdapter's prefers_fresh_final_streaming hook (Telegram's richer send path); False without a real preview / hook, or on any error.prefers_fresh_final_streamingNF)rrrz.prefers_fresh_final_streaming check failed: %sT) rr%rrrr*rDrErF)r,rKfnrrHs&& r_adapter_prefers_fresh_final1StreamTransportMixin._adapter_prefers_fresh_finalsT\\#BD I :T3355  &D==$,,O~ &&}}=F &XF& &~   LLI1 M sMA B$A97B9B B BBBB C&CC is_turn_finalc$V^8dQhRRRRRR/#)r rKrrrr5r)rs"rrr s"  3 $ RV rc P"VP'dR#VP4pVPPVPWP RR7R7GRjxL p\TRR4'gR#\TRR4pTPY6R R 7GRjxL \4Tn TPT4RTnYnT'dRTnTP#T4R#L \ d"p\PRT4Rp?R#Rp?ii;iL5i) aSend ``text`` fresh and best-effort delete the preview(s); False on any failure so the caller falls back to edit. ``is_turn_final=False`` leaves the delivery flag unset. ``is_turn_final`` is False when finalizing an interim segment at a tool boundary (a preamble) rather than the turn-final answer; the final-delivery flag is then left unset so the gateway still delivers the real answer from the next API call (#29346). Ported from openclaw/openclaw#72038. FT)final)rrrNz1Fresh-final send failed, falling back to edit: %srr z Fresh-final)rxr|)_turn_split_deliveryrvr%sendr_metadata_for_sendrDrErFrrrnrr_adopt_message_id _already_sentr_final_response_sent_record_turn_final_payload)r,rKrrurrHnew_message_ids&&$ r_try_fresh_final%StreamTransportMixin._try_fresh_final s   $ $ $++-  <<,, d=T=T[_=T=`-bbF vy%00 t<##I-#XXX$'E! ~.!# (,D %  + +D 1#b  LLLa P  YsM%D&:C5"C3#C5'8D&D$ AD&3C55 D!DD&D!!D&cV^8dQhRR/#rPr)rs"rrr/s,,t,rc vV'd#Wn\P!4VnR#RVnRVnR#)uVRetarget edits at ``message_id``; None → "__no_edit__" sentinel so we never edit it.rpN)rsrrrrs&&rr&StreamTransportMixin._adopt_message_id/s* ) '+~~'7D $,D '+D $rc(V^8dQhRRRRRRRR/#r rKrr rrr5r)rs"rrr9s,:::&*:CG:SW:rc "VPV4pTp\V4pVPP'd'VP VPPR4MTP 4pV'gpV'dfVP 'dTVP'dBVPVPRRR7R4GRjxL 'dVP4R#T;'dV'*pVPf\\V4VP8dBV'g8VPP'dVPPV9dR#VP 'd"VPWVR7GRjxL pVeV#VP'd1VPf#VP!WVVR7GRjxL pVeV#RVnVPf7VP$'g V'gR#VP'WR7GRjxL #VP$'gR#VP)WVR7GRjxL #ELLLL:L \*d"p\,P/R T4Rp?R#Rp?ii;i5i) uSend or edit the streaming message; True if delivered. ``finalize`` marks the last edit. Transport order: native frame → draft frame → edit existing → first send; a transport returns None to fall through to the next.r7u✅TrZz Finalize empty stream failed: %sNr rFzStream send/edit error: %s)rrracursorreplacestripr`rSr>rM_mark_final_deliveredrslen_MIN_NEW_MSG_CHARS _native_pushr _draft_push_last_edit_overflowed_edit_supported _first_send_edit_existingrDrEr) r,rKr rpre_fence_textvisible_strippedpreamble_finalizeokrHs &&$$ r _send_or_edit"StreamTransportMixin._send_or_edit8s) &&t,(.AEDLL"=VZaacT777D.>ut.>.T.PRRR**,%::]):    $-=)>AXAX)X&488???txxRV?V  % % %((P](^^B~  $ $ $)9)9)A''x6C(EEB~ %*" '+++H!!--d-FFF''',,TTa,bb bMR(_EGc  LL5q 9 sA8J;JJJ'&J I JJ37J+J.J6J I J)%JIJ!II J I I!I$J%I7J9IIIJJJII J *JJJ  Jc(V^8dQhRRRRRRRR/#)r rKrr rrr5Optional[bool]r)rs"rrrus)55s55d5 .5rc z"VP'g_V'dWVPR4GRjxL 'g RVnR#RVnRVn\P RVP 4T;'dTpV'gWP8XdR#V'dVPVR7VPVPWR7R4GRjxL 'd8RVn Wn\V4Vn V'dVP4R#V'dRVnRVnRVnRVnVP'd4VPVRR7GRjxL \P#R 4R#R#ELTLL" \$d"p\P#R T4Rp?R#Rp?ii;i5i) uNative streaming: every frame goes through send_stream_frame(); lazy re-seed after a boundary. None when native was disabled (seed/frame failure) → caller falls through.z.Re-seed failed, disabling native streaming: %sNFTzR[latency] Re-opened native stream after boundary (turn=%s, waited for first delta))recordrZz8send_stream_frame raised, disabling native streaming: %sz5Native fallback: finalized stream (best-effort close)z.Native fallback: failed to finalize stream: %s)rSr@r`_awaiting_reopen_after_boundaryrEinfor=rrr>rMrrrTr_final_content_delivered_delivered_final_textrFrD)r,rKr rrHs&&$$ rr!StreamTransportMixin._native_pushus)))d--.^___-2*)-D &38D 0 KK<=A]] L -- D$8$88   & &d & 3!1!1$!1!J![] ] ]!%D #' +.t9D (**, (-D %,1D ))-D &&+"  % % % R&&td&;;; TUa`* ].< R MqQQ RsF;F;F F;?F;< F;F;!7F;F F;#>F;"-F;F 'F (F F;F; F F8F3-F;3F88F;c ,V^8dQhRRRRRRRRRR/#) r rKrrr rrr5rr)rs"rrrs8JJcJ3JTJ)-J2@Jrc "VP4pV'dV'd V'dR#V'dTMTpVPP'dOVPVPP4'd$VR\ VPP4)pW`P 8XdR#VP V4GRjxL 'dR#R#L5i)a*Draft frame while no message_id exists; None = not applicable / drafts just failed. Skipped when finalizing (the real send clears the draft), EXCEPT stream-is-the-message adapters keep ONE stream per turn: a segment-break finalize must not become a real send (it would seal at every tool boundary).NT)_stream_is_messagerarendswithrrr)r,rKrr r stream_is_msg frame_texts&&&$$ rr StreamTransportMixin._draft_pushs //1 ]='4^$  88???z22488??CC#$;s488??';&;"\VRR4'd\PR4R#VPP VP WP VPW"'*R7R7GRjxL pVP'g RVn R#RVn Wn VP'd.VPVP4VPV4M&VPVP!44RVnVP%4R#L5i) zBFirst send, threaded to the user's message (correct topic/thread).rFzasuppressing the plain-send fallback: the connector already declined this destination for this run)r expect_edits)rrr8rNTrp)rrErr%rrr<rrrrrr rr_enter_fallback_mode_visible_prefixrs_notify_new_message)r,rKr rs&&$ rr StreamTransportMixin._first_sends 4+U 3 3 NN9 ||((LL$9R9R,,8,,W)YY~~~#(D !#      " "6#4#4 5  / / 7  % %d&:&:&< =,D    "!YsA5D7D8DBDc(V^8dQhRRRRRRRR/#rr)rs"rrrs*---4-PT-Y]-rc H"WP8XdV'dVP'gR#\\VP4R4;'gR\ VPR/49pVP V4pV'dIV'gV'g9VP4'd#VPWR7GRjxL 'dR#VPVPVVR7GRjxL pVP'gVPWaVVR7GRjxL #\ VRR4p\V\4'dVPR 4'dR#RVnVP#V4\ VR R 4'g R 'dxVP$'dfVP$VP8wdKRVnRVnVP+\-VP$44R VnVP/4MWn^VnR#ELVEL+L5i) zFEdit the live preview (or replace it via fresh-final when finalizing).Tr__dict__)rN)r rr rrskippedrr7r)r_adapter_requires_finalizehasattrrr%rrrrr/rsr_on_edit_failurerr#rrrr rrrrr_flood_strikes)r,rKr rhas_prefers_hook prefers_freshrrs&&$$ rr#StreamTransportMixin._edit_existings '' 'd>]>]>] D&(G H X X.'$,, TV2WW 99$?  "2t7T7T7V7V))$)LLL))T5E5Et3;*==~~~..vh=J/LL Lv~t< lD ) )l.>.>y.I.I! ++F3V7 < <%%%&*;*;t?O?O*O)-D &(,D %  " "3v'8'8#9 :#%D  $ $ &#' 9M=Ls|H"H"'H"3H" H"H"H"/H"H H"#H"2H3H" H" H !=H"4H"H"&A5H"H" H"c V^8dQhRRRR/#)r prefixrr5rQr)rs"rrr s""3"4"rc <WnRVnRVnRVnR#)zGEdits are over for this stream: send only the missing tail at got_done.TFN)_fallback_prefix_fallback_final_sendrr)r,r)s&&rr)StreamTransportMixin._enter_fallback_mode s &$(!$!rc(V^8dQhRRRRRRRR/#rr)rs"rrrs0NN3NTNZ^N$(Nrc v"^RIHpV!V4'd&\PR4RVnRVnR#T;'dTpV'dVP P'dcVPPVP P4'd.VP4V8XdRVn VPV4\VRR4p\V\4'EdVP!R4'd\#VP!R4;'g!VP$;'g VP&4VnVP!R 4p\V\"4'd7V'd/WnVP)V4VnVP-V4M&RVnVP-VP44\VR R4'dVP/4R#Rp VP1V4'EdEV;P2^, un\5VP6^,R 4p \VR R4p \V \8\:34'd+V ^8d$\=V \5\;V 4\>44p Wn\PAR VP2VPBVP64T;'d\VPDRR4RJp VP2VPB8d%V 'g\FPH!4Vn%R#V 'd\PAR4\PARVP24VP-VP44V 'gVPM4GRjxL R#L5i)zClassify a failed edit: partial overflow, flood backoff, or fallback mode. Always False; the caller's finalize path may still deliver the tail.rzedit DECLINED by the connector's egress guard; suppressing every later send for this run (the destination is not approved for this connection)TFrNpartial_overflowlast_message_iddelivered_prefixrg$@ retry_afteru@Flood control on edit (strike %d/%d), backoff interval → %.1fsFALLBACK_ON_FINAL_EDIT_FLOODz@Turn-final edit hit flood control; entering fallback immediatelyz0Edit failed (strikes=%d), entering fallback moder)'rrrErrrrarrrrr rrrr#rrr rs startswith#_fallback_preserve_partial_messagesrr_is_flood_errorr$min_current_edit_intervalintfloatmax_MAX_EDIT_BACKOFF_SECSrF_MAX_FLOOD_STRIKESr%rr_last_edit_time_try_strip_cursor) r,rrKr rr turn_finalrr2immediate_final_fallbackbackoffr3s &&&$$ rr#%StreamTransportMixin._on_edit_failures 7  NN0  %)D !#(D //- 488???t/C/C/L/LTXX__/]/]((*d2-1D )  + +D 1 v~t< lD ) )l.>.>?Q.R.R #<#3#34E#F$7$7&J[J[$7$7&*&6&6 8D +//0BC *C005E'7$;???K[;\8))*:;;@8))$*>*>*@Av92>>((* $)    ' '   1 $ $5594@G!&->K+U|44qgs5+=?U'VW*1 ' LL[,,d.E.EtGbGb dccwt||5SUZ[_cc %""T%<%<rMrVr\rcrjrvrrrrrrrrrrrrrrrrrrrr#__static_attributes__rrrr r sQ 9UZ 9HuH %  # ) , $WW6;WSWW*0 "H KLH>(.  D,:-2:JN::x5nJ*:-^"NNrr )rI __future__rrrloggingrtypingrrgateway.platforms.baserrgateway.stream_consumer_fencesr/hermes_cli.observability.shared_metrics_gatewayr getLoggerrEr=r rrrrSsL9 # NDM   4 5 H H r