File: //usr/local/lib/python3.10/dist-packages/tenacity/__pycache__/stop.cpython-310.pyc
o
���g � @ s� d dl Z d dlZd dlmZ ejrd dlZd dlmZ G dd� de j�Zej eej
dge f f Z G dd� de�Z
G d d
� d
e�ZG d d � d e�Ze� ZG d
d� de�ZG dd� de�ZG dd� de�ZG dd� de�ZdS )� N)�_utils)�RetryCallStatec @ s< e Zd ZdZejdddefdd��Zdd d
�Zdd d
�Z dS )� stop_basez(Abstract base class for stop strategies.� retry_stater �returnc C s d S �N� ��selfr r r �8/usr/local/lib/python3.10/dist-packages/tenacity/stop.py�__call__ s zstop_base.__call__�other�stop_allc C �
t | |�S r )r �r
r
r r r �__and__" �
zstop_base.__and__�stop_anyc C r r )r r r r r �__or__% r zstop_base.__or__N)r
r r r )r
r r r )
�__name__�
__module__� __qualname__�__doc__�abc�abstractmethod�boolr r r r r r r r s
r r c @ �4 e Zd ZdZdeddfdd�Zdddefd d
�ZdS ) r z+Stop if any of the stop condition is valid.�stopsr Nc G �
|| _ d S r �r �r
r r r r �__init__/ r zstop_any.__init__r r c � t � fdd�| jD ��S )Nc 3 � � | ]}|� �V qd S r r ��.0�x�r r r � <genexpr>3 � � z$stop_any.__call__.<locals>.<genexpr>)�anyr r r r' r r 2 � zstop_any.__call__�r r r r r r! r r r r r r r , � r c @ r ) r z*Stop if all the stop conditions are valid.r r Nc G r r r r r r r r! 9 r zstop_all.__init__r r c r" )Nc 3 r# r r r$ r' r r r( = r) z$stop_all.__call__.<locals>.<genexpr>)�allr r r r' r r < r+ zstop_all.__call__r, r r r r r 6 r- r c @ s" e Zd ZdZdddefdd�ZdS )� _stop_neverz Never stop.r r r c C s dS )NFr r r r r r C s z_stop_never.__call__N)r r r r r r r r r r r/ @ s r/ c @ s, e Zd ZdZd dd�Zdd defd
d �ZdS )
�stop_when_event_setz!Stop when the given event is set.�event�threading.Eventr Nc C r r )r1 )r
r1 r r r r! M r z stop_when_event_set.__init__r r c C s
| j �� S r )r1 �is_setr r r r r P r z stop_when_event_set.__call__)r1 r2 r N)r r r r r! r r r r r r r0 J s
r0 c @ r ) �stop_after_attemptz.Stop when the previous attempt >= max_attempt.�max_attempt_numberr Nc C r r )r5 )r
r5 r r r r! W r zstop_after_attempt.__init__r r c C s |j | jkS r )�attempt_numberr5 r r r r r Z s zstop_after_attempt.__call__)r r r r �intr! r r r r r r r4 T r- r4 c @ �6 e Zd ZdZdejddfdd�Zdddefd d
�ZdS ) �stop_after_delayaS
Stop when the time from the first attempt >= limit.
Note: `max_delay` will be exceeded, so when used with a `wait`, the actual total delay will be greater
than `max_delay` by some of the final sleep period before `max_delay` is exceeded.
If you need stricter timing with waits, consider `stop_before_delay` instead.
� max_delayr Nc C � t �|�| _d S r �r �
to_secondsr: �r
r: r r r r! h � zstop_after_delay.__init__r r c C s |j d u r td��|j | jkS �Nz4__call__() called but seconds_since_start is not set)�seconds_since_start� RuntimeErrorr: r r r r r k s
zstop_after_delay.__call__� r r r r r �time_unit_typer! r r r r r r r9 ^ s r9 c @ r8 ) �stop_before_delaya
Stop right before the next attempt would take place after the time from the first attempt >= limit.
Most useful when you are using with a `wait` function like wait_random_exponential, but need to make
sure that the max_delay is not exceeded.
r: r Nc C r; r r< r> r r r r! y r? zstop_before_delay.__init__r r c C s$ |j d u r td��|j |j | jkS r@ )rA rB �upcoming_sleepr: r r r r r | s
��zstop_before_delay.__call__rC r r r r rE q s rE )r �typing�tenacityr �
TYPE_CHECKING� threadingr �ABCr �Union�Callabler � StopBaseTr r r/ �
stop_neverr0 r4 r9 rE r r r r �<module> s