o wi/@sddlZddlZddlZddlZddlZddlmZdZddZddZ da da dd d Z Gd d d e ZGd dde ZGdddeZdS)Nwrapsi?csfdd}|S)Ncs t|SN) isinstance) exceptionretryable_typesE/home/ubuntu/sommelier/.venv/lib/python3.10/site-packages/retrying.py_retry_if_exception_these_types zD_retry_if_exception_of_type.._retry_if_exception_these_typesr )rr r rr _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|SrRetryingcallargskwfr r wrapped_f*sz-retry..wrap_simple..wrapped_frrrr rr wrap_simple)szretry..wrap_simplecstfdd}|S)Ncs"tijg|Ri|Srrr)dargsdkwrr r r5s"z&retry..wrap..wrapped_frrrrrr wrap4szretry..wrap)lencallable)rrrrr rr retry s  r FcCsF|dvr!tdur tta|durtsdattdt_tS|S)N)TNTF)_default_loggerlogging getLogger__name___configured_null_logger addHandler NullHandler propagate)loggerr r r _pick_logger@s  r*c@seZdZ                     dddZddZddZed d Zd d Zd dZ ddZ ddZ eddZ eddZ ddZddZdS)rNFcs6|durdn||_|durdn||_|durdn||_|dur!dn||_|dur*dn||_|dur3dn||_| dur  6Retrying.__init__....)anyr2) stop_funcsr2r z#Retrying.__init__..c_dS)Nrr )rkwargsr r r r:scr.)Nc3r/rr r0r2r r r5r6r7)maxr2) wait_funcsr2r r:r;)#_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)selfrRrXstop_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)r )r9r?r __init__Ssl              zRetrying.__init__cCs ||jkS)z;Stop after the previous attempt >= stop_max_attempt_number.)r@r`previous_attempt_numberdelay_since_first_attempt_msr r r rP zRetrying.stop_after_attemptcCs ||jkS)z=Stop after the time from the first attempt >= stop_max_delay.)rArtr r r rQrwzRetrying.stop_after_delaycCr<)z#Don't sleep at all before retrying.rr )rurvr r r no_sleepszRetrying.no_sleepcCs|jS)z0Sleep a fixed amount of time between each retry.)rBrtr r r rTszRetrying.fixed_sleepcCst|j|jS)zISleep a random amount of time between wait_random_min and wait_random_max)randomrandintrCrDrtr r r rUszRetrying.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 rr)rErFrJ)r`rurvresultr r r rVs  zRetrying.incrementing_sleepcCs2d|}|j|}||jkr|j}|dkrd}|S)Nr)rGrI)r`rurvexpr{r r r rWs  zRetrying.exponential_sleepcCr<)NFr r{r r r r]zRetrying.never_rejectcCr<)NTr r~r r r rYrzRetrying.always_rejectcCs6d}|jr|||jdO}|S|||jO}|S)NFr) has_exceptionrZvaluer^)r`attemptrejectr r r should_rejects zRetrying.should_rejectc Os>tttd}d} |jr||z t||i||d}Wnty5t}t||d}Ynw||sA| |j S|j ||j rO| |tttd|}|||ro|j sk|jrk| t||||} |jrt|j} | td| } |j d| ddd t| d|d7}q ) Nr-rTFrz Retrying in g@@z.2fz seconds.)introundtimerLAttemptr\sysexc_inforgetr_rNwarningrMrRr RetryErrorrXrKryr>infosleep) r`fnrr= start_timeattempt_numberrtbrvrjitterr r r r s:         z Retrying.call)NNNNNNNNNNNNNNFNNNNNN)r$ __module__ __qualname__rsrPrQ staticmethodrxrTrUrVrWr]rYrrr r r r rRsJ y    rc@s*eZdZdZddZd ddZddZd S) 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. cCs||_||_||_dSr)rrr)r`rrrr r r rs6s zAttempt.__init__FcCs.|jr|r t||j\}}}|||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. )rrrwith_traceback)r`rmexc_typeexcrr r r r;s   z Attempt.getc Cs>|jrd|jddt|jdSd|jd|jS)Nz Attempts: z , Error: r|z , Value: )rrjoin traceback format_tbrr`r r r __repr__Js$zAttempt.__repr__N)F)r$rr__doc__rsrrr r r r r/s   rc@s eZdZdZddZddZdS)rzU A RetryError encapsulates the last Attempt instance right before giving up. cCs ||_dSr last_attempt)r`rr r r rsVr zRetryError.__init__cCsd|jdS)Nz RetryError[]rrr r r __str__YszRetryError.__str__N)r$rrrrsrr r r r rQs rr)r"ryrrr functoolsrrHr r r!r%r*objectrrr\rr r r r s    ^"