U
|
H=®dô& ã @ sl d dl Z d dlmZ d dlZd dlZd dlZdZdd ZG dd deZ G dd d eZ
|
G d
|
d d e Z dS ) é N)Úsixiÿÿÿ?c sB t dkr,t d r,dd }| d S fdd}|S dS )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
|
é r c s t ¡ fdd}|S )Nc s t j f| |S ©N©ÚRetryingÚcall©ÚargsÚkw©Úf© úKD:\z\workplace\VsCode\pyvenv\venv\Lib\site-packages\pip/_vendor/retrying.pyÚ wrapped_f$ s z-retry.<locals>.wrap_simple.<locals>.wrapped_f©r Úwraps©r r r r r Ú wrap_simple" s zretry.<locals>.wrap_simplec s t ¡ fdd}|S )Nc s t jf| |S r r r )ÚdargsÚdkwr r r r / s z&retry.<locals>.wrap.<locals>.wrapped_fr r ©r r r r Úwrap- s zretry.<locals>.wrapN)ÚlenÚcallable)r r r r r r r Úretry s
|
r c @ sn e Zd ZdddZdd Zdd Zd d
|
Zd d Zd d Zdd Z dd Z
|
dd Z dd Z dd Z dd ZdS ) r NFc s |d kr dn|| _ |d kr dn|| _|d kr0dn|| _|d krBdn|| _|d krTdn|| _|d krfdn|| _| d krxdn| | _|
|
d krdn|
|
| _| d krtn| | _ |d kr®dn|| _
|
g |d k rÌ | j ¡ |d k rà | j ¡ |d k rð|| _n&|d kr
|
fdd| _n t| || _dd g|d k r6 | j¡ |d k sJ|d k rV | j¡ |d k sj| d k rv | j¡ |
|
d k s| d k r | j¡ |d k r¨|| _n&|d krÂfd d| _n t| || _| d krâ| j| _n| | _| d krü| j| _n| | _|| _d S )
|
Né éd éè r r c s t fddD S )Nc 3 s | ]}| V qd S r r ©Ú.0r ©ÚattemptsÚdelayr r Ú <genexpr>a s ú6Retrying.__init__.<locals>.<lambda>.<locals>.<genexpr>)Úanyr )Ú
|
stop_funcsr r Ú<lambda>a ó z#Retrying.__init__.<locals>.<lambda>c _ s dS )Nr r )r Úkwargsr r r r' h r( c s t fddD S )Nc 3 s | ]}| V qd S r r r r r r r# y s r$ )Úmaxr )Ú
|
wait_funcsr r r' y r( )Ú_stop_max_attempt_numberÚ_stop_max_delayÚ _wait_fixedÚ_wait_random_minÚ_wait_random_maxÚ_wait_incrementing_startÚ _wait_incrementing_incrementÚ _wait_exponential_multiplierÚMAX_WAITÚ_wait_exponential_maxÚ_wait_jitter_maxÚappendÚstop_after_attemptÚstop_after_delayÚstopÚgetattrÚ fixed_sleepÚ random_sleepÚincrementing_sleepÚexponential_sleepÚwaitÚ always_rejectÚ_retry_on_exceptionÚ never_rejectÚ_retry_on_resultÚ_wrap_exception)Úselfr: r@ Ústop_max_attempt_numberÚstop_max_delayÚ
|
wait_fixedÚwait_random_minÚwait_random_maxÚwait_incrementing_startÚwait_incrementing_incrementÚwait_exponential_multiplierÚwait_exponential_maxÚretry_on_exceptionÚretry_on_resultÚwrap_exceptionÚ stop_funcÚ wait_funcÚwait_jitter_maxr )r& r+ r Ú__init__: sR
|
|
|
|
|
|
|
|
|
zRetrying.__init__c C s
|
|| j kS )z;Stop after the previous attempt >= stop_max_attempt_number.)r, ©rF Úprevious_attempt_numberÚ delay_since_first_attempt_msr r r r8 s zRetrying.stop_after_attemptc C s
|
|| j kS )z=Stop after the time from the first attempt >= stop_max_delay.)r- rW r r r r9 s zRetrying.stop_after_delayc C s dS )z#Don't sleep at all before retrying.r r rW r r r Úno_sleep s zRetrying.no_sleepc C s | j S )z0Sleep a fixed amount of time between each retry.)r. rW r r r r< s zRetrying.fixed_sleepc C s t | j| j¡S )zISleep a random amount of time between wait_random_min and wait_random_max)ÚrandomÚrandintr/ r0 rW r r r r= s zRetrying.random_sleepc C s$ | j | j|d }|dk r d}|S )z¥
|
Sleep an incremental amount of time after each attempt, starting at
|
wait_incrementing_start and incrementing by wait_incrementing_increment
|
r r )r1 r2 )rF rX rY Úresultr r r r> ¡ s zRetrying.incrementing_sleepc C s2 d| }| j | }|| jkr"| j}|dk r.d}|S )Né r )r3 r5 )rF rX rY Úexpr] r r r r? « s
|
|
zRetrying.exponential_sleepc C s dS )NFr ©rF r] r r r rC ´ s zRetrying.never_rejectc C s dS )NTr r` r r r rA · s zRetrying.always_rejectc C s4 d}|j r || |jd ¡O }n|| |j¡O }|S )NFr )Ú has_exceptionrB ÚvaluerD )rF ÚattemptÚrejectr r r Ú should_rejectº s
|
zRetrying.should_rejectc O sô t tt ¡ d }d}zt||||d}W n t ¡ }t||d}Y nX | |¡sf| | j¡S t tt ¡ d | }| ||¡rª| js |j
|
r | ¡ qæt |n<| ||¡} | j rØt ¡ | j }
|
| td|
|
} t | d ¡ |d7 }qd S )Nr r FTr g @@)ÚintÚroundÚtimeÚAttemptÚsysÚexc_infore ÚgetrE r: ra Ú
|
RetryErrorr@ r6 r[ r* Úsleep) rF Úfnr r) Ú
|
start_timeÚattempt_numberrc ÚtbrY rn Újitterr r r r à s(
|
|
|
z Retrying.call)NNNNNNNNNNNNNFNNN)Ú__name__Ú
|
__module__Ú __qualname__rV r8 r9 rZ r< r= r> r? rC rA re r r r r r r 8 s: ó
|
S
|
r c @ s* e Zd ZdZdd Zd
|
ddZdd Zd S ) ri 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.
|
c C s || _ || _|| _d S r )rb rq ra )rF rb rq ra r r r rV è s zAttempt.__init__Fc C s@ | j r6|rt| q<t | jd | jd | jd ¡ n| jS dS )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.
|
r r r^ N)ra rm r Úreraiserb )rF rR r r r rl í s
|
|
"z Attempt.getc C s: | j r&d | jd t | jd ¡¡¡S d | j| j¡S d S )NzAttempts: {0}, Error:
|
{1}Ú r^ zAttempts: {0}, Value: {1})ra Úformatrq ÚjoinÚ tracebackÚ format_tbrb ©rF r r r Ú__repr__û s zAttempt.__repr__N)F)rt ru rv Ú__doc__rV rl r~ r r r r ri á s
|
ri c @ s e Zd ZdZdd Zdd ZdS )rm zU
|
A RetryError encapsulates the last Attempt instance right before giving up.
|
c C s
|
|| _ d S r )Ú last_attempt)rF r r r r rV s zRetryError.__init__c C s d | j¡S )NzRetryError[{0}])ry r r} r r r Ú__str__
|
s zRetryError.__str__N)rt ru rv r rV r r r r r rm s rm ) r[ Ú pip._vendorr rj rh r{ r4 r Úobjectr ri Ú Exceptionrm r r r r Ú<module> s *!
|
