File: //opt/alt/python311/lib/python3.11/site-packages/redis/__pycache__/retry.cpython-311.pyc
�
$�;f� � �D � d dl Z d dlmZ d dlmZmZ G d� d� � ZdS )� N)�sleep)�ConnectionError� TimeoutErrorc �> � e Zd ZdZeeej ffd�Zde fd�Z
d� Z dS )�Retryz0Retry a specific number of times after a failurec �0 � || _ || _ || _ dS )z�
Initialize a `Retry` object with a `Backoff` object
that retries a maximum of `retries` times.
You can specify the types of supported errors which trigger
a retry with the `supported_errors` parameter.
N)�_backoff�_retries�_supported_errors)�self�backoff�retries�supported_errorss �>/opt/alt/python311/lib/python3.11/site-packages/redis/retry.py�__init__zRetry.__init__
s � � ��
� ��
�!1�� � � � �specified_errorsc �r � t t | j t |� � z � � � � | _ dS )zM
Updates the supported errors with the specified error types
N)�tuple�setr )r r s r �update_supported_errosz Retry.update_supported_erros s8 � � "'� ��&��/?�)@�)@�@� A� A�"
� "
�� � � r c � � | j � � � d} |� � S # | j $ rV}|dz
} ||� � || j k r|�| j � |� � }|dk rt |� � Y d}~nd}~ww xY w�o)a&
Execute an operation that might fail and returns its result, or
raise the exception that was thrown depending on the `Backoff` object.
`do`: the operation to call. Expects no argument.
`fail`: the failure handler, expects the last error that was thrown
r T� N)r �resetr r
�computer )r �do�fail�failures�errorr
s r �call_with_retryzRetry.call_with_retry" s� � �
�
��� � � ���
#�
#��r�t�t� ���)�
#�
#�
#��A�
����U� � � ��d�m�+�+� �K� �-�/�/��9�9���Q�;�;��'�N�N�N����������
#����
#s � ( �
B�A B�BN) �__name__�
__module__� __qualname__�__doc__r r �socket�timeoutr �listr r � r r r r sf � � � � � �:�:� *�<�� �H� 2� 2� 2� 2�
�t�
�
�
�
�#� #� #� #� #r r )r% �timer �redis.exceptionsr r r r( r r �<module>r+ sj ��
�
�
�
� � � � � � � :� :� :� :� :� :� :� :�.#� .#� .#� .#� .#� .#� .#� .#� .#� .#r