Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/tenacity/asyncio/__pycache__/__init__.cpython-39.pyc
Ðазад
a _�h] � @ sN d dl Z d dlZd dlZd dlZd dlmZ d dlmZ d dlmZ d dlmZ d dlm Z d dlm Z d dlm Z d d lm Z d d lm Z d d lmZ d d lmZ d dlmZ d dlmZ d dlmZ dd lmZ ejr�d dlmZ d dlmZ e�d�Zejdej dej ej f d�Z e ej d d�dd�Z!G dd � d e�Z"g d �Z#dS ) � N)�AttemptManager)� BaseRetrying)� DoAttempt)�DoSleep)�RetryCallState)� RetryError)� after_nothing)�before_nothing)�_utils� )� RetryBaseT)� retry_all)� retry_any)�retry_if_exception)�retry_if_result� )� StopBaseT)� WaitBaseT�WrappedFnReturnT� WrappedFn.)�bound)�seconds�returnc C sB dt jv r0dd l}dd l}|�� dkr0|�| �S dd l}|�| �S )N�trior )�sys�modulesr �sniffioZcurrent_async_library�sleep�asyncio)r r r r � r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/tenacity/asyncio/__init__.py�_portable_async_sleep1 s r! c s� e Zd Zeejjej�� e� � e e dde df e je jeef ge jde jd f f ddde jdge jde jd f f e jdge jde jd f f e je jdge jde jd f f ee jd e je jdge je je je j f f dd� � fd d � Zee je jed �d d �Ze jde jf dd�dd�Zddd�dd�Z ddd�dd�Z ddd�dd�Z de je e e jf d�dd�Z!e j"e#ddf d�d d �Z$d d�d d �Z%e#d�d d!�Z&eed�� fd"d#� Z'� Z(S )$� AsyncRetryingNFr r z#t.Union[SyncRetryBaseT, RetryBaseT]r r ) r �stop�wait�retry�before�after� before_sleep�reraise�retry_error_cls�retry_error_callbackr c s$ t � j||||||||| | d� d S )N) r r# r$ r% r& r' r( r) r* r+ )�super�__init__) �selfr r# r$ r% r& r' r( r) r* r+ �� __class__r r r- D s �zAsyncRetrying.__init__)�fn�args�kwargsr c � s� | � � t| |||d�}| j|d�I d H }t|t�rzz||i |��I d H }W n tyl |�t�� � Y q�0 |� |� qt|t �r�|� � | � |�I d H q|S qd S )N)Z retry_objectr1 r2 r3 �� retry_state) �beginr �iter� isinstancer � BaseExceptionZ set_exceptionr �exc_infoZ set_resultr �prepare_for_next_attemptr )r. r1 r2 r3 r5 �do�resultr r r �__call__h s zAsyncRetrying.__call__.)r1 r c C s | j j�t�|�� d S �N)� iter_state�actions�appendr �wrap_to_async_func)r. r1 r r r �_add_action_func} s z AsyncRetrying._add_action_func)r5 r c � s t �| j�|�I d H | j_d S r? )r rC r% r@ Zretry_run_result�r. r5 r r r � _run_retry� s �zAsyncRetrying._run_retryc � s, | j r t�| j �|�I d H }nd}||_d S )Ng )r$ r rC Zupcoming_sleep)r. r5 r r r r � _run_wait� s zAsyncRetrying._run_waitc � s* |j | jd< t�| j�|�I d H | j_d S )NZdelay_since_first_attempt)Zseconds_since_start� statisticsr rC r# r@ Zstop_run_resultrE r r r � _run_stop� s �zAsyncRetrying._run_stopc � s. | � |� d }| jjD ]}||�I d H }q|S r? )Z _begin_iterr@ rA )r. r5 r= �actionr r r r7 � s zAsyncRetrying.iter)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 )r1 r2 r3 )r6 r � _retry_staterL r r r � __aiter__� s zAsyncRetrying.__aiter__c � sh | j | jd�I d H }|d u r"t�q t|t�r8t| jd�S t|t�r^| j�� | �|�I d H q t�q d S )Nr4 ) r7 rN �StopAsyncIterationr8 r r r r; r )r. r< r r r � __anext__� s zAsyncRetrying.__anext__c sV t � ���}t��tjd �tjtjtjd�� ��fdd� �� �� _|j� _i � _� S )N)� __defaults__�__kwdefaults__)r2 r3 r c � s, �� � }|j� _|�g| �R i |��I d H S r? )�copyrH )r2 r3 rT �� async_wrappedr1 r. r r rV � s z*AsyncRetrying.wraps.<locals>.async_wrapped) r, �wraps� functools�WRAPPER_ASSIGNMENTS�t�Anyr% � retry_withrH )r. r1 �wrappedr/ rU r rW � s �"zAsyncRetrying.wraps))�__name__� __module__� __qualname__r! �tenacityr# Z stop_neverr$ Z wait_noneZretry_if_exception_typer r r rZ �Callable�Union�int�float� Awaitable�Optional�bool�Typer[ r- r r r> rD rF rG rI r r r7 � Generatorr rM rO rQ rW � __classcell__r r r/ r r" C s^ �"��� �"��% � � r" )r r r r r r" )$rX r �typingrZ ra r r r r r r r r r r% r r r r r ZSyncRetryBaseT� TYPE_CHECKINGZ tenacity.stopr Z tenacity.waitr �TypeVarr rb rf r[ r re r! r" �__all__r r r r �<module> s6
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка