OwlCyberSecurity - MANAGER
Edit File: __init__.cpython-39.pyc
a �F�f&P � @ 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 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'm/Z/ dd#l'm/Z0 dd$l'm1Z1 dd%l2m3Z3 dd&l2m4Z4 dd'l5m6Z6 dd(l5m7Z7 dd)l8m9Z9 dd*l8m:Z: dZ;ej<�rXd dl=Z=dd+lm>Z> dd,l m?Z? dd-l'm@Z@ e�Ad.�ZBejAd/ejCd0ejDf d1�ZEG d2d3� d3eF�ZGeH� ZIG d4d5� d5�ZJG d6d7� d7eK�ZLG d8d9� d9�ZMG d:d;� d;eM�ZNeH� ZOejPejDeHf ejDejDd<�d=d>�ZQG d?d@� d@eF�ZRG dAdB� dB�ZSG dCdD� dDe�ZTG dEdF� dFeT�ZUejVd dGk�rRe jWejD ZXne jWZXG dHdI� dIeX�ZWG dJdK� dK�ZYejZeEeEdL�dMdN��ZejZe e%e-� e� e4e7ddOeRdf ejCejPe[eKf gej\ej]d f dPdQdRejCdKgdf ejCdKgdf ej\ejCdKgdf e^ej_d@ ej\ejCdKgejDf ejCeEgeEf dS� dTdN��ZejDejDejDdU�dVdN�Zd dWl`maZa e;�rvd dXlbmcZc g dY�ZddS )Z� N)�ABC�abstractmethod)�futures)�iscoroutinefunction� )� 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_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)� RetryBaseT)� StopBaseT)� WaitBaseT�WrappedFnReturnT� WrappedFn.)�boundc @ s e Zd ZdZdS )�TryAgainz/Always retry the executed function when raised.N)�__name__� __module__� __qualname__�__doc__� r8 r8 �_/home/gouroczh/virtualenv/test/3.9/lib/python3.9/site-packages/pip/_vendor/tenacity/__init__.pyr3 e s r3 c @ s e Zd ZdS )� DoAttemptN�r4 r5 r6 r8 r8 r8 r9 r: l s r: c @ s e Zd ZdS )�DoSleepNr; r8 r8 r8 r9 r< p s r< 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 r8 � REPR_FIELDSN�NAME��returnc s. d� � fdd�� jD ��}� jj� d|� d�S )Nz, c 3 s" | ]}|� d t � |���V qdS )�=N)�getattr)�.0�field��selfr8 r9 � <genexpr>� � z&BaseAction.__repr__.<locals>.<genexpr>�(�))�joinr> � __class__r4 )rG Z state_strr8 rF r9 �__repr__� s zBaseAction.__repr__c C s t | �S �N)�reprrF r8 r8 r9 �__str__� s zBaseAction.__str__) r4 r5 r6 r7 r> �t�Sequence�str�__annotations__r? �OptionalrN rQ r8 r8 r8 r9 r= t s r= c @ s& e Zd ZdZdZejdd�dd�ZdS )� RetryActionr �retryN)r rA c C s t |�| _d S rO )�floatr )rG r r8 r8 r9 �__init__� s zRetryAction.__init__)r4 r5 r6 r> r? rR � SupportsFloatrZ r8 r8 r8 r9 rW � s rW )�first�secondrA c C s | t u r |S | S rO )�_unset)r\ r] r8 r8 r9 � _first_set� s r_ 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_attemptrA c s || _ t� �|� d S rO )rb �superrZ )rG rb �rM r8 r9 rZ � s zRetryError.__init__z t.NoReturnr@ c C s | j jr| j �� �| �d S rO )rb �failed�resultrF r8 r8 r9 �reraise� s zRetryError.reraisec C s | j j� d| j� d�S )N�[�])rM r4 rb rF r8 r8 r9 rQ � s zRetryError.__str__) r4 r5 r6 r7 rZ rg rT rQ � __classcell__r8 r8 rd r9 r` � s r` 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 rO rm )rG rn r8 r8 r9 rZ � s zAttemptManager.__init__Nr@ c C s d S rO r8 rF r8 r8 r9 � __enter__� s zAttemptManager.__enter__ztypes.TracebackType)�exc_type� exc_value� tracebackrA c C s: |d ur&|d ur&| j �|||f� dS | j �d � d S d S )NT)rn � set_exception� set_result)rG rp rq rr r8 r8 r9 �__exit__� s zAttemptManager.__exit__) r4 r5 r6 r7 rZ ro rR rV �Type� BaseException�boolru r8 r8 r8 r9 rk � s �rk 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 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 d e'f e je je'd �d d ��Z(dS ) � BaseRetryingNFr. r/ r- rl � r �stop�waitrX �before�after� before_sleeprg �retry_error_cls�retry_error_callbackc C sJ || _ || _|| _|| _|| _|| _|| _|| _t� � | _ | | _ | | _ d S rO ) r r{ r| rX r} r~ r rg � threading�local�_localr� r� � rG r r{ r| rX r} r~ r rg r� r� r8 r8 r9 rZ � s zBaseRetrying.__init__� r r{ r| rX r} r~ r rg r� r� rA 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.rz ) rM r_ r r{ r| rX r} r~ r rg r� r� r� r8 r8 r9 �copy� s �zBaseRetrying.copyr@ 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)>) rM r4 �idr{ r| r rX r} r~ rF r8 r8 r9 rN � 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�AttributeErrorrR �cast�DictrT �AnyrF r8 r8 r9 r� � s zBaseRetrying.statistics��frA c sT t �� �tjtjtjd�� �fdd� �}tjtjtd�� �fdd� }�|_||_|S )z[Wrap a function for retrying. :param f: A function to wraps for retrying. )�args�kwrA c s �� g| �R i |��S rO r8 )r� r� �r� rG r8 r9 � wrapped_f! s z%BaseRetrying.wraps.<locals>.wrapped_f)r� �kwargsrA c s �j | i |���� �S rO )r� �wraps)r� r� r� r8 r9 � retry_with% s z&BaseRetrying.wraps.<locals>.retry_with)� functoolsr� rR r� r1 rX r� )rG r� r� r� r8 r� r9 r� 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� monotonicrF r8 r8 r9 �begin- s zBaseRetrying.begin)rn rA c C s |j }|d u r(| jd ur"| �|� t� S |jo:t|�� t�}|sR| �|�sR|�� S | j d urf| � |� |j | j d< | � |�r�| j r�| � |�S | �|�}| jr�|�� �||�� �| jr�| �|�}nd}t|�|_| j|7 _| j d |7 < | j d d7 < | jd u�r| �|� t|�S )NZdelay_since_first_attempt� r� r� r )�outcomer} r: re � isinstance� exceptionr3 rX rf r~ �seconds_since_startr� r{ r� r� rg r| rW � next_actionr� r r< )rG rn �futZis_explicit_retryZ retry_excr r8 r8 r9 �iter3 s8 zBaseRetrying.iterc c sb | � � t| d di d�}| j|d�}t|t�r<t|d�V qt|t�r^|�� | �|� qq^qd S )Nr8 )�fnr� r� rm ) r� rl r� r� r: rk r< �prepare_for_next_attemptr )rG rn �dor8 r8 r9 �__iter__X s zBaseRetrying.__iter__.�r� r� r� rA c O s d S rO r8 )rG r� r� r� r8 r8 r9 �__call__f s zBaseRetrying.__call__))r4 r5 r6 r r r# r r( r* r` rR �Callable�Union�intrY rV rx rv r� rZ r^ �objectr r� rT rN �propertyr� r� r1 r� r� r: r< r� � Generatorrk r� r r0 r� r8 r8 r8 r9 ry � st �� �" � % �ry 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� rm ) r� rl r� r� r: rw rs �sys�exc_infort r< r� r )rG r� r� r� rn r� rf r8 r8 r9 r� s s zRetrying.__call__N) r4 r5 r6 r7 rR r� r0 r� r� r8 r8 r8 r9 r� p s �r� � c sT e Zd ZdZedd�� fdd� Zeed�dd��Ze ee j ed d �d d ��Z � Z S ) ra zDEncapsulates a (future or past) attempted call to a target function.N)r� rA c s t � �� || _d S rO )rc rZ r� )rG r� rd r8 r9 rZ � s zFuture.__init__r@ c C s | � � duS )z8Return whether a exception is being held in this future.N)r� rF r8 r8 r9 re � s z Future.failed)r� �value� has_exceptionrA c C s& | |�}|r|� |� n |�|� |S )z Construct a new Future object.)rs rt )�clsr� r� r� r� r8 r8 r9 � construct� s zFuture.construct)r4 r5 r6 r7 r� rZ r� rx re � classmethodrR r� r� rj r8 r8 rd r9 ra � s ra 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 )rl z5State related to a single call wrapped with Retrying.N)r� r� r� r� rA c C sD t �� | _|| _|| _|| _|| _d| _d | _d | _ d| _ d | _ d S )Nr r� ) r� r� r� r� r� r� r� r� r� �outcome_timestampr� r� )rG r� r� r� r� r8 r8 r9 rZ � s zRetryCallState.__init__r@ c C s | j d u rd S | j | j S rO )r� r� rF r8 r8 r9 r� � s z"RetryCallState.seconds_since_startc C s$ d | _ d | _| jd7 _d | _d S �Nr )r� r� r� r� rF r8 r8 r9 r� � s z'RetryCallState.prepare_for_next_attempt)�valrA c C s. t �� }t| j�}|�|� || | _| _d S rO )r� r� ra r� rt r� r� )rG r� �tsr� r8 r8 r9 rt � s zRetryCallState.set_resultztypes.TracebackType| None)r� rA c C s2 t �� }t| j�}|�|d � || | _| _d S r� )r� r� ra r� rs r� r� )rG r� r� r� r8 r8 r9 rs � 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 (� rK z returned � r� z : attempt #z ; slept for z; last result: �>) r� re r� rM r4 rf rY �roundr� r� r� )rG rf r� ZsleptZclsnamer8 r8 r9 rN � s zRetryCallState.__repr__)r4 r5 r6 r7 ry rR rV r1 r� rZ r� rY r� r� rt �Tuplerv rw rs rT rN r8 r8 r8 r9 rl � s � � rl )�funcrA c C s d S rO r8 )r� r8 r8 r9 rX � s rX Fr. r/ r- r� c C s d S rO r8 rz r8 r8 r9 rX � s )�dargs�dkwrA 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| �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)r� r �warnings�warnrM r4 r � AsyncRetrying�tornado�hasattr�genr� �TornadoRetryingr� r� )r� �r�r� r� r8 r9 �wrap s �� zretry.<locals>.wrapN)�len�callablerX r1 )r� r� r� r8 r� r9 rX s )r� )r� )5r 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, rX r1 r3 � NO_RESULTr: r< r= rW r` rk ry r� ra rl r� )er� r� r� r� �typingrR r� �abcr r Z concurrentr �inspectr rX 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� � TYPE_CHECKING�typesr- r. r/ �TypeVarr0 r� r� r1 � Exceptionr3 r� r� r: rY r< r= rW r^ r� r_ r` rk ry r� � version_infora ZFutureGenericTrl �overloadr� rV � Awaitablerx rv Z pip._vendor.tenacity._asyncior� Z pip._vendor.tenacity.tornadowebr� �__all__r8 r8 r8 r9 �<module> s� " 2 H�$�