۾hV ddlZddlmZddlmZmZmZmZmZm Z m Z ddl m Z m Z e dZerddlmZGddZy) N)sleep) TYPE_CHECKINGAnyCallableIterableTupleTypeTypeVar)ConnectionError TimeoutErrorT)AbstractBackoffc eZdZdZeeejffdddede e e dffdZ de d efd Zd efd Zd ee e d d fdZd efdZded d fdZdegefdee ge fd efdZy )Retryz0Retry a specific number of times after a failurebackoffrretriessupported_errors.c.||_||_||_y)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)selfrrrs G/var/www/Befach/backend/env/lib/python3.12/site-packages/redis/retry.py__init__zRetry.__init__s"   !1otherreturnct|tstS|j|jk(xrF|j|jk(xr+t |j t |j k(SN) isinstancerNotImplementedrrsetr)rrs r__eq__z Retry.__eq__%sc%'! ! MMU^^ + L / LD**+s53J3J/KK rclt|j|jt|jfSr)hashrr frozensetrrs r__hash__zRetry.__hash__/s'T]]DMM9T=S=S3TUVVrspecified_errorsNcbtt|jt|z|_y)zM Updates the supported errors with the specified error types N)tupler"r)rr)s rupdate_supported_errorszRetry.update_supported_errors2s* "' &&/?)@@ A" rc|jS)z, Get the number of retries. rr's r get_retrieszRetry.get_retries<s}}rvaluec||_y)z, Set the number of retries. Nr.)rr0s rupdate_retrieszRetry.update_retriesBs  rdofailc6|jjd} |S#|j$rb}|dz }|||jdk\r||jkDr||jj |}|dkDr t |Yd}~nd}~wwxYw})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)rresetrrcomputer)rr3r4failureserrorrs rcall_with_retryzRetry.call_with_retryHs  #t )) #A U ==A%(T]]*BK--//9Q;'N #s&BABB)__name__ __module__ __qualname____doc__r r sockettimeoutintrr Exceptionrrboolr#r(rr,r/r2rr r;rrrr s:   NN9 2"22 Y 45 2* C D W#W (i 9  S CD # RUO# {C'(# #rr)r@timertypingrrrrrr r redis.exceptionsr r r redis.backoffrrrErrrJs2 OOO: CL-R#R#r