File: //usr/lib/python3.9/site-packages/pip/_vendor/__pycache__/retrying.cpython-39.pyc
a
?�f�& � @ 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� g| �R i |��S �N��Retrying�call��args�kw��f� �8/usr/lib/python3.9/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 � i ���j�g| �R i |��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 u r dn|| _ |d u r dn|| _|d u r0dn|| _|d u rBdn|| _|d u rTdn|| _|d u rfdn|| _| d u rxdn| | _|
d u r�dn|
| _| d u r�tn| | _ |d u r�dn|| _
g � |d ur̈ � | j � |d ur� � | j
� |d ur�|| _n&|d u �r
� fdd�| _n t| |�| _dd� g�|d u�r6�� | j� |d u�sJ|d u�rV�� | j� |d u�sj| d u�rv�� | j� |
d u�s�| d u�r��� | j� |d u�r�|| _n&|d u �rfd d�| _n t| |�| _| d u �r�| j| _n| | _|
d u �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 � �6Retrying.__init__.<locals>.<lambda>.<locals>.<genexpr>)�anyr )�
stop_funcsr r �<lambda>a r" 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 r" 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||i |��|d�}W n t�� }t||d�}Y n0 | �|�sj|�| 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 s2 �
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 *!