Google
Edit File: retrying.pyc
� /��_c @ 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 <genexpr>a s ( t any( R R ( t stop_funcs( R R s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyt <lambda>a s c _ s d S( Ni ( ( R t kwargs( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyR h s 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 <genexpr>y s ( t max( R R ( t wait_funcs( R R s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyR y s ( 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 ( R3 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 ( R3 RD RE ( ( 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 ( ( R3 RD RE ( ( 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 ( R3 RD RE ( ( 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 ( R3 RD RE ( ( 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 ( R3 RD RE 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" ( R3 RD RE t expRI ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyR, � s c C s t S( N( t False( R3 RI ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyR0 � s c C s t S( N( t True( R3 RI ( ( 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 ( RK t has_exceptionR/ t valueR1 ( R3 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 timeRL t AttemptRK t syst exc_infoRQ t getR2 R' RM t RetryErrorR- R# RG R t sleep( R3 t fnR R t start_timet attempt_numberRO t tbRE RZ t jitter( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyR � s* N( t __name__t __module__R RK RC R% R& RF R) R* R+ R, R0 R. RQ R ( ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyR 8 s0 F RU 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( RN R] RM ( R3 RN R] RM ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyRC � 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( RM RY R t reraiseRN ( R3 R? ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyRX � 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}t i s Attempts: {0}, Value: {1}( RM t formatR] t joint tracebackt format_tbRN ( R3 ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyt __repr__� s ,( R` Ra t __doc__RC RK RX Rh ( ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyRU � s RY 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( R3 Rj ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyRC s c C s d j | j � S( Ns RetryError[{0}]( Rd Rj ( R3 ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyt __str__ s ( R` Ra Ri RC Rk ( ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyRY s ( RG t pip._vendorR RV RT Rf R! R t objectR RU t ExceptionRY ( ( ( s8 /usr/lib/python2.7/site-packages/pip/_vendor/retrying.pyt <module> s �!