,iddlZddlZddlmZddlmZmZmZmZm Z m Z m Z m Z m Z ddlmZmZe dZe dedZerdd lmZGd d eeej,ZGd d eeZy)N)sleep) TYPE_CHECKINGAnyCallableGenericIterableOptionalTupleTypeTypeVar)ConnectionError TimeoutErrorTET)bound covariant)AbstractBackoffceZdZUdZeeedfed<dddedeeedffdZ e jd e d e fd Zd efd Zd eeed dfdZd efdZded dfdZy) AbstractRetryz0Retry a specific number of times after a failure._supported_errorsbackoffrretriessupported_errorsc.||_||_||_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_retriesr)selfrrrs P/var/www/html/langgraph-service/venv/lib/python3.12/site-packages/redis/retry.py__init__zAbstractRetry.__init__s   !1otherreturnctSN)NotImplementedrr!s r__eq__zAbstractRetry.__eq__/sr clt|j|jt|jfSr$)hashrr frozensetrrs r__hash__zAbstractRetry.__hash__3s'T]]DMM9T=S=S3TUVVr specified_errorsNcbtt|jt|z|_y)zM Updates the supported errors with the specified error types N)tuplesetr)rr-s rupdate_supported_errorsz%AbstractRetry.update_supported_errors6s*"' &&/?)@@ A" r c|jS)z, Get the number of retries. rr+s r get_retrieszAbstractRetry.get_retries>s}}r valuec||_y)z, Set the number of retries. Nr3)rr5s rupdate_retrieszAbstractRetry.update_retriesDs  r )__name__ __module__ __qualname____doc__r r r__annotations__intrabcabstractmethodrboolr'r,rr1r4r7r rrrs:T!Wc\**2"22 Q - 2" CDW#W a8I d S CDr rc eZdZejZeeejffddde de e e dfffd Z dedefd Z dd egefd ee gefd eee gefdefd ZxZS)Retryrrrr.c(t||||yr$)superr)rrrr __class__s rrzRetry.__init__Ns '+;rStimertypingrrrrrr r r r redis.exceptionsr rrrUr redis.backoffrABCrrCrAr rr\sg    ; CL CyD1-/GAJ/d3#M) $3#r