o
ai @ 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 Zefdejegejf dejddf fdd
Z dejdeje
f d ejdejde
fd
d Z dd d
Z dej
eejf fddZdedef fdd Z ZS )
AsyncRetryingr kwargsreturnNc s t jdi | || _d S )N )super__init__r )selfr r __class__r /builddir/build/BUILDROOT/alt-python310-pip-21.3.1-5.el8.x86_64/opt/alt/python310/lib/python3.10/site-packages/pip/_vendor/tenacity/_asyncio.pyr " s
zAsyncRetrying.__init__fn.argsc s | t| |||d} | j|d}t|tr s zAsyncRetrying.__aiter__c s` | j | jd}|d u rtt|trt| jdS t|tr-| j | |I d H n|S q)NTr ) r r& StopAsyncIterationr r r r r" r )r r# r r r __anext__C s
zAsyncRetrying.__anext__c sJ t t dtjdtjdtjf fdd } j|_ j|_|S )Nr r r
c s | i |I d H S )Nr )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)r
r )__name__
__module__ __qualname__r r. Callablefloat Awaitabler/ 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 TypeVarr5 r r
r r r r r s