+
    iHàj	  ã                  ó¤   € R t ^ RIHt ^ RIt^ RIHt ^ RIHt ]P                  ! R4      t	 ! R R]
4      tRtR	 R
 ltR R ltR R ltR R ltR# )zîFail-closed pre-compress checkpoint gate for ``agent.conversation_compression``.

The refusal type, its remediation text and the startup warning for
``compression.checkpoint_required``; ``conversation_compression`` re-exports every name.
)ÚannotationsN)ÚAny)Ú#PRE_COMPRESS_CHECKPOINT_API_VERSIONzagent.conversation_compressionc                  ó   € ] tR t^tRtRtR# )Ú CompressionCheckpointUnavailablezGRaised when required durable pre-compress checkpointing is unavailable.© N)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__doc__Ú__static_attributes__r   ó    ÚN/home/ubuntu/.hermes/hermes-agent/agent/conversation_compression_checkpoint.pyr   r      s   † ÝQr   r   zlset compression.checkpoint_required: false, or switch to a memory provider that implements checkpoint API v2c               ó    € V ^8„  d   QhRRRR/# )é   Úagentr   ÚreturnÚstrr   )Úformats   "r   Ú__annotate__r      s   € ÷ ?ñ ?¨ð ?°ñ ?r   c                óŒ  € \        V RR4      pVf   R# \        VRR4      p. pVer    \        V4      pV F_  p\        VRR4      p\        V\        4      '       g   K(  VP                  4       '       g   K@  VP                  VP                  4       4       Ka  	  V'       d   RP                  V4      # R#   \         d    . p L�i ; i)zBHuman-readable active provider name, or an explicit none sentinel.Ú_memory_managerNzno active providerÚ	providersÚnamez, )ÚgetattrÚlistÚ	TypeErrorÚ
isinstancer   ÚstripÚappendÚjoin)r   Úmemory_managerr   ÚnamesÚiterableÚproviderr   s   &      r   Ú_active_memory_provider_labelr&      s³   € ä˜UÐ$5°tÓ<€NØÒÙ#Ü˜¨°TÓ:€IØ€EØÒð	Ü˜I“ˆHó !ˆHÜ˜8 V¨TÓ2ˆDÜ˜$¤×$Ô$¨¯©¯¬Ø—‘˜TŸZ™Z›\Ö*ñ !÷  %ˆ4�9‰9�UÓÐ>Ð*>Ð>øô ô 	ØŠHð	ús   ¨B3 Â3CÃCc               ó    € V ^8„  d   QhRRRR/# ©r   Úreasonr   r   r   r   )r   s   "r   r   r   1   s   € ÷ ñ  ð Ð(Hñ r   c                ó   € \        R V  24      # )zLBLOCKED_MISSING_PREREQUISITE: required pre-compress checkpoint unavailable: )r   ©r)   s   &r   Ú_checkpoint_blockedr,   1   s   € Ü+Ø
VÐW]ÐV^Ð_óð r   c               ó    € V ^8„  d   QhRRRR/# r(   r   )r   s   "r   r   r   7   s   € ÷ [ñ [ #ð [Ð*Jñ [r   c                ó*   € \        V  R\         24      # )uç   Capability refusal: the gate can never pass with this provider set, so the
message carries the config-level way out. Transient checkpoint failures keep
the plain form â€” there the provider is capable and the right move is a retry.z. Recover by )r,   Ú _CHECKPOINT_REQUIRED_REMEDIATIONr+   s   &r   Ú_checkpoint_incapabler0   7   s   € ô  & ¨Ô7WÐ6XÐYÓZÐZr   c               ó    € V ^8„  d   QhRRRR/# )r   r   r   r   ÚNoner   )r   s   "r   r   r   >   s   € ÷ ñ ¸cð Àdñ r   c                ó|  € \        V RR4      RJd   R# \        V RR4      pVe>   \        VRR4      p\        V4      '       d     \        V! \        4      4      '       d   R#  \
        P                  R	\        V 4      \        \        4       R#   \         d$   p\
        P                  RTRR7        Rp?R# Rp?ii ; i)
ul  Startup warning when fail-closed compress will block (init itself must not refuse).

Capability-probe exceptions are suppressed so a broken provider cannot crash
agent construction â€” same fail-open style as the micro-compact warning.
Probe failures log at DEBUG so a flaky probe can be diagnosed without
refusing init or emitting the incapable-provider WARNING.
Úcompression_checkpoint_requiredFTNr   Ú supports_pre_compress_checkpointz?checkpoint-required capability probe failed; init continues: %s)Úexc_infozŸcompression.checkpoint_required is enabled but the active memory provider (%s) does not implement checkpoint API v%s. Compress will fail closed. Recover by %s.)
r   ÚcallableÚboolr   Ú	ExceptionÚloggerÚdebugÚwarningr&   r/   )r   r"   Úsupports_checkpointÚexcs   &   r   Ú2_warn_checkpoint_required_without_capable_providerr?   >   s¿   € ô ˆuÐ7¸Ó?ÀtÓKÙÜ˜UÐ$5°tÓ<€NØÒ!Ü% nÐ6XÐZ^Ó_ÐÜÐ'×(Ò(ð	ÜÑ+Ô,OÓP×QÒQÙð Rô ‡N�Nð	&ô 	& eÓ,Ü+Ü(öøô ô Ü—‘ØUØØ!ð ô õ
 ûðús   ÁB ÂB;ÂB6Â6B;)r   Ú
__future__r   ÚloggingÚtypingr   Úagent.memory_providerr   Ú	getLoggerr:   ÚRuntimeErrorr   r/   r&   r,   r0   r?   r   r   r   Ú<module>rF      sX   ðñõ #ã Ý å Eð 
×	Ò	Ð;Ó	<€ôR |ô Rð1ð !õ?õ&õ[÷r   