o h@snddlmZddlmZmZmZmZmZmZm Z ddl m Z m Z m Z er*ddlmZe dZGdddZdS) )sleep) TYPE_CHECKINGAny AwaitableCallableTupleTypeTypeVar)ConnectionError RedisError TimeoutError)AbstractBackoffTc @sxeZdZdZdZeeffdddedee e dffdd Z d e fd d Z d egeefdee gefdefddZdS)Retryz0Retry a specific number of times after a failure_backoff_retries_supported_errorsbackoffr 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. Nr)selfrrrrE/var/www/html/env/lib/python3.10/site-packages/redis/asyncio/retry.py__init__s zRetry.__init__specified_errorscCstt|jt||_dS)zM Updates the supported errors with the specified error types N)tuplesetr)rrrrrupdate_supported_errors&s zRetry.update_supported_errorsdofailreturnc s|jd} z|IdHWS|jyK}z.|d7}||IdH|jdkr0||jkr0||j|}|dkrAt|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 rTN)rresetrrcomputer)rrr failureserrorrrrrcall_with_retry.s"  zRetry.call_with_retryN)__name__ __module__ __qualname____doc__ __slots__r r intrrr rlistrrrrrr'rrrrr s*  rN)asynciortypingrrrrrrr redis.exceptionsr r r redis.backoffr rrrrrrs $