�
J�g� � � � d dl mZ d dlmZmZmZmZmZmZm Z d dl
m Z m Z m
Z
erd dlmZ e d� � Z G d� d� � ZdS ) � )�sleep)�
TYPE_CHECKING�Any� Awaitable�Callable�Tuple�Type�TypeVar)�ConnectionError�
RedisError� TimeoutError)�AbstractBackoff�Tc � � e Zd ZdZdZeeffdddedee e
df fd�Z d e fd
�Z
d eg ee f d ee
gef d
efd�ZdS )�Retryz0Retry a specific number of times after a failure��_backoff�_retries�_supported_errors�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.
Nr )�selfr r r s �c/home/asafur/pinokio/api/open-webui.git/app/env/lib/python3.11/site-packages/redis/asyncio/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_errorsz Retry.update_supported_errors& s8 � � "'� ��&��/?�)@�)@�@� A� A�"
� "
�� � � r �do�fail�returnc � �V K � | j � � � d} |� � � d{V ��S # | j $ rm}|dz
} ||� � � d{V �� | j dk r
|| j k r|�| j � |� � }|dk rt |� � � d{V �� Y d}~nd}~ww xY w��)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 TN� )r �resetr r �computer )r r# r$ �failures�errorr s r �call_with_retryzRetry.call_with_retry. s� � � � �
�
��� � � ���
)�
)� �R�T�T�z�z�z�z�z�z�!���)�
)�
)�
)��A�
���d�5�k�k�!�!�!�!�!�!�!��=�A�%�%�(�T�]�*B�*B� �K� �-�/�/��9�9���Q�;�;� ��.�.�(�(�(�(�(�(�(����������
)����
)s �0 �
B'�A#B"�"B'N)�__name__�
__module__� __qualname__�__doc__� __slots__r r
�intr r r r �listr" r r r r r, � r r r r
s� � � � � � �:�:�;�I�
� �:
� 2� 2�"�2� �2� ��Z� 0�#� 5�6� 2� 2� 2� 2�(
��
�
�
�
�)��2�y��|�+�,�)�4<�j�\�3�=N�4O�)�
�)� )� )� )� )� )r r N)�asyncior �typingr r r r r r r
�redis.exceptionsr r r
�
redis.backoffr r r r4 r r �<module>r9 s� �� � � � � � � P� P� P� P� P� P� P� P� P� P� P� P� P� P� P� P� P� P� F� F� F� F� F� F� F� F� F� F�� .�-�-�-�-�-�-� �G�C�L�L��6)� 6)� 6)� 6)� 6)� 6)� 6)� 6)� 6)� 6)r