o d+@spddlZddlZddlZddlZddlZdZddZddZGdddeZ Gd d d eZ Gd d d e Z dS) Ni?csfdd}|S)Ncs t|SN) isinstance) exceptionretryable_typesM/var/www/html/visualizacion-main/env/lib/python3.10/site-packages/retrying.py_retry_if_exception_these_types zD_retry_if_exception_of_type.._retry_if_exception_these_typesr)rr rrr_retry_if_exception_of_types r cs>tdkrtdrdd}|dSfdd}|S)z Decorator function that instantiates the Retrying object @param *dargs: positional arguments passed to Retrying object @param **dkw: keyword arguments passed to the Retrying object rcstfdd}|S)Ncstjg|Ri|SrRetryingcallargskwfrr wrapped_f+sz-retry..wrap_simple..wrapped_fsixwrapsrrrrr wrap_simple*szretry..wrap_simplecstfdd}|S)Ncs"tijg|Ri|Srr r)dargsdkwrrrr6s"z&retry..wrap..wrapped_frrrrrrwrap5szretry..wrap)lencallable)rrrrrrrretry!s  r!c@seZdZ                    dddZddZddZed d Zd d Zd dZ ddZ ddZ eddZ eddZ ddZddZdS)rNFcs&|durdn||_|durdn||_|durdn||_|dur!dn||_|dur*dn||_|dur3dn||_| dur  6Retrying.__init__....)anyr)) stop_funcsr)rz#Retrying.__init__..c_dS)Nrr)rkwargsrrrr1scr%)Nc3r&rrr'r)rrr,r-r.)maxr)) wait_funcsr)rr1r2) _stop_max_attempt_number_stop_max_delay _wait_fixed_wait_random_min_wait_random_max_wait_incrementing_start_wait_incrementing_increment_wait_exponential_multiplierMAX_WAIT_wait_exponential_max_wait_incrementing_max_wait_jitter_max_before_attempts_after_attemptsappendstop_after_attemptstop_after_delaystopgetattr fixed_sleep random_sleepincrementing_sleepexponential_sleepwait always_reject_retry_on_exceptionrtupler never_reject_retry_on_result_wrap_exception)selfrHrNstop_max_attempt_numberstop_max_delay wait_fixedwait_random_minwait_random_maxwait_incrementing_startwait_incrementing_incrementwait_incrementing_maxwait_exponential_multiplierwait_exponential_maxretry_on_exceptionretry_on_resultwrap_exception stop_func wait_funcwait_jitter_maxbefore_attemptsafter_attemptsr)r0r6r__init__@sn              zRetrying.__init__cCs ||jkS)z;Stop after the previous attempt >= stop_max_attempt_number.)r7rUprevious_attempt_numberdelay_since_first_attempt_msrrrrF zRetrying.stop_after_attemptcCs ||jkS)z=Stop after the time from the first attempt >= stop_max_delay.)r8rirrrrGrlzRetrying.stop_after_delaycCr3)z#Don't sleep at all before retrying.rr)rjrkrrrno_sleepszRetrying.no_sleepcCs|jS)z0Sleep a fixed amount of time between each retry.)r9rirrrrJszRetrying.fixed_sleepcCst|j|jS)zISleep a random amount of time between wait_random_min and wait_random_max)randomrandintr:r;rirrrrKszRetrying.random_sleepcCs4|j|j|d}||jkr|j}|dkrd}|S)z Sleep an incremental amount of time after each attempt, starting at wait_incrementing_start and incrementing by wait_incrementing_increment r r)r<r=rA)rUrjrkresultrrrrLs  zRetrying.incrementing_sleepcCs2d|}|j|}||jkr|j}|dkrd}|S)Nr)r>r@)rUrjrkexprprrrrMs  zRetrying.exponential_sleepcCr3)NFrrprrrrRzRetrying.never_rejectcCr3)NTrrsrrrrOrtzRetrying.always_rejectcCs6d}|jr|||jdO}|S|||jO}|S)NFr ) has_exceptionrPvaluerS)rUattemptrejectrrr should_rejects zRetrying.should_rejectc Ostttd}d} |jr||z t||i||d}Wnt}t||d}Y||s<||j S|j rD| |tttd|}| ||rd|j s`|j r`|t ||||} |jr{t|j} | td| } t| d|d7}q )Nr$r TFrg@@)introundtimerCAttemptsysexc_inforygetrTrDrHru RetryErrorrNrBrnr5sleep) rUfnrr4 start_timeattempt_numberrwtbrkrjitterrrrrs4       z Retrying.call)NNNNNNNNNNNNNNFNNNNN)__name__ __module__ __qualname__rhrFrG staticmethodrmrJrKrLrMrRrOryrrrrrr?sH v    rc@s*eZdZdZddZd ddZddZd S) r}z An Attempt encapsulates a call to a target function that may end as a normal return value from the function or an Exception depending on what occurred during the execution. cCs||_||_||_dSr)rvrru)rUrvrrurrrrhs zAttempt.__init__FcCs<|jr|r t|t|jd|jd|jddS|jS)z Return the return value of this Attempt instance or raise an Exception. If wrap_exception is true, this Attempt is wrapped inside of a RetryError before being raised. rr rqN)rurrreraiserv)rUrbrrrr#s $z Attempt.getc Cs6|jrd|jdt|jdSd|j|jS)NzAttempts: {0}, Error: {1}rqzAttempts: {0}, Value: {1})ruformatrjoin traceback format_tbrvrUrrr__repr__1s zAttempt.__repr__N)F)rrr__doc__rhrrrrrrr}s   r}c@s eZdZdZddZddZdS)rzU A RetryError encapsulates the last Attempt instance right before giving up. cCs ||_dSr) last_attempt)rUrrrrrh?r zRetryError.__init__cCs d|jS)NzRetryError[{0}])rrrrrr__str__Bs zRetryError.__str__N)rrrrrhrrrrrr:s r) rnrr~r|rr?r r!objectrr} ExceptionrrrrrsY#