t_& @ s d d l Z d d l m Z d d l Z d d l Z d d l Z d Z d d Z Gd d d e Z Gd d d e Z
Gd
d d e Z d S) N)sixi?c sY t d k r< t d r< d d } | d S f d d } | Sd 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
r c s% t j f d d } | S)Nc s t j | | S)N)Retryingcall)argskw)f /builddir/build/BUILDROOT/alt-python35-pip-20.2.4-1.el7.x86_64/opt/alt/python35/lib/python3.5/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 j f d d } | S)Nc s t j | | S)N)r r )r r )dargsdkwr r r
r / s z&retry.<locals>.wrap.<locals>.wrapped_f)r r )r r )r r )r r
wrap- s 'zretry.<locals>.wrapN)lencallable)r r r
r r )r r r
retry s
" r c @ s e Z d Z d d d d d d d d d d d d d d d d d d d Z d d Z d d Z d d
Z d d Z d
d Z d d Z d d Z
d d Z d d Z d d Z
d d Z d S)r NFc s | d k r d n | | _ | d k r- d n | | _ | d k rH d n | | _ | d k rc d n | | _ | d k r~ d n | | _ | d k r d n | | _ | d k r d n | | _ |
d k r d n |
| _ | d k r t n | | _ | d k rd n | | _
g | d k r0 j | j | d k rL j | j
| d k rd| | _ n6 | d k r f d d | _ n t | | | _ d d g | d k r j | j | d k s| d k r j | j | d k s| d k r j | j |
d k s-| d k r= j | j | d k rU| | _ n6 | d k ry f d d | _ n t | | | _ | d k r| j | _ n | | _ |
d k r| j | _ n |
| _ | | _ d S)
N d i r r c s t f d d D S)Nc 3 s | ] } | Vq d S)Nr ).0r )attemptsdelayr r
<genexpr>a s z6Retrying.__init__.<locals>.<lambda>.<locals>.<genexpr>)any)r r )
stop_funcs)r r r
<lambda>a s z#Retrying.__init__.<locals>.<lambda>c _ s d S)Nr r )r kwargsr r r
r h s c s t f d d D S)Nc 3 s | ] } | Vq d S)Nr )r r )r r r r
r y s z6Retrying.__init__.<locals>.<lambda>.<locals>.<genexpr>)max)r r )
wait_funcs)r r r
r y s )_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)selfr. r4 stop_max_attempt_numberstop_max_delay
wait_fixedwait_random_minwait_random_maxwait_incrementing_startwait_incrementing_incrementwait_exponential_multiplierwait_exponential_maxretry_on_exceptionretry_on_resultwrap_exception stop_func wait_funcwait_jitter_maxr )r r r
__init__: sR zRetrying.__init__c C s
| | j k S)z;Stop after the previous attempt >= stop_max_attempt_number.)r )r: previous_attempt_number delay_since_first_attempt_msr r r
r, s zRetrying.stop_after_attemptc C s
| | j k S)z=Stop after the time from the first attempt >= stop_max_delay.)r! )r: rK rL r r r
r- s zRetrying.stop_after_delayc C s d S)z#Don't sleep at all before retrying.r r )r: rK rL r r r
no_sleep s zRetrying.no_sleepc C s | j S)z0Sleep a fixed amount of time between each retry.)r" )r: rK rL r r r
r0 s zRetrying.fixed_sleepc C s t j | j | j S)zISleep a random amount of time between wait_random_min and wait_random_max)randomrandintr# r$ )r: rK rL r r r
r1 s zRetrying.random_sleepc C s. | j | j | d } | d k 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% r& )r: rK rL resultr r r
r2 s zRetrying.incrementing_sleepc C sE d | } | j | } | | j k r/ | j } | d k rA d } | S)N r )r' r) )r: rK rL exprP r r r
r3 s
zRetrying.exponential_sleepc C s d S)NFr )r: rP r r r
r7 s zRetrying.never_rejectc C s d S)NTr )r: rP r r r
r5 s zRetrying.always_rejectc C sF d } | j r, | | j | j d O} n | | j | j O} | S)NFr )
has_exceptionr6 valuer8 )r: attemptrejectr r r
should_reject s
zRetrying.should_rejectc
O sS t t t j d } d } x*y t | | | | d } Wn& t j } t | | d } Yn X| j | s | j | j St t t j d | } | j | | r | j r | j
r | j qAt | nR | j | | } | j
r0t j | j
}
| t d |
} t j | d | d 7} q% Wd S)Ni r FTr g @@)introundtimeAttemptsysexc_inforW getr9 r. rS
RetryErrorr4 r* rN r sleep) r: fnr r
start_timeattempt_numberrU tbrL r` jitterr r r
r s* z
Retrying.call)__name__
__module__ __qualname__rJ r, r- rM r0 r1 r2 r3 r7 r5 rW r r r r r
r 8 s0 F
r c @ s= e Z d Z d Z d d Z d d d Z d d Z d S)
r[ 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)N)rT rc rS )r: rT rc rS r r r
rJ s zAttempt.__init__Fc C sT | j rI | r t | qP t j | j d | j d | j d n | j Sd S)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 rQ N)rS r_ r reraiserT )r: rF r r r
r^ s
+z Attempt.getc C sO | j r5 d j | j d j t j | j d Sd j | j | j Sd S)NzAttempts: {0}, Error:
{1} rQ zAttempts: {0}, Value: {1})rS formatrc join traceback format_tbrT )r: r r r
__repr__ s ,zAttempt.__repr__N)rf rg rh __doc__rJ r^ ro r r r r
r[ s r[ c @ s. e Z d Z d Z d d Z d d Z d S)r_ zU
A RetryError encapsulates the last Attempt instance right before giving up.
c C s
| | _ d S)N) last_attempt)r: rq r r r
rJ s zRetryError.__init__c C s d j | j S)NzRetryError[{0}])rk rq )r: r r r
__str__
s zRetryError.__str__N)rf rg rh rp rJ rr r r r r
r_ s r_ )
rN pip._vendorr r\ rZ rm r( r objectr r[ Exceptionr_ r r r r
<module> s !