U
ʗRe @ s d dl Z d dlZd dlZd dlmZ d dlmZ d dlmZ d dlmZ d dlm Z d dlm
Z
ej dej d Z
e d
ZG d d d eZdS )
N)sleep)AttemptManager) BaseRetrying) DoAttempt)DoSleep)RetryCallState WrappedFn)bound_RetValTc s e Zd Zefejegejf ejdd fdd
Z ejdeje
f ejeje
dddZ d d d
d Z ej
eejf d d d
Zeed fdd Z ZS )
AsyncRetryingN)r kwargsreturnc s t jf | || _d S N)super__init__r )selfr r __class__ /builddir/build/BUILDROOT/alt-python38-pip-22.2.1-2.el8.x86_64/opt/alt/python38/lib/python3.8/site-packages/pip/_vendor/tenacity/_asyncio.pyr " s zAsyncRetrying.__init__.)fnargsr r
c s | t| |||d}| j|d}t|trrz|||I d H }W n" tk
rd |t Y qX | | qt|t
r| | |I d H q|S qd S )N) retry_objectr r r retry_state)
beginr iter
isinstancer
BaseException
set_exceptionsysexc_info
set_resultr prepare_for_next_attemptr )r r r r r doresultr r r __call__& s
zAsyncRetrying.__call__)r
c C s | t| d di d| _| S )Nr )r r r )r r _retry_state)r r r r __aiter__> s zAsyncRetrying.__aiter__c sb | j | jd}|d kr tq t|tr2t| jdS t|trX| j | |I d H q |S q d S )Nr ) r r' StopAsyncIterationr r r r r# r )r r$ r r r __anext__C s
zAsyncRetrying.__anext__)r r
c sF t t tjtjtjd fdd } j|_ j|_|S )N)r r r
c s | |I d H S r r )r r r r r
async_wrappedT s z*AsyncRetrying.wraps..async_wrapped)r wraps functoolstypingAnyretry
retry_with)r r r, r r+ r r- P s zAsyncRetrying.wraps)__name__
__module__ __qualname__r r/ Callablefloat Awaitabler0 r r
r& r( Unionr r* r r-
__classcell__r r r r r ! s *
r )r. r r/ asyncior pip._vendor.tenacityr r r r r TypeVarr6 r r
r r r r r s