a
ljQG @ s d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZm Z d dl
m Z d dl m
Z
ddlmZ ddlmZ ddlmZ dd lmZ dd
lmZ dd lmZ dd lmZ dd
lmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddl m Z ddl m Z ddl m Z ddl m!Z! ddl m"Z" ddl m#Z# ddl m$Z$ ddl m%Z% ddl&m'Z' dd l&m(Z( dd l&m)Z) dd l&m*Z* dd l&m+Z+ dd l&m,Z, dd!l&m-Z- dd"l&m.Z. dd"l&m.Z/ dd#l0m1Z1 dd$l0m2Z2 dd%l3m4Z4 dd&l3m5Z5 dd'l6m7Z7 dd(l6m8Z8 dZ9ej:r4d dl;Z;dd)l&md+ej?d,Z@e>d-ZAejBe@e@d.d/d0ZejBejCejCej?e@ge@f d1d2d0ZejCejCejDe@ej?e@ge@f f d1d3d0ZG d4d5 d5eEZFeG ZHG d6d7 d7ZIG d8d9 d9eJZKG d:d; d;ZLG dd?d@ZOG dAdB dBeEZPG dCdD dDZQG dEdF dFeZRG dGdH dHeRZSG dIdJ dJe jTZTG dKdL dLZUd dMlVmWZW e9rd dNlXmYZY dS )O N)ABCabstractmethod)futures)iscoroutinefunction )
retry_base) retry_all) retry_always) retry_any)retry_if_exception)retry_if_exception_type)retry_if_not_exception_type)retry_if_not_result)retry_if_result) retry_never)retry_unless_exception_type)retry_if_exception_message) retry_if_not_exception_messagesleep)sleep_using_event)stop_after_attempt)stop_after_delay)stop_all)stop_any)
stop_never)stop_when_event_set)
wait_chain) wait_combine)wait_exponential)
wait_fixed)wait_incrementing) wait_none) wait_random)wait_random_exponential)
before_log)before_nothing) after_log)
after_nothing)before_sleep_log)before_sleep_nothing) wait_base) stop_base WrappedFn)bound_RetValT)fnreturnc C s d S N )r0 r3 r3 A/usr/lib/python3.9/site-packages/pip/_vendor/tenacity/__init__.pyretrya s r5 )dargsdkwr1 c O s d S r2 r3 r6 r7 r3 r3 r4 r5 f s c sD t dkr&t d r&t d S ttd fdd }|S dS )zWrap a function with a new `Retrying` object.
:param dargs: positional arguments passed to Retrying object
:param dkw: keyword arguments passed to the Retrying object
r r fr1 c s t | tr*td| jj d| jj d t| rBt i }n:trnt tj
drntj
| rnt i }nt
i }|| S )NzGot retry_base instance (zQ) as callable argument, this will probably hang indefinitely (did you mean retry=z(...)?)is_coroutine_function)
isinstancer warningswarn __class____name__r
AsyncRetryingtornadohasattrgenr; TornadoRetryingRetryingwraps)r: rr8 r3 r4 wrapv s
zretry..wrapN)lencallabler5 r- )r6 r7 rI r3 r8 r4 r5 k s c @ s e Zd ZdZdS )TryAgainz/Always retry the executed function when raised.N)r@
__module__ __qualname____doc__r3 r3 r3 r4 rL s rL c @ s e Zd ZdS ) DoAttemptNr@ rM rN r3 r3 r3 r4 rP s rP c @ s e Zd ZdS )DoSleepNrQ r3 r3 r3 r4 rR s rR c @ sR e Zd ZU dZdZeje ed< dZ ej
e ed< edddZ edd d
Z dS )
BaseActiona5 Base class for representing actions to take by retry object.
Concrete implementations must define:
- __init__: to initialize all necessary fields
- REPR_FIELDS: class variable specifying attributes to include in repr(self)
- NAME: for identification in retry object methods and callbacks
r3 REPR_FIELDSNNAMEr1 c s. d fdd jD } jj d| dS )Nz, c 3 s" | ]}| d t |V qdS )=N)getattr).0Zfieldselfr3 r4 z&BaseAction.__repr__..())joinrT r? r@ )r[ Z state_strr3 rZ r4 __repr__ s zBaseAction.__repr__c C s t | S r2 )reprrZ r3 r3 r4 __str__ s zBaseAction.__str__)
r@ rM rN rO rT tSequencestr__annotations__rU Optionalra rc r3 r3 r3 r4 rS s
rS c @ s& e Zd ZdZdZejddddZdS ) RetryActionr r5 N)r r1 c C s t || _d S r2 )floatr )r[ r r3 r3 r4 __init__ s zRetryAction.__init__)r@ rM rN rT rU rd
SupportsFloatrk r3 r3 r3 r4 ri s ri )firstsecondr1 c C s | t u r |S | S r2 )_unset)rm rn r3 r3 r4
_first_set s rp c sD e Zd ZdZddd fdd Zddd d
Zedd d Z ZS )
RetryErrorz>Encapsulates the last attempt instance right before giving up.FutureN) last_attemptr1 c s || _ t | d S r2 )rs superrk )r[ rs r? r3 r4 rk s zRetryError.__init__z
t.NoReturnrV c C s | j jr| j | d S r2 )rs failedresultrZ r3 r3 r4 reraise s
zRetryError.reraisec C s | j j d| j dS )N[])r? r@ rs rZ r3 r3 r4 rc s zRetryError.__str__) r@ rM rN rO rk rx rf rc
__classcell__r3 r3 ru r4 rq s rq c @ s^ e Zd ZdZddddZdddd Zejeje eje ejd
eje
d d d
Z dS )AttemptManagerzManage attempt context.RetryCallState retry_statec C s
|| _ d S r2 r~ )r[ r r3 r3 r4 rk s zAttemptManager.__init__NrV c C s d S r2 r3 rZ r3 r3 r4 __enter__ s zAttemptManager.__enter__types.TracebackType)exc_type exc_value tracebackr1 c C s4 t |tr | j|||f dS | jd d S d S )NT)r<
BaseExceptionr
set_exception
set_result)r[ r r r r3 r3 r4 __exit__ s
zAttemptManager.__exit__) r@ rM rN rO rk r rd rh Typer boolr r3 r3 r3 r4 r| s r| c @ s> e Zd Zeee e eedde df
e
j e
j e
ef gdf ddee
j dgdf e
j dgdf e
je
j dgdf ee
je e
je
j dge
jf d
ddZeeeeeeeeeef
e
j e
j e
j e
ef gdf ef e
j def e
j def e
j eef e
j e
j dgdf ef e
j e
j dgdf ef e
j e
je
j dgdf ef e
j eef e
j e
je ef e
j e
je
j dge
jf ef d d d
d Zed d
dZee
jee
jf d ddZ e e dddZ dd ddZ de
j e e!e
jf dddZ"e
j#e$ddf d ddZ%e&e
j de'f e
je
je'd d d Z(dS ) BaseRetryingNFr, r+ r}
r stopwaitr5 beforeafter before_sleeprx retry_error_clsretry_error_callbackc C sJ || _ || _|| _|| _|| _|| _|| _|| _t | _
| | _ |
| _ d S r2 )
r r r r5 r r r rx threadinglocal_localr r r[ r r r r5 r r r rx r r r3 r3 r4 rk s
zBaseRetrying.__init__) r r r r5 r r r rx r r r1 c
C sn | j t|| jt|| jt|| jt|| jt|| jt|| jt|| jt|| j t| | j
t|
| j d
S )z8Copy this object with some parameters changed if needed.r ) r? rp r r r r5 r r r rx r r r r3 r3 r4 copy s
zBaseRetrying.copyrV c C sL d| j j dt| dd| j d| j d| j d| j d| j d | j d
S ) N) r? r@ idr r r r5 r r rZ r3 r3 r4 ra s zBaseRetrying.__repr__c C s2 z
| j jW S ty, i | j _| j j Y S 0 dS )aS Return a dictionary of runtime statistics.
This dictionary will be empty when the controller has never been
ran. When it is running or has ran previously it should have (but
may not) have useful and/or informational keys and values when
running is underway and/or completed.
.. warning:: The keys in this dictionary **should** be some what
stable (not changing), but there existence **may**
change between major releases as new statistics are
gathered or removed so before accessing keys ensure that
they actually exist and handle when they do not.
.. note:: The values in this dictionary are local to the thread
running call (so if multiple threads share the same retrying
object - either directly or indirectly) they will each have
there own view of statistics they have collected (in the
future we may provide a way to aggregate the various
statistics from each thread).
N)r
statisticsAttributeErrorrZ r3 r3 r4 r " s
zBaseRetrying.statisticsr9 c sT t tjtjtjd fdd }tjtjtd fdd }|_||_|S )z[Wrap a function for retrying.
:param f: A function to wraps for retrying.
)argskwr1 c s g| R i |S r2 r3 )r r r: r[ r3 r4 wrapped_fD s z%BaseRetrying.wraps..wrapped_f)r kwargsr1 c s j | i | S r2 )r rG )r r r r3 r4
retry_withH s z&BaseRetrying.wraps..retry_with) functoolsrG rd Anyr- r5 r )r[ r: r r r3 r r4 rG > s zBaseRetrying.wrapsc C s0 | j t | j d< d| j d< d| j d< d S )N
start_timer attempt_numberr idle_for)r cleartime monotonicrZ r3 r3 r4 beginP s
zBaseRetrying.begin)r r1 c C s( |j }|d u r(| jd ur"| | t S |j jo>t|j t}|sX| j|dsX| S | j d url| | |j
| j d< | j |dr| j
r|
|S | |}| jr| || | jr| j|d}nd}t||_| j|7 _| j d |7 < | j d d7 < | jd ur | | t|S )Nr~ Zdelay_since_first_attempt r r r )outcomer rP rv r< exceptionrL r5 rw r seconds_since_startr r r r rx r ri next_actionr r rR )r[ r futZis_explicit_retryZ retry_excr r3 r3 r4 iterV s8
zBaseRetrying.iterc c sb | t| d di d}| j|d}t|tr) r rv r r? r@ rw rj roundr r r )r[ rw r ZsleptZclsnamer3 r3 r4 ra s
zRetryCallState.__repr__)r@ rM rN rO r rd rh r- r rk r rj r r r Tupler r r ra r3 r3 r3 r4 r} s "r} )rA )rE )Zr r r r typingrd r= abcr r Z
concurrentr inspectr r5 r r r r
r r r
r r r r r r Znapr r r r r r r r r r r r r r r! r" r# r$ Zwait_full_jitterr r% r& r r' r( r r) r* rB
TYPE_CHECKINGtypesr+ r, TypeVarr r- r/ overloadr r ExceptionrL r Z NO_RESULTrP rj rR rS ri ro rp rq r| r rF rr r} Z pip._vendor.tenacity._asynciorA Z pip._vendor.tenacity.tornadowebrE r3 r3 r3 r4 s
$, " -F