o hV @srddlZddlmZddlmZmZmZmZmZm Z m Z ddl m Z m Z e dZer0ddlmZGdddZdS) N)sleep) TYPE_CHECKINGAnyCallableIterableTupleTypeTypeVar)ConnectionError TimeoutErrorT)AbstractBackoffc @seZdZdZeeejffdddede e e dffddZ d e d efd d Zd efd dZdee e d dfddZd efddZded dfddZdegefdee ge fd efddZdS)Retryz0Retry a specific number of times after a failurebackoffr retriessupported_errors.cCs||_||_||_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)selfrrrrM/var/www/html/optinet_system/venv/lib/python3.10/site-packages/redis/retry.py__init__s zRetry.__init__otherreturncCs:t|tstS|j|jko|j|jkot|jt|jkSN) isinstancerNotImplementedrrsetr)rrrrr__eq__%s   z Retry.__eq__cCst|j|jt|jfSr)hashrr frozensetrrrrr__hash__/szRetry.__hash__specified_errorsNcCstt|jt||_dS)zM Updates the supported errors with the specified error types N)tuplerr)rr$rrrupdate_supported_errors2s zRetry.update_supported_errorscCs|jS)z, Get the number of retries. rr"rrr get_retries<szRetry.get_retriesvaluecCs ||_dS)z, Set the number of retries. Nr')rr)rrrupdate_retriesBs zRetry.update_retriesdofailc Cs|jd} z|WS|jyA}z(|d7}|||jdkr)||jkr)||j|}|dkr7t|WYd}~nd}~wwq)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 rTN)rresetrrcomputer)rr+r,failureserrorrrrrcall_with_retryHs  zRetry.call_with_retry)__name__ __module__ __qualname____doc__r r sockettimeoutintrr Exceptionrrboolrr#rr&r(r*rr r2rrrrr s:       r)r7timertypingrrrrrrr redis.exceptionsr r r redis.backoffr rrrrrs $