o ChX@sddlmZddlmZmZmZmZmZmZm Z ddl m Z m Z m Z ddlmZe dZer4ddlmZGdddee Zd S) )sleep) TYPE_CHECKINGAny AwaitableCallableTupleTypeTypeVar)ConnectionError RedisError TimeoutError) AbstractRetryT)AbstractBackoffc seZdZejZeeffdddedee e dfffdd Z de d e fd d Zd egeefd ee ge fd efddZZS)Retrybackoffrretriessupported_errors.cst|||dSN)super__init__)selfrrr __class__e/var/www/html/myvaluetrips/my_value_trip_new/venv/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__dofailc 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)r resetr#r!computer)rr%r&failureserrorrrrrcall_with_retry%s"  zRetry.call_with_retry)__name__ __module__ __qualname__r __hash__r r intrrr rrboolr$rrrr, __classcell__rrrrr s(   rN)asynciortypingrrrrrrr redis.exceptionsr r r redis.retryr r redis.backoffrrrrrrs $