o ChM @sddlZddlZddlmZddlmZmZmZmZm Z m Z m Z m Z ddl mZmZe dZe deddZer=dd lmZGd d d eeejZGd d d eeZdS)N)sleep) TYPE_CHECKINGAnyCallableGenericIterableTupleTypeTypeVar)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_retriesrselfrrrr]/var/www/html/myvaluetrips/my_value_trip_new/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__)szAbstractRetry.__hash__specified_errorsNcCstt|jt||_dS)zM Updates the supported errors with the specified error types N)tuplesetr)rr(rrrupdate_supported_errors,s z%AbstractRetry.update_supported_errorscCs|jS)z, Get the number of retries. rr&rrr get_retries4szAbstractRetry.get_retriesvaluecCs ||_dS)z, Set the number of retries. Nr,)rr.rrrupdate_retries:s zAbstractRetry.update_retries)__name__ __module__ __qualname____doc__rr r__annotations__intrabcabstractmethodrboolr#r'rr+r-r/rrrrrs  rc seZdZejZeeejffddde de e e dfffdd Z ded efd d Zd egefd ee gefd efddZZS)Retryrrrr.cst|||dSr )superrr __class__rrrDs zRetry.__init__rrcCs:t|tstS|j|jko|j|jkot|jt|jkSr ) isinstancer9r!rrr*rr"rrrr#Ps   z Retry.__eq__dofailc 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_retryZs  zRetry.call_with_retry)r0r1r2rr'r r sockettimeoutr5rr Exceptionrrr8r#rr rE __classcell__rrr;rr9As*   r9)r6rFtimertypingrrrrrrr r redis.exceptionsr r r rHr redis.backoffrABCrr9rrrrs ( 2