JFIF $
d d 7
Viewing File: /usr/lib/python3.9/site-packages/pip/_vendor/tenacity/__pycache__/__init__.cpython-39.opt-1.pyc
a
[��fQG � @ s� d dl Z d dlZd dlZd dlZd dlZd dlZd dlmZm Z d dl
m Z d dl m
Z
ddlmZ ddlmZ ddlmZ dd lmZ dd
lmZ dd lmZ dd lmZ dd
lmZ ddlmZ ddlmZ ddlmZ ddlmZ ddlmZ ddl m 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&m.Z/ dd#l0m1Z1 dd$l0m2Z2 dd%l3m4Z4 dd&l3m5Z5 dd'l6m7Z7 dd(l6m8Z8 dZ9ej:�r4d dl;Z;dd)l&m<Z< dd*l m=Z= ej>d+ej?d,�Z@e�>d-�ZAejBe@e@d.�d/d0��ZejBejCejCej?e@ge@f d1�d2d0��ZejCejCejDe@ej?e@ge@f f d1�d3d0�ZG d4d5� d5eE�ZFeG� ZHG d6d7� d7�ZIG d8d9� d9eJ�ZKG d:d;� d;�ZLG d<d=� d=eL�ZMeG� ZNejDejCeGf ejCejCd>�d?d@�ZOG dAdB� dBeE�ZPG dCdD� dD�ZQG dEdF� dFe�ZRG dGdH� dHeR�ZSG dIdJ� dJe jT�ZTG dKdL� dL�ZUd dMlVmWZW e9�r�d dNlXmYZY dS )O� N)�ABC�abstractmethod)�futures)�iscoroutinefunction� )�
retry_base)� retry_all)� retry_always)� retry_any)�retry_if_exception)�retry_if_exception_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_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)�
before_log)�before_nothing)� after_log)�
after_nothing)�before_sleep_log)�before_sleep_nothing)� wait_base)� stop_base� WrappedFn)�bound�_RetValT)�fn�returnc C s d S �N� )r0 r3 r3 �A/usr/lib/python3.9/site-packages/pip/_vendor/tenacity/__init__.py�retrya s r5 )�dargs�dkwr1 c O s d S r2 r3 �r6 r7 r3 r3 r4 r5 f s 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 ��fr1 c s� t | t�r*t�d| jj� d| jj� d�� t| �rBt� i ���}n:trnt tj
d�rntj
� | �rnt � 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)�
isinstancer �warnings�warn� __class__�__name__r �
AsyncRetrying�tornado�hasattr�genr; �TornadoRetrying�Retrying�wraps)r: �rr8 r3 r4 �wrapv s
�� zretry.<locals>.wrapN)�len�callabler5 r- )r6 r7 rI r3 r8 r4 r5 k s c @ s e Zd ZdZdS )�TryAgainz/Always retry the executed function when raised.N)r@ �
__module__� __qualname__�__doc__r3 r3 r3 r4 rL � s rL c @ s e Zd ZdS )� DoAttemptN�r@ rM rN r3 r3 r3 r4 rP � s rP c @ s e Zd ZdS )�DoSleepNrQ r3 r3 r3 r4 rR � s rR 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
r3 � REPR_FIELDSN�NAME�r1 c s. d� � fdd�� jD ��}� jj� d|� d�S )Nz, c 3 s" | ]}|� d t � |���V qdS )�=N)�getattr)�.0Zfield��selfr3 r4 � <genexpr>� � z&BaseAction.__repr__.<locals>.<genexpr>�(�))�joinrT r? r@ )r[ Z state_strr3 rZ r4 �__repr__� s zBaseAction.__repr__c C s t | �S r2 )�reprrZ r3 r3 r4 �__str__� s zBaseAction.__str__)
r@ rM rN rO rT �t�Sequence�str�__annotations__rU �Optionalra rc r3 r3 r3 r4 rS � s
rS c @ s& e Zd ZdZdZejdd�dd�ZdS )� RetryActionr r5 N)r r1 c C s t |�| _d S r2 )�floatr )r[ r r3 r3 r4 �__init__� s zRetryAction.__init__)r@ rM rN rT rU rd �
SupportsFloatrk r3 r3 r3 r4 ri � s ri )�first�secondr1 c C s | t u r |S | S r2 )�_unset)rm rn r3 r3 r4 �
_first_set� s rp c sD e Zd ZdZddd�� fdd� Zdd�d d
�Zed�d d �Z� ZS )
�
RetryErrorz>Encapsulates the last attempt instance right before giving up.�FutureN)� last_attemptr1 c s || _ t� �|� d S r2 )rs �superrk )r[ rs �r? r3 r4 rk � s zRetryError.__init__z
t.NoReturnrV c C s | j jr| j �� �| �d S r2 )rs �failed�resultrZ r3 r3 r4 �reraise� s
zRetryError.reraisec C s | j j� d| j� d�S )N�[�])r? r@ rs rZ r3 r3 r4 rc � s zRetryError.__str__) r@ rM rN rO rk rx rf rc �
__classcell__r3 r3 ru r4 rq � s rq c @ s^ e Zd ZdZdd�dd�Zdd�dd �Zejeje eje ejd
eje
d �d d
�Z dS )�AttemptManagerzManage attempt context.�RetryCallState�� retry_statec C s
|| _ d S r2 r~ )r[ r r3 r3 r4 rk � s zAttemptManager.__init__NrV c C s d S r2 r3 rZ r3 r3 r4 � __enter__� s zAttemptManager.__enter__�types.TracebackType)�exc_type� exc_value� tracebackr1 c C s4 t |t�r | j�|||f� dS | j�d � d S d S )NT)r< �
BaseExceptionr �
set_exception�
set_result)r[ r� r� r� r3 r3 r4 �__exit__� s
zAttemptManager.__exit__) r@ rM rN rO rk r� rd rh �Typer� �boolr� r3 r3 r3 r4 r| � s �r| c @ s> e Zd Zeee� e� eedde df
e
j e
j e
ef gdf ddee
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 �d
d�Zee
jee
jf d �dd��Z e e d�dd�Z dd �dd�Z de
j e e!e
jf d�dd�Z"e
j#e$ddf d �dd�Z%e&e
j de'f e
je
je'd �d d ��Z(dS ) � BaseRetryingNFr, r+ r} �
r �stop�waitr5 �before�after� before_sleeprx �retry_error_cls�retry_error_callbackc C sJ || _ || _|| _|| _|| _|| _|| _|| _t� � | _
| | _ |
| _ d S r2 )
r r� r� r5 r� r� r� rx � threading�local�_localr� r� � r[ r r� r� r5 r� r� r� rx r� r� r3 r3 r4 rk � s
zBaseRetrying.__init__) r r� r� r5 r� r� r� rx r� r� r1 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? rp r r� r� r5 r� r� r� rx r� r� r� r3 r3 r4 �copy� s
�zBaseRetrying.copyrV 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)>) r? r@ �idr� r� r r5 r� r� rZ r3 r3 r4 ra s �������zBaseRetrying.__repr__c C s2 z
| j jW S ty, 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�AttributeErrorrZ r3 r3 r4 r� " s
zBaseRetrying.statisticsr9 c sT t �� �tjtjtjd�� �fdd� �}tjtjtd�� �fdd� }�|_||_|S )z[Wrap a function for retrying.
:param f: A function to wraps for retrying.
)�args�kwr1 c s �� g| �R i |��S r2 r3 )r� r� �r: r[ r3 r4 � wrapped_fD s z%BaseRetrying.wraps.<locals>.wrapped_f)r� �kwargsr1 c s �j | i |���� �S r2 )r� rG )r� r� r� r3 r4 �
retry_withH s z&BaseRetrying.wraps.<locals>.retry_with)� functoolsrG rd �Anyr- r5 r� )r[ r: r� r� r3 r� r4 rG > 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� monotonicrZ r3 r3 r4 �beginP s
zBaseRetrying.begin)r r1 c C s( |j }|d u r(| jd ur"| �|� t� S |j jo>t|j �� t�}|sX| j|d�sX|�� S | j d url| � |� |j
| j d< | j |d�r�| j
r�| �
|�S | �|�}| jr�|�� �||�� �| jr�| j|d�}nd}t|�|_| j|7 _| j d |7 < | j d d7 < | jd u�r | �|� t|�S )Nr~ Zdelay_since_first_attempt� r� r� r )�outcomer� rP rv r< � exceptionrL r5 rw r� �seconds_since_startr� r� r� r� rx r� ri � next_actionr� r� rR )r[ r �futZis_explicit_retryZ retry_excr r3 r3 r4 �iterV s8
zBaseRetrying.iterc c sb | � � t| d di d�}| j|d�}t|t�r<t|d�V qt|t�r^|�� | �|� qq^qd S )Nr3 )r0 r� r� r~ ) r� r} r� r< rP r| rR �prepare_for_next_attemptr )r[ r �dor3 r3 r4 �__iter__{ s
zBaseRetrying.__iter__.�r0 r� r� r1 c O s d S r2 r3 )r[ r0 r� r� r3 r3 r4 �__call__� s zBaseRetrying.__call__))r@ rM rN r r r" r r& r( rq rd �Callable�Union�intrj r rh r� r� r� rk ro �objectr� rf ra �property�Dictr� r- rG r� rP rR r� � Generatorr| r� r r/ r� r3 r3 r3 r4 r� � sl �� �" � %r� c @ s2 e Zd ZdZejdef ejejed�dd�ZdS )rF zRetrying 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_objectr0 r� r� r~ )
r� r} r� r< rP r� r� �sys�exc_infor� rR r� r )r[ r0 r� r� r r� rw r3 r3 r4 r� � s
zRetrying.__call__N) r@ rM rN rO rd r� r/ r� r� r3 r3 r3 r4 rF � s rF c sT e Zd ZdZedd�� fdd� Zeed�dd��Ze ee
j ed d �d
d ��Z � Z
S ) rr zDEncapsulates a (future or past) attempted call to a target function.N)r� r1 c s t � �� || _d S r2 )rt rk r� )r[ r� ru r3 r4 rk � s
zFuture.__init__rV c C s | � � duS )z8Return whether a exception is being held in this future.N)r� rZ r3 r3 r4 rv � s z
Future.failed)r� �value�
has_exceptionr1 c C s& | |�}|r|� |� n
|�|� |S )z Construct a new Future object.)r� r� )�clsr� r� r� r� r3 r3 r4 � construct� s
zFuture.construct)r@ rM rN rO r� rk r� r� rv � classmethodrd r� r� r{ r3 r3 ru r4 rr � s rr c @ s� e Zd ZdZeeje ejejdd�dd�Z e
eje d�dd��Z dd�d d
�Z
ejdd �d d
�Zejeje edf dd�dd�Zdd� ZdS )r} z5State related to a single call wrapped with Retrying.N)r� r0 r� r� r1 c C sD t �� | _|| _|| _|| _|| _d| _d | _d | _ d| _
d | _ d S )Nr r� ) r� r� r� r� r0 r� r� r� r� �outcome_timestampr� r� )r[ r� r0 r� r� r3 r3 r4 rk � s
zRetryCallState.__init__rV c C s | j d u rd S | j | j S r2 )r� r� rZ r3 r3 r4 r� � s
z"RetryCallState.seconds_since_startc C s$ d | _ d | _| jd7 _d | _d S �Nr )r� r� r� r� rZ r3 r3 r4 r� � s z'RetryCallState.prepare_for_next_attempt)�valr1 c C s. t �� }t| j�}|�|� || | _| _d S r2 )r� r� rr r� r� r� r� )r[ r� �tsr� r3 r3 r4 r� � s
zRetryCallState.set_resultr� )r� r1 c C s2 t �� }t| j�}|�|d � || | _| _d S r� )r� r� rr r� r� r� r� )r[ r� r� r� r3 r3 r4 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 (� r_ z returned � r� z : attempt #z ; slept for z; last result: �>) r� rv r� r? r@ rw rj �roundr� r� r� )r[ rw r� ZsleptZclsnamer3 r3 r4 ra � s
zRetryCallState.__repr__)r@ rM rN rO r� rd rh r- r� rk r� rj r� r� r� �Tupler� r� r� ra r3 r3 r3 r4 r} � s � "r} )rA )rE )Zr� r� r� r� �typingrd r= �abcr r Z
concurrentr �inspectr r5 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$ Zwait_full_jitterr� r% r& r� r' r( r� r) r* rB �
TYPE_CHECKING�typesr+ r, �TypeVarr� r- r/ �overloadr� r� � ExceptionrL r� Z NO_RESULTrP rj rR rS ri ro rp rq r| r� rF rr r} Z pip._vendor.tenacity._asynciorA Z pip._vendor.tenacity.tornadowebrE r3 r3 r3 r4 �<module> s�
$, " -F Back to Directory
nL+D550H?Mx ,D"v]qv;6*Zqn)ZP 0 !1 A "#a$2Qr D8 a Ri[f\mIykIw0 cuFcRı?lO7к_f˓[C$殷WF<_W ԣs KcëIzyQy /_LKℂ;C",pFA: /]=H ~,ls/9ć:[=/#f;)x {ٛEQ )~ =𘙲r*2~ a _V=' kumF D}KYYC)({ *g&f`툪ry`=^cJ.I](*`wq 1dđ#̩͑0;H]u搂@:~וKL Nsh}OIR*8:2 !lDJVo( 3=M(zȰ+i*NA r6KnSl )!JJӁ* %݉?|D}d5:eP0R;{$X'xF@.ÊB {,WJuQɲRI;9QE琯62fT.DUJ;*cP A\ILNj!J۱+O\ ͔]ޒ SJȧc%ANolՎprULZԛerE2=XDXgVQeӓk yP7U*omQIs,K`)6\G3t?pgjrmۛجwluGtf h9uyP0D;Uڽ"OXlif$)&|ML0Zrm1[HXPlPR0'G=i2N +0e2]] 9VTPO7h(F*癈 '=QVZDF,d߬~TX
G[`le69CR(!S2!P
<0x < !1AQ "Raq02Br#SCTb
?Ζ"]mH5WR7k.ۛ!}Q~+yԏz|@T20S~Kek *zFf^2X*(@8r?CIuI|֓>^ExLgNUY+{.RѪ
τVYTD I62'8Y2 7'\TP.6d&˦@Vqi|8- OΕ]ʔ U=TL8=;6c| !qfF3aů&~$l}'NWUs$Uk^SV:U# 6w++s&r+nڐ{@29 gL
u"TÙM=6 (^"7r} =6YݾlCuhquympǦ
G jhsǜNlɻ}o7 #S6aw4!OSrD57%|?x>L
|/nD6?/8w#[)L7+6〼T ATg ! %5MmZ/c-{1_Je"|^$'O&ޱմ Trb$ w)R$&
N1EtdU3Uȉ1pM" N*(DN yd96.(jQ)X
5cQɎMyW? Q*!R>6=7)Xj5`J]e 8%t!+'!1Q 5 !1 AQaqё#2"0BRb ? Gt^## .llQT $v,,m 㵜5 ubV =sY+@d{N! dnO< .-B; _wJt6;QJd.Qc%p{ 1,sNDdFHI0ГoXшe黅XۢF:)[FGXƹ/w_cMeD,ʡcc. WDtA$j@:) -# u
c1<@ۗ9F)KJ-hpP]_x[qBlbp ʖw q"LFGd ƶ*s+ډ_Zc"? %t[IP 6J]#=ɺVvvCGsGh1 >)6|ey?Lӣm,4GWUi` ]uJVoV DG< SB 6ϏQ@ TiUly OU0kfV~~}SZ@*WUUi##; s/[ =!7}" WN]'(L! ~y5g9T̅JkbM' +s:S + B)v@Mj
e Cf jE 0Y\QnzG1д~Wo{T 9?`Rmyhsy3!HAD]mc1~2L Su7xT;j$`}4->L#vzŏ ILS ֭ T { rjGKC; bpU= -`BsK.SFw4Mq]ZdHS0)tLg