Ë
    8aiï  ã                   óL   — d dl mZmZ d dlmZ  G d„ de«      Z G d„ de«      Zy)é    )ÚABCÚabstractmethod)ÚFailureDetectorc                   óV   — e Zd Zedededdfd„«       Zededdfd„«       Zedd„«       Zy)	ÚAsyncFailureDetectorÚ	exceptionÚcmdÚreturnNc              ƒ   ó   K  — y­w)z:Register a failure that occurred during command execution.N© ©Úselfr   r	   s      úx/var/www/html/BankruptcyAI-uat/bankruptcy-ai/venv/lib/python3.12/site-packages/redis/asyncio/multidb/failure_detector.pyÚregister_failurez%AsyncFailureDetector.register_failure   ó   è ø€ ð 	ùó   ‚c              ƒ   ó   K  — y­w)zRegister a command execution.Nr   ©r   r	   s     r   Úregister_command_executionz/AsyncFailureDetector.register_command_execution   r   r   c                  ó   — y)z*Set the command executor for this failure.Nr   ©r   Úcommand_executors     r   Úset_command_executorz)AsyncFailureDetector.set_command_executor   s   € ð 	ó    ©r
   N)	Ú__name__Ú
__module__Ú__qualname__r   Ú	ExceptionÚtupler   r   r   r   r   r   r   r      s_   „ Øð°	ð Àð È$ò ó ðð ð°Eð ¸dò ó ðð òó ñr   r   c                   óL   — e Zd ZdZdeddfd„Zdededdfd„Zdeddfd	„Z	dd
„Z
y)ÚFailureDetectorAsyncWrapperz1
    Async wrapper for the failure detector.
    Úfailure_detectorr
   Nc                 ó   — || _         y ©N)Ú_failure_detector)r   r#   s     r   Ú__init__z$FailureDetectorAsyncWrapper.__init__   s
   € Ø!1ˆÕr   r   r	   c              ƒ   óD   K  — | j                   j                  ||«       y ­wr%   )r&   r   r   s      r   r   z,FailureDetectorAsyncWrapper.register_failure   s   è ø€ Ø×Ñ×/Ñ/°	¸3Õ?ùs   ‚ c              ƒ   óB   K  — | j                   j                  |«       y ­wr%   )r&   r   r   s     r   r   z6FailureDetectorAsyncWrapper.register_command_execution"   s   è ø€ Ø×Ñ×9Ñ9¸#Õ>ùs   ‚c                 ó:   — | j                   j                  |«       y r%   )r&   r   r   s     r   r   z0FailureDetectorAsyncWrapper.set_command_executor%   s   € Ø×Ñ×3Ñ3Ð4DÕEr   r   )r   r   r   Ú__doc__r   r'   r   r    r   r   r   r   r   r   r"   r"      sQ   „ ñð2¨ð 2¸Tó 2ð@°	ð @Àð @È$ó @ð?°Eð ?¸dó ?ôFr   r"   N)Úabcr   r   Úredis.multidb.failure_detectorr   r   r"   r   r   r   ú<module>r.      s&   ðß #å :ô˜3ô ô"FÐ"6õ Fr   