OwlCyberSecurity - MANAGER
Edit File: _asyncio.cpython-38.pyc
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 e�ZdS ) � N)�sleep)�AttemptManager)� BaseRetrying)� DoAttempt)�DoSleep)�RetryCallState� WrappedFn)�bound�_RetValTc s� e Zd Zefejegejf ejdd�� fdd� Z ejdeje f ejeje d�dd�Z d d �d d �Z ej eejf d �d d �Zeed�� fdd� Z� ZS )� AsyncRetryingN)r �kwargs�returnc 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__.)�fn�argsr r c � s� | � � t| |||d�}| j|d�}t|t�rrz|||�I d H }W n" tk rd |�t�� � Y q�X |� |� 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 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 t�q t|t�r2t| jd�S t|t�rX| 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.<locals>.async_wrapped)r �wraps� functools�typing�Any�retry� retry_with)r r r, r r+ r r- P s zAsyncRetrying.wraps)�__name__� __module__� __qualname__r r/ �Callable�float� 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 �<module> s