U
ʗReQG @ 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 /builddir/build/BUILDROOT/alt-python38-pip-22.2.1-2.el8.x86_64/opt/alt/python38/lib/python3.8/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 sz t | tr*td| jj d| jj d t| r>t }n2trft tj
drftj
| rft }n
t
}|| 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).0fieldselfr3 r4 s z&BaseAction.__repr__..())joinrT r? r@ )r\ state_strr3 r[ r4 __repr__ s zBaseAction.__repr__c C s t | S r2 )reprr[ r3 r3 r4 __str__ s zBaseAction.__str__)
r@ rM rN rO rT tSequencestr__annotations__rU Optionalrb rd 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 re
SupportsFloatrl r3 r3 r3 r4 rj s rj )firstsecondr1 c C s | t kr |S | S r2 )_unset)rn ro r3 r3 r4
_first_set s rq 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 )rt superrl )r\ rt r? r3 r4 rl s zRetryError.__init__z
t.NoReturnrV c C s | j jr| j | d S r2 )rt failedresultr[ r3 r3 r4 reraise s
zRetryError.reraisec C s | j j d| j dS )N[])r? r@ rt r[ r3 r3 r4 rd s zRetryError.__str__) r@ rM rN rO rl ry rg rd
__classcell__r3 r3 rv r4 rr s rr 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 rl s zAttemptManager.__init__NrV c C s d S r2 r3 r[ 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 rl r re ri 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_sleepry retry_error_clsretry_error_callbackc C sJ || _ || _|| _|| _|| _|| _|| _|| _t | _
| | _ |
| _ d S r2 )
r r r r5 r r r ry threadinglocal_localr r r\ r r r r5 r r r ry r r r3 r3 r4 rl s
zBaseRetrying.__init__) r r r r5 r r r ry 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? rq r r r r5 r r r ry 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 r[ r3 r3 r4 rb s JzBaseRetrying.__repr__c C s4 z
| j jW S tk
r. i | j _| j j Y S X 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
statisticsAttributeErrorr[ 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 f| |S r2 r3 )r r r: r\ r3 r4 wrapped_fD s z%BaseRetrying.wraps..wrapped_f)r kwargsr1 c s j | | S r2 )r rG )r r r r3 r4
retry_withH s z&BaseRetrying.wraps..retry_with) functoolsrG re 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 monotonicr[ r3 r3 r4 beginP s
zBaseRetrying.begin)r r1 c C s( |j }|d kr(| jd k r"| | t S |j jo>t|j t}|sX| j|dsX| S | j d k rl| | |j
| j d< | j |dr| j
r|
|S | |}| jr| || | jr| j|d}nd}t||_| j|7 _| j d |7 < | j d d7 < | jd k r | | t|S )Nr delay_since_first_attempt r r r )outcomer rP rw r< exceptionrL r5 rx r seconds_since_startr r r r ry r rj next_actionr r rR )r\ r futis_explicit_retry retry_excr r3 r3 r4 iterV s8
zBaseRetrying.iterc c sb | t| d di d}| j|d}t|tr) r rw r r? r@ rx rk roundr r r )r\ rx r sleptclsnamer3 r3 r4 rb s
zRetryCallState.__repr__)r@ rM rN rO r re ri r- r rl r rk r r r Tupler r r rb r3 r3 r3 r4 r~ s "r~ )rA )rE )Zr r r r typingre r= abcr r
concurrentr inspectr r5 r r r r
r r r
r r r r r r napr r r r r r r r r r r r r r r! r" r# r$ wait_full_jitterr r% r& r r' r( r r) r* rB
TYPE_CHECKINGtypesr+ r, TypeVarr r- r/ overloadr r ExceptionrL r NO_RESULTrP rk rR rS rj rp rq rr r} r rF rs r~ pip._vendor.tenacity._asynciorA Z pip._vendor.tenacity.tornadowebrE r3 r3 r3 r4 s
$, " -F