PfddlZddlmZddlmZmZmZmZmZm Z m Z ddl m Z m Z e dZerddlmZGddZdS) N)sleep) TYPE_CHECKINGAnyCallableIterableTupleTypeTypeVar)ConnectionError TimeoutErrorT)AbstractBackoffc eZdZdZeeejffdddede e e dffdZ de e e d d fd Zd egefd ee gefd efdZd S)Retryz0Retry a specific number of times after a failurebackoffrretriessupported_errors.c0||_||_||_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)selfrrrs =/var/www/html/env/lib/python3.11/site-packages/redis/retry.py__init__zRetry.__init__s "   !1specified_errorsreturnNcrtt|jt|z|_dS)zM Updates the supported errors with the specified error types N)tuplesetr)rrs rupdate_supported_errorszRetry.update_supported_errors%s8 "' &/?)@)@@ A A" " rdofailc.|jd} |S#|j$ra}|dz }|||jdkr ||jkr||j|}|dkrt |Yd}~nd}~wwxYwz)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)rresetrrcomputer)rr"r#failureserrorrs rcall_with_retryzRetry.call_with_retry/s  # #rtt ) # # #A U =A%%(T]*B*BK-//99Q;;'NNN # #s ( BABB)__name__ __module__ __qualname____doc__r r sockettimeoutintrr Exceptionrrr!rr rr*rrrr s::   N9 22"22 Y 45 2222* (i 9     # RUO# {C'(# ######rr)r/timertypingrrrrrr r redis.exceptionsr r r redis.backoffrrr3rrr8s OOOOOOOOOOOOOOOOOO:::::::: GCLL.------9#9#9#9#9#9#9#9#9#9#r