ó
•abc @ 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 „ Z d e f d „ ƒ YZ d e f d „ ƒ YZ
d e f d
„ ƒ YZ d S( iÿÿÿÿN( t sixiÿÿÿ?c sS t ˆ ƒ d k r9 t ˆ d ƒ r9 d „ } | ˆ d ƒ S‡ ‡ f d † } | Sd S( sÆ
Decorator function that instantiates the Retrying object
@param *dargs: positional arguments passed to Retrying object
@param **dkw: keyword arguments passed to the Retrying object
i i c s" t j ˆ ƒ ‡ f d † ƒ } | S( Nc s t ƒ j ˆ | | Ž S( N( t Retryingt call( t argst kw( t f( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyt wrapped_f$ s ( R t wraps( R R ( ( R s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyt wrap_simple" s c s( t j ˆ ƒ ‡ ‡ ‡ f d † ƒ } | S( Nc s t ˆ ˆ Ž j ˆ | | Ž S( N( R R ( R R ( t dargst dkwR ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyR / s ( R R ( R R ( R R
( R s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyt wrap- s $N( t lent callable( R R
R R ( ( R R
s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyt retry s
" R c B s§ e Z d d d d d d d d d d d d d e d d d d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z
d „ Z d „ Z d „ Z
d
„ Z d „ Z RS(
c 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 r3ˆ j | j
ƒ n | d k rRˆ j | j ƒ n | d k rj| | _ n3 | d k r‹‡ f d † | _ n t | | ƒ | _ d „ g ‰ | d k rȈ j | j ƒ n | d k sà| d k róˆ j | j ƒ n | d k s | d k r ˆ j | j ƒ n |
d k s6| d k rIˆ j | j ƒ n | d k ra| | _ n3 | d k r‚‡ f d † | _ n t | | ƒ | _ | d k r¯| j | _ n | | _ |
d k rÓ| j | _ n |
| _ | | _ d S( Ni id iè i i c s t ‡ ‡ f d † ˆ Dƒ ƒ S( Nc 3 s | ] } | ˆ ˆ ƒ Vq d S( N( ( t .0R ( t attemptst delay( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pys a s ( t any( R R ( t
stop_funcs( R R s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyt a t c _ s d S( Ni ( ( R t kwargs( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyR h R c s t ‡ ‡ f d † ˆ Dƒ ƒ S( Nc 3 s | ] } | ˆ ˆ ƒ Vq d S( N( ( R R ( R R ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pys y s ( t max( R R ( t
wait_funcs( R R s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyR y R ( t Nonet _stop_max_attempt_numbert _stop_max_delayt _wait_fixedt _wait_random_mint _wait_random_maxt _wait_incrementing_startt _wait_incrementing_incrementt _wait_exponential_multipliert MAX_WAITt _wait_exponential_maxt _wait_jitter_maxt appendt stop_after_attemptt stop_after_delayt stopt getattrt fixed_sleept random_sleept incrementing_sleept exponential_sleept waitt
always_rejectt _retry_on_exceptiont never_rejectt _retry_on_resultt _wrap_exception( t selfR( R. t stop_max_attempt_numbert stop_max_delayt
wait_fixedt wait_random_mint wait_random_maxt wait_incrementing_startt wait_incrementing_incrementt wait_exponential_multipliert wait_exponential_maxt retry_on_exceptiont retry_on_resultt wrap_exceptiont stop_funct wait_funct wait_jitter_max( ( R R s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyt __init__: sR c C s
| | j k S( s; Stop after the previous attempt >= stop_max_attempt_number.( R ( R4 t previous_attempt_numbert delay_since_first_attempt_ms( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyR& s c C s
| | j k S( s= Stop after the time from the first attempt >= stop_max_delay.( R ( R4 RE RF ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyR' ‘ s c C s d S( s# Don't sleep at all before retrying.i ( ( R4 RE RF ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyt no_sleep• s c C s | j S( s0 Sleep a fixed amount of time between each retry.( R ( R4 RE RF ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyR* ™ s c C s t j | j | j ƒ S( sI Sleep a random amount of time between wait_random_min and wait_random_max( t randomt randintR R ( R4 RE RF ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyR+ s c C s1 | j | j | d } | d k r- d } n | S( s¥
Sleep an incremental amount of time after each attempt, starting at
wait_incrementing_start and incrementing by wait_incrementing_increment
i i ( R R ( R4 RE RF t result( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyR, ¡ s c C sK d | } | j | } | | j k r2 | j } n | d k rG d } n | S( Ni i ( R! R# ( R4 RE RF t expRJ ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyR- « s
c C s t S( N( t False( R4 RJ ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyR1 ´ s c C s t S( N( t True( R4 RJ ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyR/ · s c C sF t } | j r, | | j | j d ƒ O} n | | j | j ƒ O} | S( Ni ( RL t
has_exceptionR0 t valueR2 ( R4 t attemptt reject( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyt
should_rejectº s
c O s[ t t t j ƒ d ƒ ƒ } d } x2t rVy t | | | Ž | t ƒ } Wn% t j ƒ } t | | t ƒ } n X| j | ƒ s‘ | j | j
ƒ St t t j ƒ d ƒ ƒ | } | j | | ƒ rô | j
rå | j rå | j ƒ ‚ qIt
| ƒ ‚ nU | j | | ƒ } | j r8t j ƒ | j }
| t d |
ƒ } n t j | d ƒ | d 7} q% Wd S( Niè i i g @@( t intt roundt timeRM t AttemptRL t syst exc_infoRR t getR3 R( RN t
RetryErrorR. R$ RH R t sleep( R4 t fnR R t
start_timet attempt_numberRP t tbRF R[ t jitter( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyR Ã s* N( t __name__t
__module__R RL RD R& R' RG R* R+ R, R- R1 R/ RR R ( ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyR 8 s0 F
RV c B s, e Z d Z d „ Z e d „ Z d „ Z RS( s¾
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( RO R^ RN ( R4 RO R^ RN ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyRD è s c C sT | j rI | r t | ƒ ‚ qP t j | j d | j d | j d ƒ n | j Sd S( sÈ
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.
i i i N( RN RZ R t reraiseRO ( R4 R@ ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyRY í s
+c C sO | j r5 d j | j d j t j | j d ƒ ƒ ƒ Sd j | j | j ƒ Sd S( Ns Attempts: {0}, Error:
{1}R i s Attempts: {0}, Value: {1}( RN t formatR^ t joint tracebackt format_tbRO ( R4 ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyt __repr__û s ,( Ra Rb t __doc__RD RL RY Rh ( ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyRV á s RZ c B s e Z d Z d „ Z d „ Z RS( sU
A RetryError encapsulates the last Attempt instance right before giving up.
c C s
| | _ d S( N( t last_attempt( R4 Rj ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyRD s c C s d j | j ƒ S( Ns RetryError[{0}]( Rd Rj ( R4 ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyt __str__
s ( Ra Rb Ri RD Rk ( ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyRZ s (
RH t pip._vendorR RW RU Rf R" R t objectR RV t ExceptionRZ ( ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyt s ©!