File: //usr/local/lib/python3.7/site-packages/pip/_vendor/tenacity/__pycache__/tornadoweb.cpython-37.pyc
B
L��g^ � @ s| d dl Z d dlZd dlmZ d dlmZ d dlmZ d dlmZ d dlmZ ej r^d dl
m Z e� d�Z
G d d
� d
e�ZdS ) � N)� BaseRetrying)� DoAttempt)�DoSleep)�RetryCallState)�gen)�Future�_RetValTc sL e Zd Zejfdejdd�� fdd�
Zejdejejdd�d d
��Z � Z
S ) �TornadoRetryingz&typing.Callable[[float], Future[None]]N)�sleep�kwargs�returnc s t � jf |� || _d S )N)�super�__init__r
)�selfr
r )� __class__� �C/tmp/pip-unpacked-wheel-hv55ucu3/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])�fn�argsr r c o s� | � � t| |||d�}x�| j|d�}t|t�rpy|||�V }W n" tk
rb |�t�� � Y q�X |� |� qt|t
�r�|� � | � |�V qt
�|��qW d S )N)Z retry_objectr r r )� retry_state)�beginr �iter�
isinstancer �
BaseExceptionZ
set_exception�sys�exc_infoZ
set_resultr Zprepare_for_next_attemptr
r ZReturn)r r r r r Zdo�resultr r r �__call__$ s
zTornadoRetrying.__call__) �__name__�
__module__� __qualname__r r
�typing�Anyr � 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 �<module> s