Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/tenacity/__pycache__/__init__.cpython-39.pyc
Ðазад
a _�h�] � @ sN d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlm Z m Z d dl m Z ddl mZ ddlmZ ddlmZ ddlmZ dd lmZ dd lmZ dd lmZ dd lmZ dd lmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlm Z ddlm Z ddl m Z ddl m Z ddl!m"Z" ddl!m#Z# ddl!m$Z$ ddl!m%Z% ddl!m&Z& ddl!m'Z' dd l!m(Z( dd l)m*Z* dd l)m+Z+ dd l)m,Z, dd l)m-Z- dd!l)m.Z. dd"l)m/Z/ dd#l)m0Z0 dd$l)m1Z1 dd$l)m1Z2 dd%l)m3Z3 dd&l4m5Z5 dd'l4m6Z6 dd(l7m8Z8 dd)l7m9Z9 dd*l:m;Z; dd+l:m<Z< z d dl=Z=W n e>�yX dZ=Y n0 ej?�r�d dl@Z@d d,lAmBZB dd-l mCZD dd.lmEZE dd/l!mFZF dd0l)mGZG e�Hd1�ZIejHd2ejJd3ejKf d4�ZLi ZMejNd5k�r�eM�Od6d7i� e jPf i eM��G d8d9� d9��ZQG d:d;� d;eR�ZSeT� ZUG d<d=� d=�ZVG d>d?� d?eW�ZXG d@dA� dA�ZYG dBdC� dCeY�ZZeT� Z[ej\ejKeTf ejKejKdD�dEdF�Z]G dGdH� dHeR�Z^G dIdJ� dJ�Z_G dKdL� dLe �Z`G dMdN� dNe`�ZaejNdOk�r�e jbejK Zcne jbZcG dPdQ� dQec�ZbG dRdS� dS�ZdejeeLeLdT�dUdV��Zejee e'e/� e� e6e9ddWe^df ejJej\efeWf gej\dejgd f f dXdYdZejJdSgej\dejgd f f ejJdSgej\dejgd f f ejhejJdSgej\dejgd f f eiejjdH ejhejJdSgej\ejKejgejK f f ejJeLgeLf d[� d\dV��ZejKejKejKd]�d^dV�Zd d_lkmlZl e=�rBd d`lmmnZn g da�ZodS )b� N)�ABC�abstractmethod)�futures� )�_utils)� retry_base)� retry_all)� retry_always)� retry_any)�retry_if_exception)�retry_if_exception_type)� retry_if_exception_cause_type)�retry_if_not_exception_type)�retry_if_not_result)�retry_if_result)� retry_never)�retry_unless_exception_type)�retry_if_exception_message)� retry_if_not_exception_message��sleep)�sleep_using_event)�stop_after_attempt)�stop_after_delay)�stop_before_delay)�stop_all)�stop_any)� stop_never)�stop_when_event_set)� wait_chain)� wait_combine)�wait_exponential)� wait_fixed)�wait_incrementing)� wait_none)� wait_random)�wait_random_exponential)�wait_exponential_jitter)� before_log)�before_nothing)� after_log)� after_nothing)�before_sleep_log)�before_sleep_nothing)�Self)�asyncio)� RetryBaseT)� StopBaseT)� WaitBaseT�WrappedFnReturnT� WrappedFn.)�bound)� � �slotsTc @ st e Zd ZU ejed�Zejej dgej f e d< dZ e e d< dZee d< dZe e d< dZe e d < d d �d d �Zd S )� IterState)�default_factory�RetryCallState�actionsF�retry_run_resultr �delay_since_first_attempt�stop_run_result�is_explicit_retryN��returnc C s" g | _ d| _d| _d| _d| _d S )NFr )r< r= r> r? r@ ��self� rE ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/tenacity/__init__.py�resetv s zIterState.reset)�__name__� __module__� __qualname__� dataclasses�field�listr< �t�List�Callable�Any�__annotations__r= �boolr> �intr? r@ rG rE rE rE rF r9 l s �" r9 c @ s e Zd ZdZdS )�TryAgainz/Always retry the executed function when raised.N)rH rI rJ �__doc__rE rE rE rF rU ~ s rU c @ s e Zd ZdS )� DoAttemptN�rH rI rJ rE rE rE rF rW � s rW c @ s e Zd ZdS )�DoSleepNrX rE rE rE rF rY � s rY c @ sR e Zd ZU dZdZeje ed< dZ ej e ed< ed�dd�Z ed�d d �Z dS ) � BaseActiona5 Base class for representing actions to take by retry object. Concrete implementations must define: - __init__: to initialize all necessary fields - REPR_FIELDS: class variable specifying attributes to include in repr(self) - NAME: for identification in retry object methods and callbacks rE � REPR_FIELDSN�NAMErA c s. d� � fdd�� jD ��}� jj� d|� d�S )Nz, c 3 s" | ]}|� d t � |���V qdS )�=N)�getattr)�.0rL rC rE rF � <genexpr>� s z&BaseAction.__repr__.<locals>.<genexpr>�(�))�joinr[ � __class__rH )rD Z state_strrE rC rF �__repr__� s �zBaseAction.__repr__c C s t | �S �N)�reprrC rE rE rF �__str__� s zBaseAction.__str__) rH rI rJ rV r[ rN �Sequence�strrR r\ �Optionalre rh rE rE rE rF rZ � s rZ c @ s& e Zd ZdZdZejdd�dd�ZdS )� RetryActionr �retryN)r rB c C s t |�| _d S rf )�floatr )rD r rE rE rF �__init__� s zRetryAction.__init__)rH rI rJ r[ r\ rN � SupportsFloatro rE rE rE rF rl � s rl )�first�secondrB c C s | t u r |S | S rf )�_unset)rq rr rE rE rF � _first_set� s rt c sF e Zd ZdZddd�� fdd� Zejd�dd �Zed�d d �Z � Z S ) � RetryErrorz>Encapsulates the last attempt instance right before giving up.�FutureN)� last_attemptrB c s || _ t� �|� d S rf )rw �superro )rD rw �rd rE rF ro � s zRetryError.__init__rA c C s | j jr| j �� �| �d S rf )rw �failed�resultrC rE rE rF �reraise� s zRetryError.reraisec C s | j j� d| j� d�S )N�[�])rd rH rw rC rE rE rF rh � s zRetryError.__str__) rH rI rJ rV ro rN �NoReturnr| rj rh � __classcell__rE rE ry rF ru � s ru c @ s^ e Zd ZdZdd�dd�Zdd�dd �Zejeje eje ejd eje d �d d �Z dS )�AttemptManagerzManage attempt context.r; �� retry_statec C s || _ d S rf r� �rD r� rE rE rF ro � s zAttemptManager.__init__NrA c C s d S rf rE rC rE rE rF � __enter__� s zAttemptManager.__enter__ztypes.TracebackType)�exc_type� exc_value� tracebackrB c C s: |d ur&|d ur&| j �|||f� dS | j �d � d S d S )NT)r� � set_exception� set_result)rD r� r� r� rE rE rF �__exit__� s zAttemptManager.__exit__) rH rI rJ rV ro r� rN rk �Type� BaseExceptionrS r� rE rE rE rF r� � s �r� c @ s� e Zd Zeee� e� eedde df e j e j e ef gdf ddde j dgdf e j dgdf e je j dgdf ee je e je j dge jf d� dd �Zeeeeeeeeeef e j e j e j e ef gdf ef e j def e j def e j eef e j e j dgdf ef e j e j dgdf ef e j e je j dgdf ef e j eef e j e je ef e j e je j dge jf ef d d � d d �Zed�dd�Zee jee jf d�dd��Z ee d�dd��Z e e d�dd�Z dd�dd�Z!e j de jf dd�d d �Z"ddd �d d �Z#ddd �d!d"�Z$ddd �d#d$�Z%de j e&e'e jf d �d%d&�Z(ddd �d'd(�Z)ddd �d)d*�Z*ddd �d+d,�Z+e j,e-ddf d�d-d.�Z.e/e j de0f e je je0d/�d0d1��Z1dS )2� BaseRetryingNFr1 r2 r0 r; � r �stop�waitrm �before�after� before_sleepr| �retry_error_cls�retry_error_callbackc C sJ || _ || _|| _|| _|| _|| _|| _|| _t� � | _ | | _ | | _ d S rf ) r r� r� rm r� r� r� r| � threading�local�_localr� r� � rD r r� r� rm r� r� r� r| r� r� rE rE rF ro � s zBaseRetrying.__init__r. � r r� r� rm r� r� r� r| r� r� rB c C sn | j t|| j�t|| j�t|| j�t|| j�t|| j�t|| j�t|| j�t|| j �t| | j �t| | j �d� S )z8Copy this object with some parameters changed if needed.r� ) rd rt r r� r� rm r� r� r� r| r� r� r� rE rE rF �copy� s ��zBaseRetrying.copyrA c C sL d| j j� dt| �d�d| j� d| j� d| j� d| j� d| j� d | j� d �S ) N�<z object at 0x�xz (stop=z, wait=z, sleep=z, retry=z , before=z, after=z)>) rd rH �idr� r� r rm r� r� rC rE rE rF re s �������zBaseRetrying.__repr__c C sF z | j jW S ty@ t�tjttjf i �| j _| j j Y S 0 dS )aS Return a dictionary of runtime statistics. This dictionary will be empty when the controller has never been ran. When it is running or has ran previously it should have (but may not) have useful and/or informational keys and values when running is underway and/or completed. .. warning:: The keys in this dictionary **should** be some what stable (not changing), but there existence **may** change between major releases as new statistics are gathered or removed so before accessing keys ensure that they actually exist and handle when they do not. .. note:: The values in this dictionary are local to the thread running call (so if multiple threads share the same retrying object - either directly or indirectly) they will each have there own view of statistics they have collected (in the future we may provide a way to aggregate the various statistics from each thread). N)r� � statistics�AttributeErrorrN �cast�Dictrj rQ rC rE rE rF r� s zBaseRetrying.statisticsc C s4 z | j jW S ty. t� | j _| j j Y S 0 d S rf )r� � iter_stater� r9 rC rE rE rF r� < s zBaseRetrying.iter_state��frB c sd t �� t jd �tjtjtjd�� ��fdd� ��tjtjtd�� �fdd� }��_|�_i �_�S )z[Wrap a function for retrying. :param f: A function to wraps for retrying. )� __defaults__�__kwdefaults__)�args�kwrB c s& �� � }|j�_|� g| �R i |��S rf )r� r� )r� r� r� �r� rD � wrapped_frE rF r� J s z%BaseRetrying.wraps.<locals>.wrapped_f)r� �kwargsrB c s �j | i |���� �S rf )r� �wraps)r� r� )r� rD rE rF � retry_withT s z&BaseRetrying.wraps.<locals>.retry_with) � functoolsr� �WRAPPER_ASSIGNMENTSrN rQ r4 rm r� r� )rD r� r� rE r� rF r� D s �" zBaseRetrying.wrapsc C s0 | j �� t�� | j d< d| j d< d| j d< d S )N� start_timer �attempt_numberr �idle_for)r� �clear�time� monotonicrC rE rE rF �begin^ s zBaseRetrying.begin.)�fnrB c C s | j j�|� d S rf )r� r< �append)rD r� rE rE rF �_add_action_funcd s z BaseRetrying._add_action_func)r� rB c C s | � |�| j_d S rf )rm r� r= r� rE rE rF � _run_retryg s zBaseRetrying._run_retryc C s | j r| � |�}nd}||_d S )N� )r� �upcoming_sleep)rD r� r rE rE rF � _run_waitj s zBaseRetrying._run_waitc C s |j | jd< | �|�| j_d S )Nr> )�seconds_since_startr� r� r� r? r� rE rE rF � _run_stopr s zBaseRetrying._run_stopc C s( | � |� d }| jjD ] }||�}q|S rf )� _begin_iterr� r< )rD r� r{ �actionrE rE rF �iterv s zBaseRetrying.iterc C s| | j �� |j}|d u r@| jd ur.| �| j� | �dd� � d S |joRt|�� t�| j _ | j j sl| �| j � | �| j � d S )Nc S s t � S rf )rW ��rsrE rE rF �<lambda>� � z*BaseRetrying._begin_iter.<locals>.<lambda>) r� rG �outcomer� r� rz � isinstance� exceptionrU r@ r� �_post_retry_check_actions)rD r� �futrE rE rF r� } s � zBaseRetrying._begin_iterc C s` | j js"| j js"| �dd� � d S | jd ur8| �| j� | �| j� | �| j� | �| j� d S )Nc S s | j �� S rf )r� r{ r� rE rE rF r� � r� z8BaseRetrying._post_retry_check_actions.<locals>.<lambda>)r� r@ r= r� r� r� r� �_post_stop_check_actionsr� rE rE rF r� � s z&BaseRetrying._post_retry_check_actionsc s� � j jr@� jr � �� j� d S dd d�� fdd� }� �|� d S dd d�� fdd� }� �|� � jd urt� �� j� � �dd� � d S ) Nr; )r� rB c s4 t �t| j�}� �|�}� jr&|�� �||�� �d S rf )rN r� rv r� r� r| r� )r� r� Z retry_excrC rE rF � exc_check� s z8BaseRetrying._post_stop_check_actions.<locals>.exc_checkc sF | j }t|�| _| j|7 _� jd |7 < � jd d7 < d S )Nr� r� r )r� rl � next_actionr� r� )r� r rC rE rF r� � s z:BaseRetrying._post_stop_check_actions.<locals>.next_actionc S s t | j�S rf )rY r� r� rE rE rF r� � r� z7BaseRetrying._post_stop_check_actions.<locals>.<lambda>)r� r? r� r� r� )rD r� r� r� rE rC rF r� � s z%BaseRetrying._post_stop_check_actionsc c sb | � � t| d di d�}| j|d�}t|t�r<t|d�V qt|t�r^|�� | �|� qq^qd S )NrE )r� r� r� r� ) r� r; r� r� rW r� rY �prepare_for_next_attemptr )rD r� �dorE rE rF �__iter__� s zBaseRetrying.__iter__�r� r� r� rB c O s d S rf rE )rD r� r� r� rE rE rF �__call__� s zBaseRetrying.__call__)2rH rI rJ r r r$ r r) r+ ru rN rP �UnionrT rn rk rS r� rQ ro rs �objectr r� rj re �propertyr� r� r9 r� r4 r� r� r� r� r� r� rW rY r� r� r� r� � Generatorr� r� r r3 r� rE rE rE rF r� � s� �� �" � �� ! �r� c @ s2 e Zd ZdZejdef ejejed�dd�ZdS )�RetryingzRetrying controller..r� c O s� | � � t| |||d�}| j|d�}t|t�rnz||i |��}W n ty` |�t�� � Y q�0 |� |� qt|t �r�|� � | � |� q|S qd S )N)� retry_objectr� r� r� r� ) r� r; r� r� rW r� r� �sys�exc_infor� rY r� r )rD r� r� r� r� r� r{ rE rE rF r� � s zRetrying.__call__N) rH rI rJ rV rN rP r3 rQ r� rE rE rE rF r� � s �r� )r6 � c sT e Zd ZdZedd�� fdd� Zeed�dd��Ze ee j ed d �d d ��Z � Z S ) rv zDEncapsulates a (future or past) attempted call to a target function.N)r� rB c s t � �� || _d S rf )rx ro r� )rD r� ry rE rF ro � s zFuture.__init__rA c C s | � � duS )z8Return whether a exception is being held in this future.N)r� rC rE rE rF rz � s z Future.failed)r� �value� has_exceptionrB c C s& | |�}|r|� |� n |�|� |S )z Construct a new Future object.)r� r� )�clsr� r� r� r� rE rE rF � construct� s zFuture.construct)rH rI rJ rV rT ro r� rS rz � classmethodrN rQ r� r� rE rE ry rF rv � s �rv c @ s� e Zd ZdZeeje ejejdd�dd�Z e eje d�dd��Z dd�d d �Z ejdd �d d �Zejeje edf dd�dd�Zed�dd�ZdS )r; z5State related to a single call wrapped with Retrying.N)r� r� r� r� rB c C sJ t �� | _|| _|| _|| _|| _d| _d | _d | _ d| _ d | _ d| _ d S )Nr r� ) r� r� r� r� r� r� r� r� r� �outcome_timestampr� r� r� )rD r� r� r� r� rE rE rF ro s zRetryCallState.__init__rA c C s | j d u rd S | j | j S rf )r� r� rC rE rE rF r� - s z"RetryCallState.seconds_since_startc C s$ d | _ d | _| jd7 _d | _d S �Nr )r� r� r� r� rC rE rE rF r� 3 s z'RetryCallState.prepare_for_next_attempt)�valrB c C s. t �� }t| j�}|�|� || | _| _d S rf )r� r� rv r� r� r� r� )rD r� �tsr� rE rE rF r� 9 s zRetryCallState.set_resultztypes.TracebackType| None)r� rB c C s2 t �� }t| j�}|�|d � || | _| _d S r� )r� r� rv r� r� r� r� )rD r� r� r� rE rE rF r� ? s z RetryCallState.set_exceptionc C s� | j d u rd}n:| j jr:| j �� }d|jj� d|� d�}nd| j �� � �}tt| jd��}| jj}d|� dt | �� d| j � d |� d |� d � S ) Nznone yetzfailed (� rb z returned � r� z : attempt #z ; slept for z; last result: �>) r� rz r� rd rH r{ rn �roundr� r� r� )rD r{ r� �sleptZclsnamerE rE rF re J s zRetryCallState.__repr__)rH rI rJ rV r� rN rk r4 rQ ro r� rn r� r� r� �Tupler� r� r� rj re rE rE rE rF r; s" � �� r; )�funcrB c C s d S rf rE )r� rE rE rF rm X s rm Fr1 r2 z.t.Union[RetryBaseT, tasyncio.retry.RetryBaseT]r� c C s d S rf rE r� rE rE rF rm \ s )�dargs�dkwrB c sD t � �dkr&t� d �r&t� � d �S ttd�� �fdd� }|S dS )z�Wrap a function with a new `Retrying` object. :param dargs: positional arguments passed to Retrying object :param dkw: keyword arguments passed to the Retrying object r r r� c s� t | t�r*t�d| jj� d| jj� d�� t�| �rDt� i ���}n:t rpt t j d�rpt j � | �rpt � i ���}nt� i ���}|�| �S )NzGot retry_base instance (zQ) as callable argument, this will probably hang indefinitely (did you mean retry=z(...)?)�is_coroutine_function)r� r �warnings�warnrd rH r Zis_coroutine_callable� AsyncRetrying�tornado�hasattr�genr� �TornadoRetryingr� r� )r� �r�r� r� rE rF �wrap~ s" �� � � �zretry.<locals>.wrapN)�len�callablerm r4 )r� r� r� rE r� rF rm s s )r� )r� )6r r r r r r r r r r r r r r r r r r r r r r r r r r! r" r# r$ r% r& �wait_full_jitterr' r( r) r* r+ r, r- rm r4 rU � NO_RESULTrW rY rZ rl ru r� r� r� rv r; r� )prK r� r� r� r� �typingrN r� �abcr r Z concurrentr � r rm r r r r r r r r r r r r r r Znapr r r� r r r r r r r r� r r r! r" r# r$ r% r& r� r' r� r( r) r� r* r+ r� r, r- r� � ImportError� TYPE_CHECKING�types�typing_extensionsr. r/ Ztasyncior0 r1 r2 �TypeVarr3 rP rQ r4 Zdataclass_kwargs� version_info�update� dataclassr9 � ExceptionrU r� r� rW rn rY rZ rl rs r� rt ru r� r� r� rv ZFutureGenericTr; �overloadrT � Awaitablerk rS r� Ztenacity.asyncior� Ztenacity.tornadowebr� �__all__rE rE rE rF �<module> s� " w M�(�� �"��"
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка