a %gh/@sddlZddlZddlZddlZddlZddlmZdZddZddZ da da dd d Z Gd d d e ZGd dde ZGdddeZdS)Nwrapsi?csfdd}|S)Ncs t|SN) isinstance) exceptionretryable_typesX/mounts/lovelace/software/anaconda3/envs/metaDMG/lib/python3.9/site-packages/retrying.py_retry_if_exception_these_typesszD_retry_if_exception_of_type.._retry_if_exception_these_typesr )rr r rr _retry_if_exception_of_types r csBtdkr,tdr,dd}|dSfdd}|SdS)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|SrRetryingcallargskwfr r wrapped_f*sz-retry..wrap_simple..wrapped_frrrr rr wrap_simple)szretry..wrap_simplecstfdd}|S)Ncs"tijg|Ri|Srrr)dargsdkwrr r r5sz&retry..wrap..wrapped_frrrrrr wrap4szretry..wrapN)lencallable)rrrrr rr retry s  rFcCsJ|dvrBtdurtta|dur>ts>dattdt_tS|SdS)N)TNTF)_default_loggerlogging getLogger__name___configured_null_logger addHandler NullHandler propagate)loggerr r r _pick_logger@s  r)c@szeZdZdddZddZddZed d Zd d Zd dZ ddZ ddZ eddZ eddZ ddZddZdS)rNFcsP|dur dn||_|durdn||_|dur0dn||_|durBdn||_|durTdn||_|durfdn||_| durxdn| |_| durdn| |_| durtn| |_ | durtn| |_ |durdn||_ ||_ ||_ t||_g|dur|j|dur |j|dur||_n&|dur6fdd|_n t|||_ddg|durb|j|dusv|dur|j|dus| dur|j| dus| durˆ|j|dur||_n&|durfd d|_n t|||_| dur|j|_nt| ttfr&t| } | |_|dur@|j |_!n||_!||_"dS) Ndrr cstfddDS)Nc3s|]}|VqdSrr .0rZattemptsdelayr r s6Retrying.__init__....)anyr/) stop_funcsr/r sz#Retrying.__init__..c_sdS)Nrr )rkwargsr r r r5cstfddDS)Nc3s|]}|VqdSrr r-r/r r r1sr2)maxr/) wait_funcsr/r r5s)#_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_attemptsr)_loggerappendstop_after_attemptstop_after_delaystopgetattr fixed_sleep random_sleepincrementing_sleepexponential_sleepwait always_reject_retry_on_exceptionrtuple Exceptionr never_reject_retry_on_result_wrap_exception)selfrLrRZstop_max_attempt_numberZstop_max_delayZ wait_fixedZwait_random_minZwait_random_maxZwait_incrementing_startZwait_incrementing_incrementZwait_incrementing_maxZwait_exponential_multiplierZwait_exponential_maxZretry_on_exceptionZretry_on_resultwrap_exceptionZ stop_funcZ wait_funcZwait_jitter_maxZbefore_attemptsZafter_attemptsr(r )r4r9r __init__Ssp                    zRetrying.__init__cCs ||jkS)z;Stop after the previous attempt >= stop_max_attempt_number.)r:rZprevious_attempt_numberdelay_since_first_attempt_msr r r rJszRetrying.stop_after_attemptcCs ||jkS)z=Stop after the time from the first attempt >= stop_max_delay.)r;r]r r r rKszRetrying.stop_after_delaycCsdS)z#Don't sleep at all before retrying.rr )r^r_r r r no_sleepszRetrying.no_sleepcCs|jS)z0Sleep a fixed amount of time between each retry.)r<r]r r r rNszRetrying.fixed_sleepcCst|j|jS)zISleep a random amount of time between wait_random_min and wait_random_max)randomrandintr=r>r]r r r rOszRetrying.random_sleepcCs4|j|j|d}||jkr$|j}|dkr0d}|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@rD)rZr^r_resultr r r rPs  zRetrying.incrementing_sleepcCs2d|}|j|}||jkr"|j}|dkr.d}|S)Nr)rArC)rZr^r_exprcr r r rQs  zRetrying.exponential_sleepcCsdS)NFr rcr r r rWszRetrying.never_rejectcCsdS)NTr rfr r r rSszRetrying.always_rejectcCs4d}|jr |||jdO}n|||jO}|S)NFr ) has_exceptionrTvaluerX)rZattemptZrejectr r r should_rejects zRetrying.should_rejectc OsFtttd}d}|jr(||zt||i||d}Wn&tyht}t||d}Yn0||s| |j S|j ||j r| |tttd|}|||r|j s|jr| nt|nX|||} |jrt|j} | td| } |j d| ddd t| d|d7}qdS) Nr,r FTrz Retrying in g@@z.2fz seconds.)introundtimerFAttemptrVsysexc_inforjgetrYrHwarningrGrLrg RetryErrorrRrErar8infosleep) rZfnrr6 start_timeattempt_numberritbr_ruZjitterr r r r s4           z Retrying.call)NNNNNNNNNNNNNNFNNNNNN)r# __module__ __qualname__r\rJrK staticmethodr`rNrOrPrQrWrSrjrr r r r rRsH y     rc@s*eZdZdZddZd ddZddZd S) rnz 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)rhrxrg)rZrhrxrgr r r r\6szAttempt.__init__FcCs6|jr,|rt|q2|j\}}}||n|jSdS)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. N)rgrsrhwith_traceback)rZr[exc_typeexcryr r r rq;s    z Attempt.getc CsB|jr*d|jddt|jdSd|jd|jSdS)Nz Attempts: z , Error: rdz , Value: )rgrxjoin traceback format_tbrhrZr r r __repr__Js$zAttempt.__repr__N)F)r#rzr{__doc__r\rqrr r r r rn/s rnc@s eZdZdZddZddZdS)rszU A RetryError encapsulates the last Attempt instance right before giving up. cCs ||_dSr last_attempt)rZrr r r r\VszRetryError.__init__cCsd|jdS)Nz RetryError[]rrr r r __str__YszRetryError.__str__N)r#rzr{rr\rr r r r rsQsrs)N)r!rarormr functoolsrrBr rr r$r)objectrrnrVrsr r r r s  ^"