+
    iHàjÐ  ã                   ó®   a € R t0 t R t^ RIHt ^ RIHt ]! RRR7      t] ^ k ]! 0 Rm4      tRt	R R lt
R R	 ltR
 t]R 4       t]RR/R R ll4       tR# )zSTurn-local presentation of diagnostic-only wakes; execution and controls stay live.)Úcontextmanager)Ú
ContextVarÚmuted_notification_surfaceN)Údefaultc                ó<   € V ^8„  d   QhR\         R\         R\        /# )é   ÚeventÚ
session_idÚreturn)ÚstrÚbool)Úformats   "ÚD/home/ubuntu/.hermes/hermes-agent/agent/notification_presentation.pyÚ__annotate__r      s&   € ÷ Lñ L¤Cð L´Sð L¼Tñ Ló    c                 óR   € \         P                  4       V8H  ;'       d
    V \        9   # )N)Ú_muted_surfaceÚgetÚ_FREEFORM_EVENTS)r   r	   s   &&r   Úevent_presentation_mutedr      s$   € Ü×ÑÓ :Ñ-×KÐK°%Ô;KÑ2KÐKr   c                ó0   € V ^8„  d   QhR\         R\        /# )r   r   r
   )Údictr   )r   s   "r   r   r      s   € ÷ ñ ¤Dð ¬Tñ r   c                ón   € \        V P                  R4      4      ;'       g    V P                  R4      R9   # )zMEarly failure/monitor diagnostics, not the explicitly requested final result.Útask_failure_noticeÚtype>   Úwatch_disabledÚwatch_overflow_trippedÚwatch_overflow_released)r   r   )r   s   &r   Údiagnostic_process_eventr      s9   € ä�—	‘	Ð/Ó0Ó1÷ ð °U·Y±Y¸vÓ5Fð Kñ 6ð r   c                 ó   € ^ RI Hp  V ! 4       # )zYRead the owning effective config once per turn (the loader already returns a fresh copy).©Úeffective_user_config)Úgateway.warning_notificationsr!   r    s    r   Únotification_config_snapshotr#      s   € åCÙ Ó"Ð"r   c           	   #  ól  "  € \        4       pR Uu/ uF  pV\        WV4      bK  	  pp W n        Wn        Rx € VP	                  4        F#  w  rFWcJ d   \        W4       K  \        WV4       K%  	  R# u upi   TP	                  4        F#  w  rFYcJ d   \        Y4       K  \        YT4       K%  	  i ; i5i)z\Bind one foreground policy for callbacks, including worker threads. ``config`` is read-only.N)Ú_notification_configÚ_notification_platform)ÚobjectÚgetattrr%   r&   ÚitemsÚdelattrÚsetattr)ÚagentÚplatformÚconfigÚmissingÚkeyÚsavedÚvalues   &&&    r   Únotification_policy_snapshotr3   %   s­   é € ô ‹h€GáJóLÙJ�ð ”'˜% gÓ.Ò.ÙJð 
ð Lð	+Ø%+Ô"Ø'/Ô$ÛàŸ+™+ž-‰JˆCØÓÜ˜Ö#ä˜ EÖ*ó	 (ùòLøð  Ÿ+™+ž-‰JˆCØÓÜ˜Ö#ä˜ EÖ*ò	 (üs%   ‚B4‘A3§B4ªA8 º>B4Á89B1Â1B4r	   Ú c                ó0   € V ^8„  d   QhR\         R\        /# )r   Úmutedr	   )r   r   )r   s   "r   r   r   8   s   € ÷ $ñ $¤tð $¼ñ $r   c          	   #  óT  "  € V'       g   Rx € R# \        4       p. \        ORNRN5pV Uu/ uF  qU\        WV4      bK  	  pp\        P	                  V4      p \         F  p\        WR4       K  	  RV n        RV n        Rx € VP                  4        F#  w  rXWƒJ d   \        W4       K  \        WV4       K%  	  \        P                  V4       R# u upi   TP                  4        F#  w  rXYƒJ d   \        Y4       K  \        YT4       K%  	  \        P                  T4       i ; i5i)zPFreeze the current turn's presentation without touching prompts or tool schemas.NÚsuppress_status_outputÚ_mute_notification_replyT)r'   Ú_PRESENTATION_CALLBACKSr(   r   Úsetr+   r8   r9   r)   r*   Úreset)	r,   r6   r	   r/   Úkeysr0   r1   Útokenr2   s	   &$$      r   Únotification_turnr?   7   s  é € ÷ ÛÙÜ‹h€GØ[Ô$Ð[Ð&>Ð[Ð@ZÑ[€DÙ:>Ó?¹$°3”'˜% gÓ.Ò.¹$€EÐ?Ü×Ñ˜zÓ*€Eð$ß*ˆCÜ�E Ö%ñ +à'+ˆÔ$Ø)-ˆÔ&ÛàŸ+™+ž-‰JˆCØÓÜ˜Ö#ä˜ EÖ*ñ	 (ô
 	×Ñ˜UÖ#ùò @øð  Ÿ+™+ž-‰JˆCØÓÜ˜Ö#ä˜ EÖ*ñ	 (ô
 	×Ñ˜UÕ#üs*   ‚*D(¬CÁD(Á+C ÂAD(ÃAD%Ä%D(c                ód   € V ^8„  d   Qh/ ^ \         9   d   \        \        R,          ,          ;R&   # )r   Nr   )Ú__conditional_annotations__r   r   )r   s   "r   r   r      s%   € × YÑ Y÷
 `Ò _”
œ3 �:Õ&Ñ _ò Zr   >   ÚerrorÚreactionú
tool.startúmessage.deltaúmessage.startústatus.updateútool.completeúthinking.deltaúmessage.interimúreasoning.deltaútool.generatingúmessage.completeúnotification.show)Ústream_delta_callbackÚinterim_assistant_callbackÚreasoning_callbackÚtool_progress_callbackÚtool_start_callbackÚtool_complete_callbackÚtool_gen_callbackÚreaction_callback)rA   Ú__doc__Ú
contextlibr   Úcontextvarsr   r   Ú	frozensetr   r:   r   r   r#   r3   r?   r   )rA   s   @r   Ú<module>r[      sy   øðÞ YÝ %Ý "ñ *4Ð4PÐZ^Ô)_€Ó _áò ó Ð ð
Ð õLõò#ð ñ+ó ð+ð" ð$¸rö $ó ò$r   