`miN J d dl Z d dlZd dlZd dlmZ ej rd dlmZ G d de j Z G d de Z G d d e Z
G d
d e Z G d d
e Z G d de Z
G d de Z G d de Z G d de ZdS ) N)_utils)RetryCallStatec j e Zd ZdZej dddefd Zd dZdd de j
d fd
Z d S )
wait_basez(Abstract base class for wait strategies. retry_stater returnc d S N selfr s /builddir/build/BUILDROOT/alt-python311-pip-21.3.1-4.el9.x86_64/opt/alt/python311/lib/python3.11/site-packages/pip/_vendor/tenacity/wait.py__call__zwait_base.__call__ s other wait_combinec " t | | S r
)r r
r s r __add__zwait_base.__add__" s D%(((r )r r c < |dk r| S | | S Nr )r r s r __radd__zwait_base.__radd__% s" A::K||E"""r N)r r r r ) __name__
__module__ __qualname____doc__abcabstractmethodfloatr r typingUnionr r r r r r s 22
$4
) ) ) )#k #fl;V.W # # # # # #r r c 2 e Zd ZdZdeddfdZdddefdZdS )
wait_fixedzCWait strategy that waits a fixed amount of time between each retry.waitr Nc || _ d S r
r# )r
r$ s r __init__zwait_fixed.__init__/ s
r r r c | j S r
r& r s r r zwait_fixed.__call__2 s
r )r r r r r r' r r r r r# r# , s_ MM U t $4 r r# c $ e Zd ZdZd fd Z xZS ) wait_nonez7Wait strategy that doesn't wait at all before retrying.r Nc J t d d S r )superr' )r
__class__s r r' zwait_none.__init__9 s!
r )r N)r r r r r'
__classcell__r- s @r r* r* 6 sC AA r r* c l e Zd ZdZd dej eef dej eef ddfdZd d
defd Z dS )
wait_randomzAWait strategy that waits a random amount of time between min/max.r minmaxr Nc " || _ || _ d S r
)wait_random_minwait_random_max)r
r3 r4 s r r' zwait_random.__init__@ s " " r r r c X | j t j | j | j z
z z S r
)r6 randomr7 r s r r zwait_random.__call__D s' #v}$:NQUQe:e'fggr )r r2 )
r r r r r r! intr r' r r r r r1 r1 = s KK# #FLe 4 #v|CQVJ?W #`d # # # #h$4 h h h h h h hr r1 c 2 e Zd ZdZdeddfdZdddefdZdS ) r z#Combine several waiting strategies.
strategiesr Nc || _ d S r
)
wait_funcsr
r< s r r' zwait_combine.__init__K
$r r r c D t fd| j D S )Nc 3 0 K | ]} | V dS )r Nr ).0xr s r z(wait_combine.__call__..O s0 GG!11---GGGGGGr )sumr> r s `r r zwait_combine.__call__N s( GGGGtGGGGGGr r r r r r r' r r r r r r r H sg --%I %$ % % % %H$4 H H H H H H Hr r c 2 e Zd ZdZdeddfdZdddefdZdS )
wait_chaina Chain two or more waiting strategies.
If all strategies are exhausted, the very last strategy is used
thereafter.
For example::
@retry(wait=wait_chain(*[wait_fixed(1) for i in range(3)] +
[wait_fixed(2) for j in range(5)] +
[wait_fixed(5) for k in range(4)))
def wait_chained():
print("Wait 1s for 3 attempts, 2s for 5 attempts and 5s
thereafter.")
r< r Nc || _ d S r
)r< r? s r r' zwait_chain.__init__b r@ r r r c t t |j d t | j }| j |dz
} || S )Nr2 rC )r3 r4 attempt_numberlenr< )r
r wait_func_no wait_funcs r r zwait_chain.__call__e sL 3{ 91==s4??S?STT OL1$45 y[1111r rH r r r rJ rJ R sc
%I %$ % % % %2$4 2 2 2 2 2 2 2r rJ c e Zd ZdZddej fdej ee f dej ee f dej ee f ddfd Z
d
d de fd Z dS )
wait_incrementingzWait an incremental amount of time after each attempt.
Starting at a starting value and incrementing by a value for each attempt
(and restricting the upper limit to some maximum value).
r d start incrementr4 r Nc 0 || _ || _ || _ d S r
)rT rU r4 )r
rT rU r4 s r r' zwait_incrementing.__init__r s
"r r r c | | j | j |j dz
z z }t dt || j S Nr2 r )rT rU rM r4 r3 )r
r results r r zwait_incrementing.__call__| s9 t~1Ka1O PQ1c&$(++,,,r r r r r r MAX_WAITr r! r: r r' r r r r rR rR k s +,.1(. |CJ' <U
+ \#u*
%
-$4 - - - - - - -r rR c e Zd ZdZdej ddfdej ee f dej ee f dej ee f dej ee f d d
f
d Z
d d
d e fdZ d
S )wait_exponentiala Wait strategy that applies exponential backoff.
It allows for a customized multiplier and an ability to restrict the
upper and lower limits to some maximum and minimum value.
The intervals are fixed (i.e. there is no jitter), so this strategy is
suitable for balancing retries against latency when a required resource is
unavailable for an unknown duration, but *not* suitable for resolving
contention between multiple processes for a shared resource. Use
wait_random_exponential for the latter case.
r2 r
multiplierr4 exp_baser3 r Nc > || _ || _ || _ || _ d S r
)r_ r3 r4 r` )r
r_ r4 r` r3 s r r' zwait_exponential.__init__ s$ %
r r r c | j |j dz
z }| j |z }n# t $ r
| j cY S w xY wt t d| j t || j S rX )r` rM r_
OverflowErrorr4 r3 )r
r exprY s r r zwait_exponential.__call__ sw -K$>$BCC_s*FF 8OOO 3q$(##S%:%:;;;s 33rZ r r r r] r] s
01(.-.()
!
!Le,
! \#u*
%
! ,sEz*
!
\#u*
%
!
!
!
!
!<$4 < < < < < < rm s "
' ' ' ' ' ' 4333333# # # # # # # #"
h h h h h) h h hH H H H H9 H H H2 2 2 2 2 2 2 22- - - - - - - -, < < < <