U
.e& @ 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 NRetryingcallargskwf 8/usr/lib/python3.8/site-packages/pip/_vendor/retrying.py wrapped_f$ s z-retry..wrap_simple..wrapped_fr wrapsr r r
r r wrap_simple" s zretry..wrap_simplec s t fdd}|S )Nc s t jf| |S r r r )dargsdkwr r
r r / s z&retry..wrap..wrapped_fr r r r r r wrap- s zretry..wrapN)lencallable)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 krdn|| _
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 krfd 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 ZattemptsZdelayr
r a s 6Retrying.__init__....)anyr )
stop_funcsr r a z#Retrying.__init__..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_multiplierMAX_WAIT_wait_exponential_max_wait_jitter_maxappendstop_after_attemptstop_after_delaystopgetattr fixed_sleep random_sleepincrementing_sleepexponential_sleepwait
always_reject_retry_on_exception never_reject_retry_on_result_wrap_exception)selfr8 r> Zstop_max_attempt_numberZstop_max_delayZ
wait_fixedZwait_random_minZwait_random_maxZwait_incrementing_startZwait_incrementing_incrementZwait_exponential_multiplierZwait_exponential_maxZretry_on_exceptionZretry_on_resultwrap_exceptionZ stop_funcZ wait_funcZwait_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* rD previous_attempt_number delay_since_first_attempt_msr
r
r r6 s zRetrying.stop_after_attemptc C s
|| j kS )z=Stop after the time from the first attempt >= stop_max_delay.)r+ rG r
r
r r7 s zRetrying.stop_after_delayc C s dS )z#Don't sleep at all before retrying.r r
rG r
r
r no_sleep s zRetrying.no_sleepc C s | j S )z0Sleep a fixed amount of time between each retry.)r, rG r
r
r r: s zRetrying.fixed_sleepc C s t | j| jS )zISleep a random amount of time between wait_random_min and wait_random_max)randomZrandintr- r. rG 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 )r/ r0 )rD rH rI resultr
r
r r< s zRetrying.incrementing_sleepc C s2 d| }| j | }|| jkr"| j}|dk r.d}|S )N r )r1 r3 )rD rH rI ZexprL r
r
r r= s
zRetrying.exponential_sleepc C s dS )NFr
rD rL r
r
r rA s zRetrying.never_rejectc C s dS )NTr
rN r
r
r r? s zRetrying.always_rejectc C s4 d}|j r || |jd O }n|| |jO }|S )NFr )
has_exceptionr@ valuerB )rD attemptZrejectr
r
r
should_reject s
zRetrying.should_rejectc O s t tt d }d}zt||||d}W n t }t||d}Y nX | |sf|| jS t tt d | }| ||r| js|j
r| qt |n<| ||} | j
rt | j
}
| td|
} t| d |d7 }qd S )Nr r FTr g @@)introundtimeAttemptsysexc_inforR getrC r8 rO
RetryErrorr> r4 rK r( sleep) rD fnr r' Z
start_timeattempt_numberrQ tbrI r[ Zjitterr
r
r r s(
z
Retrying.call)NNNNNNNNNNNNNFNNN)__name__
__module__ __qualname__rF r6 r7 rJ r: r; r< r= rA r? rR r r
r
r
r r 8 s:
S
r c @ s* e Zd ZdZdd Zd
ddZdd Zd S ) rV 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 )rP r] rO )rD rP r] rO r
r
r rF s zAttempt.__init__Fc C s@ | j r6|rt| q s *!