j ddlmZddlmZmZmZmZmZmZm Z m Z m Z ddl m Z mZmZddlmZe dZerddlmZGddeeZy ) )sleep) TYPE_CHECKINGAny AwaitableCallableOptionalTupleTypeTypeVarUnion)ConnectionError RedisError TimeoutError) AbstractRetryT)AbstractBackoffc eZdZejZeeffdddedee e dfffd Z de de fd Z dd egeefd eeege feeege ffd eeege fd e def dZxZS)Retrybackoffrretriessupported_errors.c(t||||yN)super__init__)selfrrr __class__s ]/var/www/html/Fitness-lenito-AI-main/venv/lib/python3.12/site-packages/redis/asyncio/retry.pyrzRetry.__init__s '+;<otherreturnct|tstS|j|jk(xrF|j|jk(xr+t |j t |j k(Sr) isinstancerNotImplemented_backoff_retriesset_supported_errors)rr s r__eq__z Retry.__eq__%sc%'! ! MMU^^ + L / LD**+s53J3J/KK rdofail is_retryablewith_failure_countcK|jjd} |d{S7#|j$r}|r ||s|dz }|r|||d{7n||d{7|jdk\r||jkDr||jj |}|dkDrt |d{7Yd}~nd}~wwxYww)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 ``is_retryable``: optional function to determine if an error is retryable ``with_failure_count``: if True, the failure count is passed to the failure handler rN)r%resetr(r&computer)rr*r+r,r-failureserrorrs rcall_with_retryzRetry.call_with_retry/s$  )Tz!z)) ) U(;A %uh///u+%%==A%(T]]*BK--//9Q;.(( )s\C 202C2CCA" C1A42ACCC CCC)NF)__name__ __module__ __qualname__r__hash__r rintr r rrrboolr)rrrr Exceptionrr4 __classcell__)rs@rrrs%%H  : =" = = Z 0# 56 = C D "?C#(%) R1% &%) i[#% & i%s* + - %)x T(9:;%)!%) %)rrN)asynciortypingrrrrrr r r r redis.exceptionsr rr redis.retryrr redis.backoffrrrrrCsC   GF% CL-=)M* %=)r