�
J�g� � � � d dl Z d dlmZ d dlmZmZmZmZmZm Z m
Z
d dl m Z m
Z
e
d� � Zerd dlmZ G d� d� � ZdS ) � N)�sleep)�
TYPE_CHECKING�Any�Callable�Iterable�Tuple�Type�TypeVar)�ConnectionError� TimeoutError�T)�AbstractBackoffc � � e Zd ZdZeeej ffdddede e
e df fd�Z de
e
e d d
fd �Zd eg ef d
ee gef d efd�Zd
S )�Retryz0Retry a specific number of times after a failure�backoffr �retries�supported_errors.c �0 � || _ || _ || _ dS )a'
Initialize a `Retry` object with a `Backoff` object
that retries a maximum of `retries` times.
`retries` can be negative to retry forever.
You can specify the types of supported errors which trigger
a retry with the `supported_errors` parameter.
N)�_backoff�_retries�_supported_errors)�selfr r r s �[/home/asafur/pinokio/api/open-webui.git/app/env/lib/python3.11/site-packages/redis/retry.py�__init__zRetry.__init__ s � �" ��
� ��
�!1�� � � � �specified_errors�returnNc �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_errorsz Retry.update_supported_errors% s8 � � "'� ��&��/?�)@�)@�@� A� A�"
� "
�� � � r �do�failc �. � | j � � � d} |� � S # | j $ ra}|dz
} ||� � | j dk r
|| j k r|�| j � |� � }|dk rt |� � Y d}~nd}~ww xY w�z)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 r" r# �failures�errorr s r �call_with_retryzRetry.call_with_retry/ s� � �
�
��� � � ���
#�
#��r�t�t� ���)�
#�
#�
#��A�
����U� � � ��=�A�%�%�(�T�]�*B�*B� �K� �-�/�/��9�9���Q�;�;��'�N�N�N����������
#����
#s � ( �
B�AB�B)�__name__�
__module__� __qualname__�__doc__r r �socket�timeout�intr r � Exceptionr r r! r r
r r* � r r r r
s� � � � � � �:�:�
� � �N�9
� 2� 2�"�2� �2� ��Y��� 4�5� 2� 2� 2� 2�*
� (��i� � 9�
�
�
�
�
�
�#� �R��U�O�#� � �{�C�'�(�#�
� #� #� #� #� #� #r r )r/ �timer �typingr r r r r r r
�redis.exceptionsr r r
�
redis.backoffr r r3 r r �<module>r8 s� ��
�
�
�
� � � � � � � O� O� O� O� O� O� O� O� O� O� O� O� O� O� O� O� O� O� :� :� :� :� :� :� :� :� �G�C�L�L��� .�-�-�-�-�-�-�9#� 9#� 9#� 9#� 9#� 9#� 9#� 9#� 9#� 9#r