o

$we�@s6dd
lZddl
mZ
ddlmZmZ
Gdd�d�Zd
S)�N)
�sleep)�ConnectionError�TimeoutErrorc@s:eZ
dZd
Zeeejff
dd�
Zde	fdd�Z
dd�Zd	S)
�Retryz0Retry a specific number of times after a failurecCs|
|_||_
||_d
S)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)�self�backoff�retries�supported_errors�r
�D/home/arjun/projects/env/lib/python3.10/site-packages/redis/retry.py�__init__
s



zRetry.__init__�specified_errorscCstt
|jt|
�
�
�
|_d
S)zM
        Updates the supported errors with the specified error types
        N)�tuple�setr)r	rr
r
r�update_supported_errorss

�zRetry.update_supported_errorsc
Cs�|j�
�
d
}	z|
�WS|jyA
}
z(|d7}||�

|jd
kr)||jkr)|�
|j�|�
}|d
kr7t|�

WYd}~nd}~w
wq)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�resetrr�computer)r	�do�fail�failures�errorr
r
r
r�call_with_retry#s 












���zRetry.call_with_retryN)�__name__�
__module__�__qualname__�__doc__rr�socket�timeoutr�listrrr
r
r
rrs


�r)r �timer�redis.exceptionsrrrr
r
r
r�<module>
s