OwlCyberSecurity - MANAGER
Edit File: retrying.cpython-38.pyc
U ��.e�& � @ sl d dl Z d dlmZ d dlZd dlZd dlZdZdd� ZG dd� de�Z G dd � d e�Z G d d � d e �Z dS ) � N)�sixi���?c sB t � �dkr,t� d �r,dd� }|� d �S � �fdd�}|S dS )z� Decorator function that instantiates the Retrying object @param *dargs: positional arguments passed to Retrying object @param **dkw: keyword arguments passed to the Retrying object � r c s t �� �� fdd��}|S )Nc s t � j� f| �|�S �N��Retrying�call��args�kw��f� �8/usr/lib/python3.8/site-packages/pip/_vendor/retrying.py� wrapped_f$ s z-retry.<locals>.wrap_simple.<locals>.wrapped_f�r �wraps�r r r r r � wrap_simple" s zretry.<locals>.wrap_simplec s t �� ���� fdd��}|S )Nc s t � ��j�f| �|�S r r r )�dargs�dkwr r r r / s z&retry.<locals>.wrap.<locals>.wrapped_fr r �r r r r �wrap- s zretry.<locals>.wrapN)�len�callable)r r r r r r r �retry s r c @ sn e Zd Zddd�Zdd� Zdd� Zd d � Zd d � Zd d� Zdd� Z dd� Z dd� Z dd� Z dd� Z dd� ZdS ) r NFc s |d kr dn|| _ |d kr dn|| _|d kr0dn|| _|d krBdn|| _|d krTdn|| _|d krfdn|| _| d krxdn| | _| d kr�dn| | _| d kr�tn| | _ |d kr�dn|| _ g � |d k r̈ � | j � |d k r� � | j � |d k r�|| _n&|d k�r � fdd�| _n t| |�| _dd� g�|d k �r6�� | j� |d k �sJ|d k �rV�� | j� |d k �sj| d k �rv�� | j� | d k �s�| d k �r��� | j� |d k �r�|| _n&|d k�rfd d�| _n t| |�| _| d k�r�| j| _n| | _| d k�r�| j| _n| | _|| _d S ) N� �d �� r r c s t � �fdd��D ��S )Nc 3 s | ]}|� ��V qd S r r ��.0r �ZattemptsZdelayr r � <genexpr>a s �6Retrying.__init__.<locals>.<lambda>.<locals>.<genexpr>)�anyr )� stop_funcsr r �<lambda>a � z#Retrying.__init__.<locals>.<lambda>c _ s dS )Nr r )r �kwargsr r r r% h r& c s t � �fdd��D ��S )Nc 3 s | ]}|� ��V qd S r r r r r r r! y s r" )�maxr )� wait_funcsr r r% y r& )�_stop_max_attempt_number�_stop_max_delay� _wait_fixed�_wait_random_min�_wait_random_max�_wait_incrementing_start� _wait_incrementing_increment� _wait_exponential_multiplier�MAX_WAIT�_wait_exponential_max�_wait_jitter_max�append�stop_after_attempt�stop_after_delay�stop�getattr� fixed_sleep� random_sleep�incrementing_sleep�exponential_sleep�wait� always_reject�_retry_on_exception� never_reject�_retry_on_result�_wrap_exception)�selfr8 r> Zstop_max_attempt_numberZstop_max_delayZ wait_fixedZwait_random_minZwait_random_maxZwait_incrementing_startZwait_incrementing_incrementZwait_exponential_multiplierZwait_exponential_maxZretry_on_exceptionZretry_on_result�wrap_exceptionZ stop_funcZ wait_funcZwait_jitter_maxr )r$ r) r �__init__: sR zRetrying.__init__c C s || j kS )z;Stop after the previous attempt >= stop_max_attempt_number.)r* �rD �previous_attempt_number� delay_since_first_attempt_msr r r r6 � s zRetrying.stop_after_attemptc C s || j kS )z=Stop after the time from the first attempt >= stop_max_delay.)r+ rG r r r r7 � s zRetrying.stop_after_delayc C s dS )z#Don't sleep at all before retrying.r r rG r r r �no_sleep� s zRetrying.no_sleepc C s | j S )z0Sleep a fixed amount of time between each retry.)r, rG r r r r: � s zRetrying.fixed_sleepc C s t �| j| j�S )zISleep a random amount of time between wait_random_min and wait_random_max)�randomZrandintr- r. rG r r r r; � s zRetrying.random_sleepc C s$ | j | j|d }|dk r d}|S )z� Sleep an incremental amount of time after each attempt, starting at wait_incrementing_start and incrementing by wait_incrementing_increment r r )r/ r0 )rD rH rI �resultr r r r< � s zRetrying.incrementing_sleepc C s2 d| }| j | }|| jkr"| j}|dk r.d}|S )N� r )r1 r3 )rD rH rI ZexprL r r r r= � s zRetrying.exponential_sleepc C s dS )NFr �rD rL r r r rA � s zRetrying.never_rejectc C s dS )NTr rN r r r r? � s zRetrying.always_rejectc C s4 d}|j r || �|jd �O }n|| �|j�O }|S )NFr )� has_exceptionr@ �valuerB )rD �attemptZrejectr r r � should_reject� s zRetrying.should_rejectc O s� t tt�� d ��}d}zt|||�|d�}W n t�� }t||d�}Y nX | �|�sf|�| j�S t tt�� d ��| }| � ||�r�| js�|j r�|�� �q�t |��n<| � ||�} | j r�t�� | j } | td| � } t�| d � |d7 }qd S )Nr r FTr g @�@)�int�round�time�Attempt�sys�exc_inforR �getrC r8 rO � RetryErrorr> r4 rK r( �sleep) rD �fnr r' Z start_time�attempt_numberrQ �tbrI r[ Zjitterr r r r � s( z Retrying.call)NNNNNNNNNNNNNFNNN)�__name__� __module__� __qualname__rF r6 r7 rJ r: r; r< r= rA r? rR r r r r r r 8 s: � S r c @ s* e Zd ZdZdd� Zd dd�Zdd� Zd S ) rV z� An Attempt encapsulates a call to a target function that may end as a normal return value from the function or an Exception depending on what occurred during the execution. c C s || _ || _|| _d S r )rP r] rO )rD rP r] rO r r r rF � s zAttempt.__init__Fc C s@ | j r6|rt| ��q<t�| jd | jd | jd � n| jS dS )z� Return the return value of this Attempt instance or raise an Exception. If wrap_exception is true, this Attempt is wrapped inside of a RetryError before being raised. r r rM N)rO rZ r ZreraiserP )rD rE r r r rY � s "z Attempt.getc C s: | j r&d�| jd�t�| jd ���S d�| j| j�S d S )NzAttempts: {0}, Error: {1}� rM zAttempts: {0}, Value: {1})rO �formatr] �join� traceback� format_tbrP �rD r r r �__repr__� s zAttempt.__repr__N)F)r_ r` ra �__doc__rF rY rh r r r r rV � s rV c @ s e Zd ZdZdd� Zdd� ZdS )rZ zU A RetryError encapsulates the last Attempt instance right before giving up. c C s || _ d S r )� last_attempt)rD rj r r r rF s zRetryError.__init__c C s d� | j�S )NzRetryError[{0}])rc rj rg r r r �__str__ s zRetryError.__str__N)r_ r` ra ri rF rk r r r r rZ s rZ ) rK Z pip._vendorr rW rU re r2 r �objectr rV � ExceptionrZ r r r r �<module> s *!