dIp d dl Z d dlZd dlZd dlmZ d dlmZ d dlmZ d dlmZ d dlm Z d dlm
Z
ej dej Z
ej d
Z G d d e ZdS )
N)sleep)AttemptManager) BaseRetrying) DoAttempt)DoSleep)RetryCallState WrappedFn)bound_RetValTc e Zd Zefdej egej f dej ddf fd
Z dej dej e
f dej dej de
fd Z d
d
Z dej
eej f fd Zdedef fd Z xZS )
AsyncRetryingr kwargsreturnNc H t j di | || _ d S )N )super__init__r )selfr r __class__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/_asyncio.pyr zAsyncRetrying.__init__" s+ ""6"""
fn.argsc K | t | ||| } | | }t |t r[ ||i | d {V }| | n}# t $ r) | t j Y nKw xY wt |t r0| | | d {V n|S )N) retry_objectr r r T retry_state)
beginr iter
isinstancer
set_result
BaseException
set_exceptionsysexc_infor prepare_for_next_attemptr )r r r r r doresults r __call__zAsyncRetrying.__call__& s,
$$2DQWXXX
{33B"i((
3#%2t#6v#6#6 6 6 6 6 6 6F **62222 % > > > --clnn=====> B((
44666jjnn$$$$$$$$
s A; ;0B.-B.c ^ | t | d di | _ | S )Nr )r r r )r r _retry_state)r s r __aiter__zAsyncRetrying.__aiter__> s-
*4Dr" M M M r c > K | | j }|t t |t rt | j S t |t r5| j | | d {V n|S )NTr ) r r+ StopAsyncIterationr r r r r& r )r r' s r __anext__zAsyncRetrying.__anext__C s
t'899Bz((B **
%$2CDDDDB((
!::<<<jjnn$$$$$$$$
r c t t j dt j dt j dt j ffd }j |_ j |_ |S )Nr r r c $ K | i | d {V S )Nr )r r r s r
async_wrappedz*AsyncRetrying.wraps..async_wrappedT s. T,V,,,,,,,, ,r )r wraps functoolstypingAnyretry
retry_with)r r r2 r s ` r r3 zAsyncRetrying.wrapsP s
WW]]2
-vz -VZ -FJ - - - - -
- !h
#%=
r )r r
)__name__
__module__ __qualname__r r5 Callablefloat Awaitabler6 r r r) r, Unionr r/ r r3
__classcell__)r s @r r
r
! s+ KP fougv7G.G H \b\f ko OC!1(!; ; < z *
0
nfj.H!I i r r
)r4 r$ r5 asyncior pip._vendor.tenacityr r r r r TypeVarr< r r r
r r r rD s $
/ / / / / / - - - - - - * * * * * * ( ( ( ( ( ( / / / / / / FN;fo > > > 6>* % %; ; ; ; ; L ; ; ; ; ; r