2bi
P F S SK r S SKrS SKrS SKrS SKrS SKrS SKJrJ r S SK
J r S SK J
r
SSKJr SSKJr SSKJr SS KJr SS
KJr SS KJr SS KJr SS
KJr SSKJr SSKJr SSKJr SSKJr SSKJr SSKJ r SSK J r SSK J r SSK J!r! SSK J"r" SSK J#r# SSK J$r$ SSK J%r% SSK J&r& SS K'J(r( SS K'J)r) SS K'J*r* SS K'J+r+ SS K'J,r, SS!K'J-r- SS"K'J.r. SS#K'J/r/ SS#K'J/r0 SS$K'J1r1 SS%K2J3r3 SS&K2J4r4 SS'K5J6r6 SS(K5J7r7 SS)K8J9r9 SS*K8J:r: Sr;\Rx ( a S SK=r=SS+KJ>r> SS,K J?r? SS-K'J@r@ \R " S.5 rB\R " S/\R S0\R 4 S19rE " S2 S3\F5 rG\H" 5 rI " S4 S55 rJ " S6 S7\K5 rL " S8 S95 rM " S: S;\M5 rN\H" 5 rOS<\R \R \H4 S=\R S>\R 4S? jrQ " S@ SA\F5 rR " SB SC5 rS " SD SE\5 rT " SF SG\T5 rU\R S SH: a \ R \R rXO \ R rX " SI SJ\X5 rW " SK SL5 rY\R SM\ES>\E4SN j5 r\R \ \%\-" 5 \" 5 \4\7SSO\RS4
SP\R \R \[\K4 /S4 SQSRSSSTSUSVSW\R SL/S4 SX\R SL/S4 SY\R \R SL/S4 SZ\]S[\R SA S\\R \R SL/\R 4 S>\R \E/\E4 4S] jj5 rS^\R S_\R S>\R 4S` jrS SaK_J`r` \;( a S SbKaJbrb / ScQrcg)d N)ABCabstractmethod)futures)iscoroutinefunction )
retry_base) retry_all) retry_always) retry_any)retry_if_exception)retry_if_exception_type) retry_if_exception_cause_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)wait_exponential_jitter)
before_log)before_nothing) after_log)
after_nothing)before_sleep_log)before_sleep_nothing)
RetryBaseT) StopBaseT) WaitBaseTWrappedFnReturnT WrappedFn.)boundc \ rS rSrSrSrg)TryAgaine z/Always retry the executed function when raised. N)__name__
__module__ __qualname____firstlineno____doc____static_attributes__r7 ڏ/builddir/build/BUILDROOT/alt-python313-pip-23.3.1-3.el8.x86_64/opt/alt/python313/lib/python3.13/site-packages/pip/_vendor/tenacity/__init__.pyr5 r5 e s 9r> r5 c \ rS rSrSrg) DoAttemptl r7 Nr8 r9 r: r; r= r7 r> r? rA rA l r> rA c \ rS rSrSrg)DoSleepp r7 NrC r7 r> r? rF rF p rD r> rF c \ rS rSr% SrSr\R \ \ S' Sr
\R \ \ S' S\4S jr S\4S jr
Srg)
BaseActiont a! 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
r7 REPR_FIELDSNNAMEreturnc ^ SR U 4S jT R 5 5 nT R R SU S3$ )Nz, c 3 F ># U H o S [ TU5 < 3v M g7f)=N)getattr).0fieldselfs r? &BaseAction.__repr__.. s$ `O_equ)=(@ AO_s !())joinrK __class__r8 )rT state_strs ` r? __repr__BaseAction.__repr__ s; II `tO_O_ `` ..))*!I;a88r> c [ U 5 $ N)reprrT s r? __str__BaseAction.__str__ s Dzr> )r8 r9 r: r; r< rK tSequencestr__annotations__rL Optionalr\ rb r= r7 r> r? rI rI t sE $&KC % D!**S/ 9# 9 r> rI c B \ rS rSrSrSrS\R SS4S jrSr g) RetryAction r retryr rM Nc $ [ U5 U l g r_ )floatr )rT r s r? __init__RetryAction.__init__ s
5\
r> )
r8 r9 r: r; rK rL rd
SupportsFloatro r= r7 r> r? rj rj s# K D"aoo "$ "r> rj firstsecondrM c U [ L a U$ U $ r_ )_unset)rr rs s r?
_first_setrv s f_6/%/r> c H ^ \ rS rSrSrSU 4S jjrS S jrS\4S jrSr U =r
$ )
RetryError z>Encapsulates the last attempt instance right before giving up.rM c 0 > Xl [ TU ] U5 g r_ ) last_attemptsuperro )rT r{ rZ s r? ro RetryError.__init__ s (
&r> c p U R R ( a U R R 5 eU er_ )r{ failedresultra s r? reraiseRetryError.reraise s+ # ###**, ,
r> c N U R R SU R S3$ )N[])rZ r8 r{ ra s r? rb RetryError.__str__ s' ..))*!D,=,=+>a@@r> )r{ )r{ FuturerM N)rM z
t.NoReturn) r8 r9 r: r; r< ro r rf rb r=
__classcell__rZ s @r? rx rx s$ H'
A A Ar> rx c \ rS rSrSrS
S jrSS jrS\R \R \
S\R \
S \R S
S\R \ 4S jr S r
g)AttemptManager zManage attempt context.c Xl g r_ retry_state)rT r s r? ro AttemptManager.__init__ s &r> rM Nc g r_ r7 ra s r? __enter__AttemptManager.__enter__ s r> exc_type exc_value tracebackztypes.TracebackTypec Ub! Ub U R R XU45 gU R R S 5 g )NT)r
set_exception
set_result)rT r r r s r? __exit__AttemptManager.__exit__ sD I$9 * *H+K L
' ' -r> r )r RetryCallStaterM N)r8 r9 r: r; r< ro r rd rh Type
BaseExceptionboolr r= r7 r> r? r r sh !'
**QVVM 23 ::m, :: 34
D r> r c ~ \ rS rSr\\\" 5 \" 5 \\ SS\
S4
S\ R \ R \\4 /S4 SSSSS S
S \ R S /S4 S
\ R S /S4 S\ R \ R S /S4 S\S\ R$ \
S\ R \ R S /\ R& 4 4S jjr\\\\\\\\\\4
S\ R \ R \ R \\4 /S4 \4 S\ R S\4 S\ R S\4 S \ R \\4 S \ R \ R S /S4 \4 S
\ R \ R S /S4 \4 S\ R \ R \ R S /S4 \4 S\ R \\4 S\ R \ R$ \
\4 S\ R \ R \ R S /\ R& 4 \4 SS 4S jjrS\4S jr\S\ R8 \\ R& 4 4S j5 r S\ S\ 4S jr S#S jr SS S\ R \!\"\ R& 4 4S jr#S\ RH \%SS4 4S jr&\'S \ R S \(4 S \ R& S \ R& S\(4S! j5 r)S"r*g)$ BaseRetrying NFr stopr/ waitr0 rl r. beforer after before_sleepr retry_error_clsretry_error_callbackc Xl X l X0l X@l XPl X`l Xpl Xl [ R " 5 U l
Xl Xl g r_ )
r r r rl r r r r threadinglocal_localr r rT r r r rl r r r r r r s r? ro BaseRetrying.__init__ sG
( oo' . $8!r> rM c U R [ XR 5 [ X R 5 [ X0R 5 [ X@R
5 [ XPR 5 [ X`R 5 [ XpR 5 [ XR 5 [ XR 5 [ XR 5 S9
$ )z8Copy this object with some parameters changed if needed.
r r r rl r r r r r r ) rZ rv r r r rl r r r r r r r s r? copyBaseRetrying.copy s ~~ UJJ/D)),D)), UJJ/ fkk2 UJJ/#L2C2CD w 5 &8L8L M!+,@B[B[!\
r> c SU R R S[ U 5 S SU R SU R SU R
SU R SU R S U R S
3$ ) N) rZ r8 idr r r rl r r ra s r? r\ BaseRetrying.__repr__ s ''(
bhq\ BII; II; ZZL !ZZL !kk] #ZZL
$
r> c U R R $ ! [ ad [ R " [ R
[ [ R 4 0 5 U R l U R R s $ f = f)a 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).
)r
statisticsAttributeErrorrd castDictrf Anyra s r? r BaseRetrying.statistics s^ , *;;)) ) *%&VVAFF3:,>%CDKK ";;)) ) *s A+BBfc & ^ ^ [ R " T5 S[ R S[ R S[ R 4UU 4S jj5 nS[ R S[ R S[ 4UU 4S jjnT Ul X2l U$ )zKWrap a function for retrying.
:param f: A function to wraps for retrying.
argskwrM c > T" T/U Q70 UD6$ r_ r7 )r r r rT s r? wrapped_f%BaseRetrying.wraps..wrapped_f! s 'D'B' 'r> kwargsc F > TR " U 0 UD6R T5 $ r_ )r wraps)r r r rT s r?
retry_with&BaseRetrying.wraps..retry_with% s" 99d-f-33A6 6r> ) functoolsr rd r r2 rl r )rT r r r s `` r? r BaseRetrying.wraps s}
(QUU (!%% (AEE (
( 7aee 7quu 7 7 7 ) r> c U R R 5 [ R " 5 U R S' SU R S' SU R S' g )N
start_timer attempt_numberr idle_for)r cleartime monotonicra s r? beginBaseRetrying.begin- sD (,(8 %,-()&'
#r> r c UR nUc( U R b U R U5 [ 5 $ UR =( a [ UR 5 [ 5 nU( d& U R U5 ( d UR 5 $ U R b U R U5 UR U R S' U R U5 ( ad U R ( a U R U5 $ U R U5 nU R ( a UR 5 eXBR 5 eU R ( a U R! U5 nOSn[# U5 Ul U=R& U-
sl U R S== U-
ss' U R S== S-
ss' U R( b U R) U5 [+ U5 $ )Ndelay_since_first_attempt r r r )outcomer rA r
isinstance exceptionr5 rl r r seconds_since_startr r r r r r rj next_actionr r rF )rT r futis_explicit_retry retry_excr s r? iterBaseRetrying.iter3 st !! ;{{& K( ; JJ P:cmmox+P!TZZ %<%<::< :: ! JJ{ #7B7V7V34 99[ ! !((00== ,,S1I|| '')) 0 99IIk*EE"-e"4 %
#u,# ()Q.) ( k *u~ r> c # # U R 5 [ U S S0 S9n U R US9n[ U[ 5 ( a [ US9v O8[ U[ 5 ( a" UR 5 U R U5 Og Mj 7f)Nr7 )fnr r r ) r r r r rA r rF prepare_for_next_attemptr )rT r dos r? __iter__BaseRetrying.__iter__X su
$TdBG {3B"i(($==B((446
2 s BB
r .r r c g r_ r7 )rT r r r s r? __call__BaseRetrying.__call__f s
r> ) r r r r r rl r r r r r r )+r8 r9 r: r; r r r$ r
r) r+ rx rd CallableUnionintrn rh r r r ro ru objectr r rf r\ propertyr r r2 r r rA rF r Generatorr r r r1 r r= r7 r> r? r r s :? & %K 5 77E6CIM .8RV9zz1773:./569 9 9
9
,-t34
9 zz+,d239 jj-=,>,D!EF9 9
+9 jj5E4F4M)N O96 KQ-3-3-3HNGMZ`)/?Eci
wwqzz1773:#6"7"=>FG
ggk6)*
ggk6)*
wwz6)*
$4#5t#; r c x \ rS rSrSrS\R S\4 S\R S\R S\4S jr S r
g
) Retryingip zRetrying controller.r .r r rM c U R 5 [ XX#S9n U R US9n[ U[ 5 ( a U" U0 UD6nUR U5 O9[ U[ 5 ( a" UR 5 U R U5 OU$ Mz ! [ a' UR [ R " 5 5 N2f = f)N) retry_objectr r r r )
r r r r rA r r r sysexc_inforF r r )rT r r r r r r s r? r Retrying.__call__s s
$$DX {3B"i((3 0 0F **62B((446
2
% > --clln=>s B .CCr7 N) r8 r9 r: r; r< rd r r1 r r r= r7 r> r? r r p sG
JJs ,, - uu %%
r> r c ^ \ rS rSrSrS\SS4U 4S jjr\S\4S j5 r \
S\S\ R S \SS 4S
j5 r
S rU =r$ ) r i zDEncapsulates a (future or past) attempted call to a target function.r rM Nc . > [ TU ] 5 Xl g r_ )r| ro r )rT r rZ s r? ro Future.__init__ s
,r> c & U R 5 SL$ )z8Return whether a exception is being held in this future.N)r ra s r? r
Future.failed s ~~ t++r> value
has_exceptionc l U " U5 nU( a UR U5 U$ UR U5 U$ )z Construct a new Future object.)r r )clsr r r r s r? constructFuture.construct s9 .! e $
NN5 !
r> )r )r8 r9 r: r; r< r ro r r r classmethodrd r r r= r r s @r? r r si N-s -t - , , , s 155 RZ r> r c
4 \ rS rSrSrS\S\R \ S\R S\R SS4
S jr
\ S\R \ 4S
j5 r
SS jrS \R SS4S
jrS\R \R" \ \S4 SS4S jrS\4S jrSrg)r i z5State related to a single call wrapped with Retrying.r r r r rM Nc [ R " 5 U l Xl X l X0l X@l SU l S U l S U l SU l
S U l g )Nr r ) r r r r r r r r r outcome_timestampr r )rT r r r r s r? ro RetryCallState.__init__ sO ..* ( $%+/ 48 "
48r> c P U R c g U R U R -
$ r_ )r
r ra s r? r "RetryCallState.seconds_since_start s& ! ! )%%77r> c X S U l S U l U =R S-
sl S U l g Nr )r r
r r ra s r? r 'RetryCallState.prepare_for_next_attempt s* !% q r> valc [ R " 5 n[ U R 5 nUR U5 X2sU l U l g r_ )r r r r r r r
)rT r tsr s r? r RetryCallState.set_result s9
^^
T(() s/2, d,r> r ztypes.TracebackType| Nonec [ R " 5 n[ U R 5 nUR US 5 X2sU l U l g r )r r r r r r r
)rT r r r s r? r RetryCallState.set_exception sA ^^
T(() (1+&/2, d,r> c U R c SnOpU R R ( a8 U R R 5 nSUR R SU S3nO SU R R 5 3n[
[ U R S5 5 nU R R nSU S[ U 5 SU R S U S
U S 3 $ ) Nznone yetzfailed ( rX z returned r z : attempt #z ; slept for z; last result: >) r r r rZ r8 r rn roundr r r )rT r r sleptclsnames r? r\ RetryCallState.__repr__ s << F
\\
..0I 3 3 < < =QykKF !4!4!6 78FeDMM1-...))7)1RXJk$2E2E1FlSXRYYhiohppqrrr> )
r r r r r r r r
r r r )r8 r9 r: r; r< r rd rh r2 r ro r rn r r r Tupler r r rf r\ r= r7 r> r? r r s ?9"9
JJy !9 ee 9
9
9: 8QZZ%6 8 8
7aee 7 7 7} 5}Fa ab7
7 s# sr> r funcc g r_ r7 )r s r? rl rl s r> Fr r r/ r r0 rl r. r r r r r r c
g r_ r7 r s
r? rl rl s r> dargsdkwc ^ ^ [ T 5 S:X a& [ T S 5 ( a [ 5 " T S 5 $ S[ S[ 4U U4S jjnU$ )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 r rM c > [ U [ 5 ( aE [ R " SU R R
SU R R
S35 [
U 5 ( a [ T0 TD6nOe[ ( aO [ [ R S5 ( a0 [ R R U 5 ( a [ T0 TD6nO [ T0 TD6nUR U 5 $ )NzGot retry_base instance (zQ) as callable argument, this will probably hang indefinitely (did you mean retry=z(...)?)is_coroutine_function)r r warningswarnrZ r8 r
AsyncRetryingtornadohasattrgenr' TornadoRetryingr r )r rr# r$ s r? wrapretry..wrap s !Z((
/ 0D0D/E FPPQP[P[PdPdOeeln
#1%%!50C0WW[[2I J Jw{{OpOpqrOsOs#U2c2 e+s+771: r> )lencallablerl r2 )r# r$ r0 s `` r? rl rl sN 5zQ8E!H--wuQx I ) r> )r* )r. )5r r r
r r r
r r r r r r r 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- rl r2 r5 NO_RESULTrA rF rI rj rx r r r r r r* )dr r r r typingrd r( abcr r
concurrentr inspectr rl r 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& r4 r' r r( r) r r* r+ r r, r- r+
TYPE_CHECKINGtypesr. r/ r0 TypeVarr1 r r r2 Exceptionr5 r r5 rA rn rF rI rj ru r rv rx r r r version_infor FutureGenericTr overloadr rh r r pip._vendor.tenacity._asyncior* pip._vendor.tenacity.tornadowebr. __all__r7 r> r? rE s (
# ' % * 0 . & " . - 1 " % " % " # ) = ) " + . ??! 99 /0
IIkCJ)? @ :y :
H e ("* "
0aggaeeVm, 0aee 0 0
A
A 0n
3 n
b| 8 A! ^^AEE*N ^^N^ .Es EsP i 5:"! 133A2?EI,6NR ::qwwsEz*+T1 2
JJ()4/ 0
::'($. /
**QZZ)9(:D(@ AB VVL) **QZZ1A0BAEE0I%JK ZZ Y&' !%% !%% < 8
?6 r>