a
lja @ s| d dl Z d dlZd dlmZ d dlmZ d dlmZ d dlmZ d dlmZ ej r^d dl
m Z e dZ
G d d
d
eZdS ) N) BaseRetrying) DoAttempt)DoSleep)RetryCallState)gen)Future_RetValTc sL e Zd Zejfdejdd fdd
Zejdejejddd d
Z Z
S ) TornadoRetryingz&typing.Callable[[float], Future[None]]N)sleepkwargsreturnc s t jf i | || _d S )N)super__init__r
)selfr
r __class__ C/usr/lib/python3.9/site-packages/pip/_vendor/tenacity/tornadoweb.pyr s zTornadoRetrying.__init__zhtyping.Callable[..., typing.Union[typing.Generator[typing.Any, typing.Any, _RetValT], Future[_RetValT]]]z2typing.Generator[typing.Any, typing.Any, _RetValT])fnargsr r c o s | t| |||d}| j|d}t|trpz||i |V }W n tyb |t Y q0 | | qt|t
r| | |V qt
|qd S )N)Z retry_objectr r r ) retry_state)Zbeginr iter
isinstancer
BaseExceptionZ
set_exceptionsysexc_infoZ
set_resultr Zprepare_for_next_attemptr
r ZReturn)r r r r r Zdoresultr r r __call__$ s
zTornadoRetrying.__call__) __name__
__module__ __qualname__r r
typingAnyr coroutiner
__classcell__r r r r r s r )r r! Zpip._vendor.tenacityr r r r Ztornador
TYPE_CHECKINGZtornado.concurrentr TypeVarr r r r r r s