OwlCyberSecurity - MANAGER
Edit File: __init__.cpython-39.pyc
a )��e�G � @ 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<�rLd dl=Z=dd+l'm>Z> dd,l m?Z? ej@d-ejAd.�ZBe�@d/�ZCejDeBeBd0�d1d2��ZejDejEejEejAeBgeBf d3�d4d2��ZejEejEejFeBejAeBgeBf f d3�d5d2�ZG d6d7� d7eG�ZHeI� ZJG d8d9� d9�ZKG d:d;� d;eL�ZMG d<d=� d=�ZNG d>d?� d?eN�ZOeI� ZPejFejEeIf ejEejEd@�dAdB�ZQG dCdD� dDeG�ZRG dEdF� dF�ZSG dGdH� dHe�ZTG dIdJ� dJeT�ZUG dKdL� dLe jV�ZVG dMdN� dN�ZWd dOlXmYZY e;�r�d dPlZm[Z[ dS )Q� 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)� wait_base)� stop_base� WrappedFn)�bound�_RetValT)�fn�returnc C s d S �N� )r2 r5 r5 �^/home/gouroczh/virtualenv/pat/3.9/lib/python3.9/site-packages/pip/_vendor/tenacity/__init__.py�retryc s r7 )�dargs�dkwr3 c O s d S r4 r5 �r8 r9 r5 r5 r6 r7 h 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 ��fr3 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< �rr: r5 r6 �wrapx s �� zretry.<locals>.wrapN)�len�callabler7 r/ )r8 r9 rK r5 r: r6 r7 m s c @ s e Zd ZdZdS )�TryAgainz/Always retry the executed function when raised.N)rB � __module__� __qualname__�__doc__r5 r5 r5 r6 rN � s rN c @ s e Zd ZdS )� DoAttemptN�rB rO rP r5 r5 r5 r6 rR � s rR c @ s e Zd ZdS )�DoSleepNrS r5 r5 r5 r6 rT � s rT 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 r5 � REPR_FIELDSN�NAME�r3 c s. d� � fdd�� jD ��}� jj� d|� d�S )Nz, c 3 s" | ]}|� d t � |���V qdS )�=N)�getattr)�.0�field��selfr5 r6 � <genexpr>� � z&BaseAction.__repr__.<locals>.<genexpr>�(�))�joinrV rA rB )r^ Z state_strr5 r] r6 �__repr__� s zBaseAction.__repr__c C s t | �S r4 )�reprr] r5 r5 r6 �__str__� s zBaseAction.__str__) rB rO rP rQ rV �t�Sequence�str�__annotations__rW �Optionalrd rf r5 r5 r5 r6 rU � s rU c @ s& e Zd ZdZdZejdd�dd�ZdS )� RetryActionr r7 N)r r3 c C s t |�| _d S r4 )�floatr )r^ r r5 r5 r6 �__init__� s zRetryAction.__init__)rB rO rP rV rW rg � SupportsFloatrn r5 r5 r5 r6 rl � s rl )�first�secondr3 c C s | t u r |S | S r4 )�_unset)rp rq r5 r5 r6 � _first_set� s rs 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_attemptr3 c s || _ t� �|� d S r4 )rv �superrn )r^ rv �rA r5 r6 rn � s zRetryError.__init__z t.NoReturnrX c C s | j jr| j �� �| �d S r4 )rv �failed�resultr] r5 r5 r6 �reraise� s zRetryError.reraisec C s | j j� d| j� d�S )N�[�])rA rB rv r] r5 r5 r6 rf � s zRetryError.__str__) rB rO rP rQ rn r{ ri rf � __classcell__r5 r5 rx r6 rt � s rt 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 r4 r� )r^ r� r5 r5 r6 rn � s zAttemptManager.__init__NrX c C s d S r4 r5 r] r5 r5 r6 � __enter__� s zAttemptManager.__enter__�types.TracebackType)�exc_type� exc_value� tracebackr3 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� r5 r5 r6 �__exit__� s zAttemptManager.__exit__) rB rO rP rQ rn r� rg rk �Typer� �boolr� r5 r5 r5 r6 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�waitr7 �before�after� before_sleepr{ �retry_error_cls�retry_error_callbackc C sJ || _ || _|| _|| _|| _|| _|| _|| _t� � | _ | | _ | | _ d S r4 ) r r� r� r7 r� r� r� r{ � threading�local�_localr� r� � r^ r r� r� r7 r� r� r� r{ r� r� r5 r5 r6 rn � s zBaseRetrying.__init__) r r� r� r7 r� r� r� r{ r� r� r3 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� ) rA rs r r� r� r7 r� r� r� r{ r� r� r� r5 r5 r6 �copy� s �zBaseRetrying.copyrX 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)>) rA rB �idr� r� r r7 r� r� r] r5 r5 r6 rd 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�AttributeErrorr] r5 r5 r6 r� $ s zBaseRetrying.statisticsr; c sT t �� �tjtjtjd�� �fdd� �}tjtjtd�� �fdd� }�|_||_|S )z[Wrap a function for retrying. :param f: A function to wraps for retrying. )�args�kwr3 c s �� g| �R i |��S r4 r5 )r� r� �r< r^ r5 r6 � wrapped_fF s z%BaseRetrying.wraps.<locals>.wrapped_f)r� �kwargsr3 c s �j | i |���� �S r4 )r� rI )r� r� r� r5 r6 � retry_withJ s z&BaseRetrying.wraps.<locals>.retry_with)� functoolsrI rg �Anyr/ r7 r� )r^ r< r� r� r5 r� r6 rI @ 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] r5 r5 r6 �beginR s zBaseRetrying.begin)r� r3 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� rR ry r> � exceptionrN r7 rz r� �seconds_since_startr� r� r� r� r{ r� rl � next_actionr� r� rT )r^ r� �futZis_explicit_retryZ retry_excr r5 r5 r6 �iterX s8 zBaseRetrying.iterc c sb | � � t| d di d�}| j|d�}t|t�r<t|d�V qt|t�r^|�� | �|� qq^qd S )Nr5 )r2 r� r� r� ) r� r� r� r> rR r rT �prepare_for_next_attemptr )r^ r� �dor5 r5 r6 �__iter__} s zBaseRetrying.__iter__.�r2 r� r� r3 c O s d S r4 r5 )r^ r2 r� r� r5 r5 r6 �__call__� s zBaseRetrying.__call__))rB rO rP r r r# r r( r* rt rg �Callable�Union�intrm r rk r� r� r� rn rr �objectr� ri rd �property�Dictr� r/ rI r� rR rT r� � Generatorr r� r r1 r� r5 r5 r5 r6 r� � sl �� �" � %r� c @ s2 e Zd ZdZejdef ejejed�dd�ZdS )rH 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_objectr2 r� r� r� ) r� r� r� r> rR r� r� �sys�exc_infor� rT r� r )r^ r2 r� r� r� r� rz r5 r5 r6 r� � s zRetrying.__call__N) rB rO rP rQ rg r� r1 r� r� r5 r5 r5 r6 rH � s rH c sT e Zd ZdZedd�� fdd� Zeed�dd��Ze ee j ed d �d d ��Z � Z S ) ru zDEncapsulates a (future or past) attempted call to a target function.N)r� r3 c s t � �� || _d S r4 )rw rn r� )r^ r� rx r5 r6 rn � s zFuture.__init__rX c C s | � � duS )z8Return whether a exception is being held in this future.N)r� r] r5 r5 r6 ry � s z Future.failed)r� �value� has_exceptionr3 c C s& | |�}|r|� |� n |�|� |S )z Construct a new Future object.)r� r� )�clsr� r� r� r� r5 r5 r6 � construct� s zFuture.construct)rB rO rP rQ r� rn r� r� ry � classmethodrg r� r� r~ r5 r5 rx r6 ru � s ru 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� r2 r� r� r3 c C sD t �� | _|| _|| _|| _|| _d| _d | _d | _ d| _ d | _ d S )Nr r� ) r� r� r� r� r2 r� r� r� r� �outcome_timestampr� r� )r^ r� r2 r� r� r5 r5 r6 rn � s zRetryCallState.__init__rX c C s | j d u rd S | j | j S r4 )r� r� r] r5 r5 r6 r� � s z"RetryCallState.seconds_since_startc C s$ d | _ d | _| jd7 _d | _d S �Nr )r� r� r� r� r] r5 r5 r6 r� � s z'RetryCallState.prepare_for_next_attempt)�valr3 c C s. t �� }t| j�}|�|� || | _| _d S r4 )r� r� ru r� r� r� r� )r^ r� �tsr� r5 r5 r6 r� � s zRetryCallState.set_resultr� )r� r3 c C s2 t �� }t| j�}|�|d � || | _| _d S r� )r� r� ru r� r� r� r� )r^ r� r� r� r5 r5 r6 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� ry r� rA rB rz rm �roundr� r� r� )r^ rz r� ZsleptZclsnamer5 r5 r6 rd � s zRetryCallState.__repr__)rB rO rP rQ r� rg rk r/ r� rn r� rm r� r� r� �Tupler� r� r� rd r5 r5 r5 r6 r� � s � "r� )rC )rG )\r� r� r� r� �typingrg r? �abcr r Z concurrentr �inspectr r7 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% Zwait_full_jitterr& r� r' r( r� r) r* r� r+ r, rD � TYPE_CHECKING�typesr- r. �TypeVarr� r/ r1 �overloadr� r� � ExceptionrN r� Z NO_RESULTrR rm rT rU rl rr rs rt r r� rH ru r� Z pip._vendor.tenacity._asynciorC Z pip._vendor.tenacity.tornadowebrG r5 r5 r5 r6 �<module> s� $, " -F