g+~ddlZddlZddlZddlZddlZdZdZdZGddeZ GddeZ Gd d e Z y) Ni?cfd}|S)Nct|SN) isinstance) exceptionretryable_typess E/var/www/dash_apps/app1/venv/lib/python3.12/site-packages/retrying.py_retry_if_exception_these_typeszD_retry_if_exception_of_type.._retry_if_exception_these_typess)_55)rr s` r _retry_if_exception_of_typer s6 +*r cjtdk(rtdrd}|dSfd}|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 rcBtjfd}|S)Nc@tjg|i|SrRetryingcall)argskwfs r wrapped_fz-retry..wrap_simple..wrapped_f+s &xzq646266r sixwraps)rrs` r wrap_simplezretry..wrap_simple*s% YYq\ 7 7 r cHtjfd}|S)NcBtijg|i|Srr)rrdargsdkwrs r rz&retry..wrap..wrapped_f6s*3x.#.33ACCCCr r)rrrr s` r wrapzretry..wrap5s' YYq\ D D r )lencallable)rr rr!s`` r retryr$!s= 5zQ8E!H- 58$$  r ceZdZ ddZdZdZedZdZdZ dZ d Z ed Z ed Z d Zd Zy)rNc|dn||_|dn||_|dn||_|dn||_|dn||_|dn||_| dn| |_| dn| |_| tn| |_ | tn| |_ |dn||_ ||_ ||_ g|j|j|j|j |||_n| fd|_nt%|||_dg|j|j&||j|j(|| j|j*| | j|j,|||_n| fd|_nt%|||_| |j0|_n"t5| t6r t9| } | |_||j:|_||_y||_||_y) Ndrrc2tfdDS)Nc30K|] }|ywrr .0rattemptsdelays r z6Retrying.__init__....4'((E"4)any)r.r/ stop_funcss``r z#Retrying.__init__..4,641r cy)Nrr )rkwargss r r5z#Retrying.__init__..sr c2tfdDS)Nc30K|] }|ywrr r,s r r0z6Retrying.__init__....r1r2)max)r.r/ wait_funcss``r r5z#Retrying.__init__..r6r ) _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)selfrNrTstop_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_attemptsr4r<s @@r __init__zRetrying.__init__@s]2)0A6M %'5&= stop_max_attempt_number.)r=r[previous_attempt_numberdelay_since_first_attempt_mss r rLzRetrying.stop_after_attempts&$*G*GGGr c ||jk\S)z=Stop after the time from the first attempt >= stop_max_delay.)r>rps r rMzRetrying.stop_after_delays+t/C/CCCr cy)z#Don't sleep at all before retrying.rr )rqrrs r no_sleepzRetrying.no_sleepsr c|jS)z0Sleep a fixed amount of time between each retry.)r?rps r rPzRetrying.fixed_sleepsr cVtj|j|jS)zISleep a random amount of time between wait_random_min and wait_random_max)randomrandintr@rArps r rQzRetrying.random_sleeps~~d33T5J5JKKr c|j|j|dz zz}||jkDr |j}|dkrd}|S)z Sleep an incremental amount of time after each attempt, starting at wait_incrementing_start and incrementing by wait_incrementing_increment rr)rBrCrG)r[rqrrresults r rRzRetrying.incrementing_sleepsT ..  - -1H11L M  D// /00F A:F r crd|z}|j|z}||jkDr |j}|dkrd}|S)Nr)rDrF)r[rqrrexpr{s r rSzRetrying.exponential_sleepsG((22S8 D.. .//F A:F r cy)NFr r{s r rXzRetrying.never_rejectsr cy)NTr rs r rUzRetrying.always_rejectsr cd}|jr#||j|jdz}|S||j|jz}|S)NFr) has_exceptionrVvaluerY)r[attemptrejects r should_rejectzRetrying.should_rejectsU  d..w}}Q/?@ @F  d++GMM: :F r c\tttjdz}d} |jr|j| t ||i||d}|j|s|j|jS|jr|j|tttjdz|z }|j||r3|js|jr|jt||j||} |jr0t!j |jz} | t#d| z} tj$| dz |dz }X#t j }t ||d}YMxYw)Nr)rTFrg@@)introundtimerIAttemptsysexc_inforgetrZrJrNr RetryErrorrTrHrxr;sleep) r[fnrr8 start_timeattempt_numberrtbrrrjitters r rz Retrying.callsjtyy{T123 $$%%n5 <!"d"5f"5~uM %%g.{{4#7#788##$$^4+.uTYY[45G/H+IJ+V (yy)EF++0E0E!++-'$W-- .2NO((#]]_t/D/DDF!C6N2E 56>* a N=  <\\^!"nd;s F#F+)NNNNNNNNNNNNNNFNNNNN)__name__ __module__ __qualname__rnrLrM staticmethodrurPrQrRrSrXrUrrr r r rr?s  $ $$("$(!+t.lHD L ! r rc$eZdZdZdZddZdZy)rz 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. c.||_||_||_yr)rrr)r[rrrs r rnzAttempt.__init__s ,*r c|jrL|r t|tj|jd|jd|jdy|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. rrr}N)rrrreraiser)r[rhs r rz Attempt.get#sM    && DJJqM4::a=$**Q-H:: r c |jrKdj|jdjt j |j dSdj|j|j S)NzAttempts: {0}, Error: {1}r}zAttempts: {0}, Value: {1})rformatrjoin traceback format_tbrr[s r __repr__zAttempt.__repr__1sd   /66##RWWY-@-@A-O%P /55d6I6I4::V Vr N)F)rrr__doc__rnrrr r r rrs + Wr rceZdZdZdZdZy)rzU A RetryError encapsulates the last Attempt instance right before giving up. c||_yr) last_attempt)r[rs r rnzRetryError.__init__?s (r c8dj|jS)NzRetryError[{0}])rrrs r __str__zRetryError.__str__Bs ''(9(9::r N)rrrrrnrr r r rr:s);r r) rxrrrrrEr r$objectrr Exceptionrr r r rsQ  +