File: //usr/local/lib/python3.10/dist-packages/tenacity/__pycache__/__init__.cpython-310.pyc
o
���g�] � @ s` 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< zd dl=Z=W n e>�y, dZ=Y nw ej?�rMd dl@Z@dd,l
mAZB dd-lmCZC dd.l!mDZD dd/l)mEZE e�Fd0�ZGejFd1ejHd2ejIf d3�ZJi ZKejLd4k�rneK�Md5d6i� e jNdli eK��G d7d8� d8��ZOG d9d:� d:eP�ZQeR� ZSG d;d<� d<�ZTG d=d>� d>eU�ZVG d?d@� d@�ZWG dAdB� dBeW�ZXeR� ZYdCejZejIeRf dDejIdEejIfdFdG�Z[G dHdI� dIeP�Z\G dJdK� dK�Z]G dLdM� dMe �Z^G dNdO� dOe^�Z_ejLdPk�r�e j`ejI Zane j`ZaG dQdR� dRea�Z`G dSdT� dT�ZbejcdUeJdEeJfdVdW��Zejce e'e/� e� e6e9ddXe\df
dYejHejZedeUf gejZdejed f f dZd[d\d]dWd^d_ejHdTgejZdejed f f d`ejHdTgejZdejed f f daejfejHdTgejZdejed f f dbegdcejhdI ddejfejHdTgejZejIejeejI f f dEejHeJgeJf fdedW��ZdfejIdgejIdEejIfdhdW�Zd dilimjZj e=�r�d djlkmlZl g dk�ZmdS )m� 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)�asyncio)�
RetryBaseT)� StopBaseT)� WaitBaseT�WrappedFnReturnT� WrappedFn.)�bound)� �
�slotsTc @ sp e Zd ZU ejed�Zejej dgej
f e d< dZ e
e d< dZee d< dZe
e d< dZe
e d < dd d
�Zd S )� IterState)�default_factory�RetryCallState�actionsF�retry_run_resultr �delay_since_first_attempt�stop_run_result�is_explicit_retry�returnNc C s" g | _ d| _d| _d| _d| _d S )NFr )r; r< r= r> r? ��self� rC �</usr/local/lib/python3.10/dist-packages/tenacity/__init__.py�resett s
zIterState.reset�r@ N)�__name__�
__module__� __qualname__� dataclasses�field�listr; �t�List�Callable�Any�__annotations__r< �boolr= �intr> r? rE rC rC rC rD r8 j s
"� r8 c @ s e Zd ZdZdS )�TryAgainz/Always retry the executed function when raised.N)rG rH rI �__doc__rC rC rC rD rT | s rT c @ � e Zd ZdS )� DoAttemptN�rG rH rI rC rC rC rD rW � � rW c @ rV )�DoSleepNrX rC rC rC rD rZ � rY rZ c @ sR e Zd ZU dZdZeje ed< dZ ej
e ed< defdd�Z defd 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
rC � REPR_FIELDSN�NAMEr@ c s. d� � fdd�� jD ��}� jj� d|� d�S )Nz, c 3 s$ � | ]
}|� d t � |���V qdS )�=N)�getattr)�.0rK rA rC rD � <genexpr>� s �
�z&BaseAction.__repr__.<locals>.<genexpr>�(�))�joinr\ � __class__rG )rB � state_strrC rA rD �__repr__� s �zBaseAction.__repr__c C s t | �S �N)�reprrA rC rC rD �__str__� s zBaseAction.__str__)
rG rH rI rU r\ rM �Sequence�strrQ r] �Optionalrg rj rC rC rC rD r[ � s
r[ c @ s( e Zd ZdZdZdejddfdd�ZdS )� RetryActionr �retryr r@ Nc C s t |�| _d S rh )�floatr )rB r rC rC rD �__init__� s zRetryAction.__init__)rG rH rI r\ r] rM �
SupportsFloatrq rC rC rC rD rn � s rn �first�secondr@ c C s | t u r|S | S rh )�_unset)rs rt rC rC rD �
_first_set� s rv c s@ e Zd ZdZd � fdd� Zdejfdd �Zdefd
d �Z � Z
S )
�
RetryErrorz>Encapsulates the last attempt instance right before giving up.� last_attempt�Futurer@ Nc s || _ t� �|� d S rh )rx �superrq )rB rx �re rC rD rq � s zRetryError.__init__c C s | j jr | j �� �| �rh )rx �failed�resultrA rC rC rD �reraise� s
zRetryError.reraisec C s | j j� d| j� d�S )N�[�])re rG rx rA rC rC rD rj � � zRetryError.__str__)rx ry r@ N) rG rH rI rU rq rM �NoReturnr~ rl rj �
__classcell__rC rC r{ rD rw � s
rw c @ s\ e Zd ZdZddd�Zddd �Zd
ejeje d eje d ejd
deje
fdd�Z dS )�AttemptManagerzManage attempt context.� retry_stater: c C s
|| _ d S rh �r� �rB r� rC rC rD rq � s
zAttemptManager.__init__r@ Nc C � d S rh rC rA rC rC rD � __enter__� � zAttemptManager.__enter__�exc_type� exc_value� tracebackztypes.TracebackTypec C s6 |d ur|d ur| j �|||f� dS | j �d � d S )NT)r� �
set_exception�
set_result)rB r� r� r� rC rC rD �__exit__� s
zAttemptManager.__exit__)r� r: rF ) rG rH rI rU rq r� rM rm �Type�
BaseExceptionrR r� rC rC rC rD r� � s
����r� c @ s� e Zd Zeee� e� eedde df
de
j e
j e
ef gdf dddddd d
e
j d gdf d e
j d gdf d
e
je
j d gdf dede
je de
je
j d ge
jf fdd�Zeeeeeeeeeef
de
j e
j e
j e
ef gdf ef de
j def de
j def de
j eef d
e
j e
j d gdf ef d e
j e
j d gdf ef d
e
j e
je
j d gdf ef de
j eef de
j e
je ef de
j e
je
j d ge
jf ef dd fdd�Zdefdd�Zede
jee
jf fdd��Z ede fdd��Z d e de fd d �Z d:d d �Z!d!e
j d"e
jf ddfd#d$�Z"d;d&d'�Z#d;d(d)�Z$d;d*d+�Z%d%d de
j e&e'e
jf fd,d-�Z(d;d.d/�Z)d;d0d1�Z*d;d2d3�Z+de
j,e-ddf fd4d5�Z.e/d!e
j d"e0f d6e
jd7e
jde0fd8d9��Z1dS )<� BaseRetryingNFr �stopr0 �waitr1 ro r/ �beforer: �after� before_sleepr~ �retry_error_cls�retry_error_callbackc C sJ || _ || _|| _|| _|| _|| _|| _|| _t� � | _
| | _ |
| _ d S rh )
r r� r� ro r� r� r� r~ � threading�local�_localr� r� � rB r r� r� ro r� r� r� r~ r� r� rC rC rD rq � s
zBaseRetrying.__init__r@ 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 r� r� ro r� r� r� r~ r� r� ) re rv r r� r� ro r� r� r� r~ r� r� r� rC rC rD �copy� s
��zBaseRetrying.copyc 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)>) re rG �idr� r� r ro r� r� rA rC rC rD rg s �������zBaseRetrying.__repr__c C sB z| j jW S ty t�tjttjf i �| j _| j j Y S w )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).
)r� �
statistics�AttributeErrorrM �cast�Dictrl rP rA rC rC rD r� s
�zBaseRetrying.statisticsc C s0 z| j jW S ty t� | j _| j j Y S w rh )r� �
iter_stater� r8 rA rC rC rD r� : s
�zBaseRetrying.iter_state�fc sl t �� t jd �dtjdtjdtjf� ��fdd� ��dtjdtjdtf� �fdd � }��_|�_i �_�S )
z[Wrap a function for retrying.
:param f: A function to wraps for retrying.
)� __defaults__�__kwdefaults__�args�kwr@ c s& �� � }|j�_|� g| �R i |��S rh )r� r� )r� r� r� �r� rB � wrapped_frC rD r� H s z%BaseRetrying.wraps.<locals>.wrapped_f�kwargsc s �j | i |���� �S rh )r� �wraps)r� r� )r� rB rC rD �
retry_withR r� z&BaseRetrying.wraps.<locals>.retry_with) � functoolsr� �WRAPPER_ASSIGNMENTSrM rP r3 ro r� r� )rB r� r� rC r� rD r� B 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� monotonicrA rC rC rD �begin\ s
zBaseRetrying.begin�fn.c C s | j j�|� d S rh )r� r; �append)rB r� rC rC rD �_add_action_funcb � z BaseRetrying._add_action_funcr� c C s | � |�| j_d S rh )ro r� r< r� rC rC rD �
_run_retrye r� zBaseRetrying._run_retryc C s | j r | � |�}nd}||_d S )N� )r� �upcoming_sleep)rB r� r rC rC rD � _run_waith s
zBaseRetrying._run_waitc C s |j | jd< | �|�| j_d S )Nr= )�seconds_since_startr� r� r� r> r� rC rC rD � _run_stopp s zBaseRetrying._run_stopc C s( | � |� d }| jjD ]}||�}q |S rh )� _begin_iterr� r; )rB r� r} �actionrC rC rD �itert s
zBaseRetrying.iterc C s| | j �� |j}|d u r | jd ur| �| j� | �dd� � d S |jo)t|�� t�| j _ | j j s6| �| j
� | �| j � d S )Nc S s t � S rh )rW ��rsrC rC rD �<lambda>� s z*BaseRetrying._begin_iter.<locals>.<lambda>) r� rE �outcomer� r� r| �
isinstance� exceptionrT r? r� �_post_retry_check_actions)rB r� �futrC rC rD r� { s
� zBaseRetrying._begin_iterc C s` | j js| j js| �dd� � d S | jd ur | �| j� | �| j� | �| j� | �| j� d S )Nc S s
| j �� S rh )r� r} r� rC rC rD r� � �
z8BaseRetrying._post_retry_check_actions.<locals>.<lambda>)r� r? r< r� r� r� r� �_post_stop_check_actionsr� rC rC rD r� � s
z&BaseRetrying._post_retry_check_actionsc sz � j jr � jr� �� j� d S d
� fdd� }� �|� d S d
� fdd� }� �|� � jd ur4� �� j� � �dd � � d S ) Nr� r: r@ c s0 t �t| j�}� �|�}� jr|�� �||�� �rh )rM r� ry r� r� r~ r� )r� r� � retry_excrA rC rD � 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� rn � next_actionr� r� )r� r rA rC rD r� � s
z:BaseRetrying._post_stop_check_actions.<locals>.next_actionc S s
t | j�S rh )rZ r� r� rC rC rD r� � r� z7BaseRetrying._post_stop_check_actions.<locals>.<lambda>)r� r: r@ N)r� r> r� r� r� )rB r� r� r� rC rA rD r� � s
z%BaseRetrying._post_stop_check_actionsc c sd � | � � t| d di d�} | j|d�}t|t�r t|d�V nt|t�r/|�� | �|� nd S q)NrC )r� r� r� Tr� ) r� r: r� r� rW r� rZ �prepare_for_next_attemptr )rB r� �dorC rC rD �__iter__� s �
�zBaseRetrying.__iter__r� r� c O r� rh rC )rB r� r� r� rC rC rD �__call__� s zBaseRetrying.__call__rF )r� r: r@ N)2rG rH rI r r r$ r r) r+ rw rM rO �UnionrS rp rm rR r� rP rq ru �objectr r� rl rg �propertyr� r� r8 r� r3 r� r� r� r� r� r� rW rZ r� r� r� r� � Generatorr� r� r r2 r� rC rC rC rD r� � s� �������� �
�
��"� � � ����� � �
��
�!
����r� c @ s8 e Zd ZdZdejdef dejdejdefdd�Zd S )
�RetryingzRetrying controller.r� .r� r� r@ c O s� | � � t| |||d�} | j|d�}t|t�r8z ||i |��}W n ty1 |�t�� � Y nw |� |� nt|t
�rG|� � | � |� n|S q
)N)� retry_objectr� r� r� Tr� )
r� r: r� r� rW r� r� �sys�exc_infor� rZ r� r )rB r� r� r� r� r� r} rC rC rD r� � s
�
�zRetrying.__call__N) rG rH rI rU rM rO r2 rP r� rC rC rC rD r� � s ����r� )r5 � c s\ e Zd ZdZdeddf� fdd� Zedefdd��Ze ded e
j d
edd fd d ��Z � Z
S )
ry zDEncapsulates a (future or past) attempted call to a target function.r� r@ Nc s t � �� || _d S rh )rz rq r� )rB r� r{ rC rD rq � s
zFuture.__init__c C s | � � duS )z8Return whether a exception is being held in this future.N)r� rA rC rC rD r| � s z
Future.failed�value�
has_exceptionc C s( | |�}|r
|� |� |S |�|� |S )z Construct a new Future object.)r� r� )�clsr� r� r� r� rC rC rD � construct� s
�zFuture.construct)rG rH rI rU rS rq r� rR r| � classmethodrM rP r� r� rC rC r{ rD ry � s ����ry c
@ s� e Zd ZdZdedeje dejdejddf
dd �Z e
deje fd
d ��Z dd d
�Z
dejddfdd�Zdejeje edf ddfdd�Zdefdd�ZdS )r: z5State related to a single call wrapped with Retrying.r� r� r� r� r@ Nc 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� )rB r� r� r� r� rC rC rD rq s
zRetryCallState.__init__c C s | j d u rd S | j | j S rh )r� r� rA rC rC rD r� + s
z"RetryCallState.seconds_since_startc C s$ d | _ d | _| jd7 _d | _d S �Nr )r� r� r� r� rA rC rC rD r� 1 s
z'RetryCallState.prepare_for_next_attempt�valc C s. t �� }t| j�}|�|� ||| _| _d S rh )r� r� ry r� r� r� r� )rB r� �tsr� rC rC rD r� 7 s
zRetryCallState.set_resultr� ztypes.TracebackType| Nonec C s2 t �� }t| j�}|�|d � ||| _| _d S r� )r� r� ry r� r� r� r� )rB r� r� r� rC rC rD 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 (� rc z returned � r� z : attempt #z ; slept for z; last result: �>) r� r| r� re rG r} rp �roundr� r� r� )rB r} r� �slept�clsnamerC rC rD rg H s
*zRetryCallState.__repr__rF )rG rH rI rU r� rM rm r3 rP rq r� rp r� r� r� �Tupler� r� r� rl rg rC rC rC rD r: s2 ����
�
��
� r: �funcc C r� rh rC )r� rC rC rD ro V r� ro Fr r� r0 r� r1 z.t.Union[RetryBaseT, tasyncio.retry.RetryBaseT]r� r� r� r~ r� r� c
C r� rh rC r� rC rC rD ro Z s �dargs�dkwc sB t � �dkrt� d �rt� � d �S dtdtf� �fdd� }|S )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� r@ c s� t | t�rt�d| jj� d| jj� d�� t�| �r"t� i ���}n t r8t
t j d�r8t j � | �r8t
� 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�warnre rG r �is_coroutine_callable�
AsyncRetrying�tornado�hasattr�genr� �TornadoRetryingr� r� )r� �r�r� r� rC rD �wrap| s"
��
�
�
�
zretry.<locals>.wrap)�len�callablero r3 )r� r� r rC r rD ro q 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- ro r3 rT � NO_RESULTrW rZ r[ rn rw r� r� r� ry r: r� rC )nrJ r� r� r� r� �typingrM r� �abcr r �
concurrentr � r ro r r r r
r r r
r r r r r r r �napr 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�typesr. �tasyncior/ r0 r1 �TypeVarr2 rO rP r3 �dataclass_kwargs� version_info�update� dataclassr8 � ExceptionrT r� r rW rp rZ r[ rn ru r� rv rw r� r� r� ry �FutureGenericTr: �overloadrS � Awaitablerm rR r� �tenacity.asyncior� �tenacity.tornadowebr� �__all__rC rC rC rD �<module> s �
& w M�(�������� ����"�� � "