X9c ddlZddlZddlZddlZddlZddlmZddlZddlm Z eje Z e dddddde df dZe dddddde df dZd Zd Zd Zd Zde dfd Ze dddddde df dZdde dddddde df dZy)N)partial decoratorFc ||} } | r |Syy#|$rQ} | dz} |rt|||| | | | s| | | tj| t|||| } Yd} ~ nd} ~ wwxYw| rf_Nr) _log_attempttimesleep _new_delay f exceptionstriesdelay max_delaybackoffjittershow_tracebacklogger fail_callback_tries_delayes +lib/python3.12/site-packages/reretry/api.py__retry_internalrsEFF  D3J  D aKFUNFFFAN(a JJv  7FFCF D sA'AA""A'c K||} } | r |d{Syy7#|$rc} | dz} |rt|||| | | | s| | | d{7tj| d{7t|||| } Yd} ~ nd} ~ wwxYw| rswr )r asyncior r rs r__retry_internal_asyncr 2sEFF  D9   D aKFUNFFFAN(#A&&&--' ' ' 7FFCF D sNB  B B'B A  B'A*(B;B BB c|r\|rAdjtjd||j}|j ||j d|||z ||y|dkDr|j d|||z |yy)Nz4%s, attempt %s/%s failed - retrying in %s seconds...rz%%s, attempt %s/%s failed - giving up!)join tracebackformat_exception __traceback__warning)rrrrrrtb_strs rr r Us{ WWY77aQRF NN6 " B FN      3Q  cz||z}|t|trtj|n|z }| t ||}|SN) isinstancetuplerandomuniformmin)rrrrs rr r isA gF FE)Bfnnf%NFVY' Mr)c\tj|xrtj| Sr+)riscoroutinefunctioninspectisgeneratorfunctionrs r _is_asyncr6ss&  & &q ) P'2M2Ma2P.PPr)c0t|rtStSr+)r6r rr5s r_get_internal_functionr8ws%.q\ !G7GGr)c|r |Jd|r5t|r t|st|s t|rJdyyy)Nz`show_traceback` needs `logger`zWIf the retried function is async, fail_callback needs to be async as well or vice versa)r6)rrrrs r _check_paramsr:{sQ!3V5VV 1)M2! Y}%=aaa%=3r)c Dtf d} | S)aReturns a retry decorator. :param exceptions: an exception or a tuple of exceptions to catch. default: Exception. :param tries: the maximum number of attempts. default: -1 (infinite). :param delay: initial delay between attempts (in seconds). default: 0. :param max_delay: the maximum value of delay (in seconds). default: None (no limit). :param backoff: multiplier applied to delay between attempts. default: 1 (no backoff). :param jitter: extra seconds added to delay between attempts. default: 0. fixed if a number, random if a range tuple (min, max) :param show_traceback: if True, the traceback of the exception will be logged. :param logger: logger.warning(fmt, error, delay) will be called on failed attempts. default: retry.logging_logger. if None, logging is disabled. :param fail_callback: fail_callback(e) will be called on failed attempts. :returns: a retry decorator. c0 t|||    Sr+) retry_call) rfargsfkwargsrrrrrrrrrs rretry_decoratorzretry..retry_decorators4             r)r) rrrrrrrrrr@s ````````` rretryrAs%6   r)c |xs t} |xs t} t|| | | t|}|t |g| i| ||||||| | | S)a Calls a function and re-executes it if it failed. :param f: the function to execute. :param fargs: the positional arguments of the function to execute. :param fkwargs: the named arguments of the function to execute. :param exceptions: an exception or a tuple of exceptions to catch. default: Exception. :param tries: the maximum number of attempts. default: -1 (infinite). :param delay: initial delay between attempts (in seconds). default: 0. :param max_delay: the maximum value of delay (in seconds). default: None (no limit). :param backoff: multiplier applied to delay between attempts. default: 1 (no backoff). :param jitter: extra seconds added to delay between attempts. default: 0. fixed if a number, random if a range tuple (min, max) :param show_traceback: if True, the traceback of the exception will be logged. :param logger: logger.warning(fmt, error, delay) will be called on failed attempts. default: retry.logging_logger. if None, logging is disabled. :param fail_callback: fail_callback(e) will be called on failed attempts. :returns: the result of the f function. )listdictr:r8r)rr>r?rrrrrrrrrargskwargsfuncs rr=r=snB ?DFD  F!^V]; !! $D #D#F#    r))rloggingr.r r$ functoolsrr3compatr getLogger__name__logging_logger Exceptionrr r r r6r8r:rAr=r)rrPs """8,     DJ    DF (QH%*.PTa   ,b     2r)