OwlCyberSecurity - MANAGER
Edit File: _asyncio.cpython-39.pyc
a �F�f� � @ s� d dl Z d dlZd dlZd dlmZ d dlmZ d dlmZ d dlm Z d dlm Z d dlm Z e� d�Z ej d ejd ejej f d �ZG d d � d e�ZdS )� N)�sleep)�AttemptManager)� BaseRetrying)� DoAttempt)�DoSleep)�RetryCallState�WrappedFnReturnT� WrappedFn.)�boundc s� e Zd ZU ejegejej f ed< e fejegejej f ejdd�� fdd� Z e ejeje d�dd�Z ejeddf d �d d �Zd d �d d �Zed �dd�Ze e d�� fdd� Z� ZS )� AsyncRetryingr N)r �kwargs�returnc s t � jf i |�� || _d S �N)�super�__init__r )�selfr r �� __class__� �_/home/gouroczh/virtualenv/test/3.9/lib/python3.9/site-packages/pip/_vendor/tenacity/_asyncio.pyr $ s zAsyncRetrying.__init__)�fn�argsr r c � s� | � � t| |||d�}| j|d�}t|t�rtz||i |��I d H }W n tyf |�t�� � Y q�0 |� |� qt|t �r�|� � | � |�I d H q|S qd S )N)� retry_objectr r r �� retry_state) �beginr �iter� isinstancer � BaseException� set_exception�sys�exc_info� set_resultr �prepare_for_next_attemptr )r r r r r �do�resultr r r �__call__( s zAsyncRetrying.__call__)r c C s t d��d S )Nz$AsyncRetrying object is not iterable)� TypeError�r r r r �__iter__= s zAsyncRetrying.__iter__c C s | � � t| d di d�| _| S )Nr )r r r )r r � _retry_stater( r r r � __aiter__@ s zAsyncRetrying.__aiter__c � sb | j | jd�}|d u r t�q t|t�r2t| jd�S t|t�rX| j�� | �|�I d H q t�q d S )Nr ) r r* �StopAsyncIterationr r r r r# r )r r$ r r r � __anext__E s zAsyncRetrying.__anext__)r r c sF t � �� �� t�� �tjtjtjd�� fdd� �}� j|_� j|_|S )N)r r r c � s � | i |��I d H S r r )r r �r r r � async_wrappedV s z*AsyncRetrying.wraps.<locals>.async_wrapped)r �wraps� functools�t�Any�retry� retry_with)r r r/ r r. r r0 R s zAsyncRetrying.wraps)�__name__� __module__� __qualname__r2 �Callable�float� Awaitabler3 �__annotations__r r r r r& � Generatorr r) r+ r- r0 � __classcell__r r r r r ! s 0 � r )r1 r �typingr2 Zasyncior �pip._vendor.tenacityr r r r r �TypeVarr r9 r; r3 r r r r r r �<module> s