← Back
Editing: retrying.pyo
� ��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 <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 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 <genexpr>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 <module> s �!
Save File
Cancel