hXddlmZddlmZmZmZmZmZmZm Z ddl m Z m Z m Z ddlmZe dZerddlmZGddee Zy ) )sleep) TYPE_CHECKINGAny AwaitableCallableTupleTypeTypeVar)ConnectionError RedisError TimeoutError) AbstractRetryT)AbstractBackoffc eZdZejZeeffdddedee e dfffd Z de de fd Zd egeefd ee ge fdefd ZxZS) Retrybackoffrretriessupported_errors.c(t||||yN)super__init__)selfrrr __class__s u/var/www/fastuser/data/www/generator.snapmosaic.io/flask_app/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)rrs r__eq__z Retry.__eq__sc%'! ! MMU^^ + L / LD**+s53J3J/KK rdofailcvK|jjd} |d{S7#|j$rt}|dz }||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 rN)r#resetr&r$computer)rr(r)failureserrorrs rcall_with_retryzRetry.call_with_retry%s  )Tz!z)) )A 5k!!==A%(T]]*BK--//9Q;.(( )sPB9 202B92B5B0AAB0%B(&B0+B90B55B9)__name__ __module__ __qualname__r__hash__r r intrr r rrboolr'rrrr0 __classcell__)rs@rrr s%%H  : =" = = Z 0# 56 = C D )2y|+,)4r>s:PPPFF% CL--)M* %-)r