o >h @snddlmZddlmZmZmZmZmZmZm Z ddl m Z m Z m Z er*ddlmZe dZGdddZdS) )sleep) TYPE_CHECKINGAny AwaitableCallableTupleTypeTypeVar)ConnectionError RedisError TimeoutError)AbstractBackoffTc @seZdZdZdZeeffdddedee e dffdd Z d e fd d Z d efddZded dfddZdegeefdee gefd efddZdS)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)selfrrrrs/var/www/vedio/testing/chatpythonscript.ninositsolution.com/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_errorsreturncCs|jS)z, Get the number of retries. r)rrrr get_retries.szRetry.get_retriesvalueNcCs ||_dS)z, Set the number of retries. Nr )rr"rrrupdate_retries4s zRetry.update_retriesdofailc 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)rr$r%failureserrorrrrrcall_with_retry:s"  zRetry.call_with_retry)__name__ __module__ __qualname____doc__ __slots__r r intrrr rlistrr!r#rrrrr+rrrrr s.  rN)asynciortypingrrrrrrr redis.exceptionsr r r redis.backoffr rrrrrrs $