PfddlmZddlmZmZmZmZmZmZm Z ddl m Z m Z m Z erddlmZe dZGddZdS) )sleep) TYPE_CHECKINGAny AwaitableCallableTupleTypeTypeVar)ConnectionError RedisError TimeoutError)AbstractBackoffTc eZdZdZdZeeffdddedee e dffdZ d e fd Z d egeefd ee gefd efdZdS)Retryz0Retry a specific number of times after a failure_backoff_retries_supported_errorsbackoffrretriessupported_errors.c0||_||_||_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. Nr)selfrrrs E/var/www/html/env/lib/python3.11/site-packages/redis/asyncio/retry.py__init__zRetry.__init__s    !1specified_errorscrtt|jt|z|_dS)zM Updates the supported errors with the specified error types N)tuplesetr)rrs rupdate_supported_errorszRetry.update_supported_errors&s8"' &/?)@)@@ A A" " rdofailreturncVK|jd} |d{VS#|j$rm}|dz }||d{V|jdkr ||jkr||j|}|dkrt |d{VYd}~nd}~wwxYw)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$failureserrorrs rcall_with_retryzRetry.call_with_retry.s  ) )RTTzzzzzz!) ) ) )A d5kk!!!!!!!=A%%(T]*B*BK-//99Q;;..((((((( ) )s0 B'A#B""B'N)__name__ __module__ __qualname____doc__ __slots__r r intrr r rlistr"rrrrr,rrrr s::;I  : 22"22 Z 0# 56 2222(     )2y|+,)4r9sPPPPPPPPPPPPPPPPPPFFFFFFFFFF.------ GCLL6)6)6)6)6)6)6)6)6)6)r