o i @sddlmZddlmZmZmZmZmZmZm Z m Z m Z ddl m Z mZmZddlmZe dZer8ddlmZGdddeeZd S) )sleep) TYPE_CHECKINGAny AwaitableCallableOptionalTupleTypeTypeVarUnion)ConnectionError RedisError TimeoutError) AbstractRetryT)AbstractBackoffc seZdZejZeeffdddedee e dfffdd Z de d e fd d Z ddegeefdeeege feeege ffdeeege fde d ef ddZZS)Retrybackoffrretriessupported_errors.cst|||dSN)super__init__)selfrrr __class__G/home/ubuntu/.local/lib/python3.10/site-packages/redis/asyncio/retry.pyrs zRetry.__init__otherreturncCs:t|tstS|j|jko|j|jkot|jt|jkSr) isinstancerNotImplemented_backoff_retriesset_supported_errors)rrrrr__eq__%s   z Retry.__eq__NFdofail is_retryablewith_failure_countc s|jd} z|IdHWS|jy]}z@|r ||s |d7}|r/|||IdHn||IdH|jdkrB||jkrB||j|}|dkrSt|IdHWYd}~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 ``is_retryable``: optional function to determine if an error is retryable ``with_failure_count``: if True, the failure count is passed to the failure handler rTN)r"resetr%r#computer)rr'r(r)r*failureserrorrrrrcall_with_retry/s*   zRetry.call_with_retry)NF)__name__ __module__ __qualname__r__hash__r rintrr r rrboolr&rrrr Exceptionrr0 __classcell__rrrrrs<   rN)asynciortypingrrrrrrr r r redis.exceptionsr r r redis.retryrr redis.backoffrrrrrrs ,