o ¼>hV ã@srddlZddlmZddlmZmZmZmZmZm Z m Z ddl m Z m Z e dƒZer0ddlmZGdd„dƒZdS) éN)Úsleep)Ú TYPE_CHECKINGÚAnyÚCallableÚIterableÚTupleÚTypeÚTypeVar)ÚConnectionErrorÚ TimeoutErrorÚT)ÚAbstractBackoffc @sÀeZdZdZeeejffdddede e e dffdd„Z d e d efd d „Zd efd d„Zdee e d dfdd„Zd efdd„Zded dfdd„Zdegefdee ge fd efdd„ZdS)ÚRetryz0Retry a specific number of times after a failureÚbackoffr ÚretriesÚsupported_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. N)Ú_backoffÚ_retriesÚ_supported_errors)Úselfrrr©rúk/var/www/vedio/testing/chatpythonscript.ninositsolution.com/env/lib/python3.10/site-packages/redis/retry.pyÚ__init__s zRetry.__init__ÚotherÚreturncCs:t|tƒstS|j|jko|j|jkot|jƒt|jƒkS©N)Ú isinstancerÚNotImplementedrrÚsetr)rrrrrÚ__eq__%s   ÿýz Retry.__eq__cCst|j|jt|jƒfƒSr)ÚhashrrÚ frozensetr©rrrrÚ__hash__/szRetry.__hash__Úspecified_errorsNcCstt|jt|ƒƒƒ|_dS)zM Updates the supported errors with the specified error types N)Útuplerr)rr$rrrÚupdate_supported_errors2s ÿzRetry.update_supported_errorscCs|jS)z, Get the number of retries. ©rr"rrrÚ get_retries<szRetry.get_retriesÚvaluecCs ||_dS)z, Set the number of retries. Nr')rr)rrrÚupdate_retriesBs zRetry.update_retriesÚdoÚfailc Cs†|j ¡d} 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 rTéN)rÚresetrrÚcomputer)rr+r,ÚfailuresÚerrorrrrrÚcall_with_retryHs  €ùýzRetry.call_with_retry)Ú__name__Ú __module__Ú __qualname__Ú__doc__r r ÚsocketÚtimeoutÚintrrÚ ExceptionrrÚboolrr#rr&r(r*rr r2rrrrr s:ýüþý ü  ÿ þ  þ ýür)r7ÚtimerÚtypingrrrrrrr Úredis.exceptionsr r r Ú redis.backoffr rrrrrÚs $