o /i@sddlZddlZddlmZddlmZmZmZmZm Z m Z m Z m Z m Z ddlmZmZe dZe deddZer?dd lmZGd d d eeejZGd d d eeZdS)N)sleep) TYPE_CHECKINGAnyCallableGenericIterableOptionalTupleTypeTypeVar)ConnectionError TimeoutErrorTET)bound covariant)AbstractBackoffc@seZdZUdZeeedfed<dddedeeedffdd Z e j d e d e fd d Zd efddZdeeed dfddZd efddZded dfddZdS) AbstractRetryz0Retry a specific number of times after a failure._supported_errorsbackoffrretriessupported_errorscCs||_||_||_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_retriesrselfrrrrK/var/www/html/flask_server/venv/lib/python3.10/site-packages/redis/retry.py__init__s  zAbstractRetry.__init__otherreturncCstSN)NotImplementedrrrrr__eq__/szAbstractRetry.__eq__cCst|j|jt|jfSr!)hashrr frozensetrrrrr__hash__3szAbstractRetry.__hash__specified_errorsNcCstt|jt||_dS)zM Updates the supported errors with the specified error types N)tuplesetr)rr)rrrupdate_supported_errors6s z%AbstractRetry.update_supported_errorscCs|jS)z, Get the number of retries. rr'rrr get_retries>szAbstractRetry.get_retriesvaluecCs ||_dS)z, Set the number of retries. Nr-)rr/rrrupdate_retriesDs zAbstractRetry.update_retries)__name__ __module__ __qualname____doc__r r r__annotations__intrabcabstractmethodrboolr$r(rr,r.r0rrrrrs  rc seZdZejZeeejffddde de e e dfffdd Z ded efd d Z dd egefdee gefdeee gefd efddZZS)Retryrrrr.cst|||dSr!)superrr __class__rrrNs zRetry.__init__rr cCs:t|tstS|j|jko|j|jkot|jt|jkSr!) isinstancer:r"rrr+rr#rrrr$Zs   z Retry.__eq__Ndofail is_retryablec Cs|jd} z|WS|jyH}z/|r||s|d7}|||jdkr0||jkr0||j|}|dkr>t|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@rAfailureserrorrrrrcall_with_retryds$   zRetry.call_with_retryr!)r1r2r3rr(r r sockettimeoutr6r r Exceptionrrr9r$rrrrG __classcell__rrr<rr:Ks0   r:)r7rHtimertypingrrrrrrr r r redis.exceptionsr r rrJr redis.backoffrABCrr:rrrrs ,  2