관리-도구
편집 파일: __init__.cpython-38.pyc
U ʗReQG � @ 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 ��/builddir/build/BUILDROOT/alt-python38-pip-22.2.1-2.el8.x86_64/opt/alt/python38/lib/python3.8/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 sz t | t�r*t�d| jj� d| jj� d�� t| �r>t� ��}n2trft tj d�rftj � | �rft � ��}n t � ��}|�| �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)�.0�field��selfr3 r4 � <genexpr>� s z&BaseAction.__repr__.<locals>.<genexpr>�(�))�joinrT r? r@ )r\ � state_strr3 r[ r4 �__repr__� s zBaseAction.__repr__c C s t | �S r2 )�reprr[ r3 r3 r4 �__str__� s zBaseAction.__str__) r@ rM rN rO rT �t�Sequence�str�__annotations__rU �Optionalrb rd 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 re � SupportsFloatrl r3 r3 r3 r4 rj � s rj )�first�secondr1 c C s | t kr |S | S r2 )�_unset)rn ro r3 r3 r4 � _first_set� s rq 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 )rt �superrl )r\ rt �r? r3 r4 rl � s zRetryError.__init__z t.NoReturnrV c C s | j jr| j �� �| �d S r2 )rt �failed�resultr[ r3 r3 r4 �reraise� s zRetryError.reraisec C s | j j� d| j� d�S )N�[�])r? r@ rt r[ r3 r3 r4 rd � s zRetryError.__str__) r@ rM rN rO rl ry rg rd � __classcell__r3 r3 rv r4 rr � s rr 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 rl � s zAttemptManager.__init__NrV c C s d S r2 r3 r[ 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 rl r� re ri �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_sleepry �retry_error_cls�retry_error_callbackc C sJ || _ || _|| _|| _|| _|| _|| _|| _t� � | _ | | _ | | _ d S r2 ) r r� r� r5 r� r� r� ry � threading�local�_localr� r� � r\ r r� r� r5 r� r� r� ry r� r� r3 r3 r4 rl � s zBaseRetrying.__init__) r r� r� r5 r� r� r� ry 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? rq r r� r� r5 r� r� r� ry 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� r[ r3 r3 r4 rb s J�zBaseRetrying.__repr__c C s4 z | j jW S tk r. i | j _| j j Y S X 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�AttributeErrorr[ 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 �� f| �|�S r2 r3 )r� r� �r: r\ r3 r4 � wrapped_fD s z%BaseRetrying.wraps.<locals>.wrapped_f)r� �kwargsr1 c s �j | |��� �S r2 )r� rG )r� r� r� r3 r4 � retry_withH s z&BaseRetrying.wraps.<locals>.retry_with)� functoolsrG re �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� monotonicr[ r3 r3 r4 �beginP s zBaseRetrying.begin)r� r1 c C s( |j }|d kr(| jd k r"| �|� t� S |j jo>t|j �� t�}|sX| j|d�sX|�� S | j d k rl| � |� |j | j d< | j |d�r�| j r�| � |�S | �|�}| jr�|�� �||�� �| jr�| j|d�}nd}t|�|_| j|7 _| j d |7 < | j d d7 < | jd k �r | �|� t|�S )Nr �delay_since_first_attempt� r� r� r )�outcomer� rP rw r< � exceptionrL r5 rx r� �seconds_since_startr� r� r� r� ry r� rj � next_actionr� r� rR )r\ r� �fut�is_explicit_retry� 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( rr re �Callable�Union�intrk r ri r� r� r� rl rp �objectr� rg rb �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�rlz|||�}W n" tk r^ |�t�� � Y q�X |� |� 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� rx r3 r3 r4 r� � s zRetrying.__call__N) r@ rM rN rO re 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 ) rs zDEncapsulates a (future or past) attempted call to a target function.N)r� r1 c s t � �� || _d S r2 )ru rl r� )r\ r� rv r3 r4 rl � s zFuture.__init__rV c C s | � � dk S )z8Return whether a exception is being held in this future.N)r� r[ r3 r3 r4 rw � 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� rl r� r� rw � classmethodre r� r� r| r3 r3 rv r4 rs � s rs 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 rl � s zRetryCallState.__init__rV c C s | j d krd S | j | j S r2 )r� r� r[ r3 r3 r4 r� � s z"RetryCallState.seconds_since_startc C s$ d | _ d | _| jd7 _d | _d S �Nr )r� r� r� r� r[ r3 r3 r4 r� � s z'RetryCallState.prepare_for_next_attempt)�valr1 c C s. t �� }t| j�}|�|� || | _| _d S r2 )r� r� rs 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� rs r� r� r� r� )r\ r� r� r� r3 r3 r4 r� � s z RetryCallState.set_exceptionc C s� | j d krd}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� rw r� r? r@ rx rk �roundr� r� r� )r\ rx r� �slept�clsnamer3 r3 r4 rb � s zRetryCallState.__repr__)r@ rM rN rO r� re ri r- r� rl r� rk r� r� r� �Tupler� r� r� rb r3 r3 r3 r4 r~ � s � "r~ )rA )rE )Zr� r� r� r� �typingre r= �abcr r � concurrentr �inspectr r5 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$ �wait_full_jitterr� r% r& r� r' r( r� r) r* rB � TYPE_CHECKING�typesr+ r, �TypeVarr� r- r/ �overloadr� r� � ExceptionrL r� � NO_RESULTrP rk rR rS rj rp rq rr r} r� rF rs r~ � pip._vendor.tenacity._asynciorA Z pip._vendor.tenacity.tornadowebrE r3 r3 r3 r4 �<module> s� $, " -F