File: //usr/local/CyberPanel/lib64/python3.10/site-packages/botocore/__pycache__/waiter.cpython-310.pyc
o
�h�8 � @ s� d dl Z d dlZd dlZd dlmZ d dlmZ ddlmZ ddl m
Z
m Z m Z e �
e�Zdd� Zd d
� ZG d d � d �ZG d
d� d�ZG dd� d�ZG dd� d�ZG dd� d�ZdS )� N)�WaiterDocstring)�get_service_module_name� )�
xform_name)� ClientError�WaiterConfigError� WaiterErrorc C s~ |� | �}t|j�}tt||��}dd� }t| |jj|jj|dd�|_ t
t |jj�� d| � ��}t |t
fd|i�}|| ||�S )a
:type waiter_name: str
:param waiter_name: The name of the waiter. The name should match
the name (including the casing) of the key name in the waiter
model file (typically this is CamelCasing).
:type waiter_model: botocore.waiter.WaiterModel
:param waiter_model: The model for the waiter configuration.
:type client: botocore.client.BaseClient
:param client: The botocore client associated with the service.
:rtype: botocore.waiter.Waiter
:return: The waiter object.
c [ s t j| fi |�� d S �N)�Waiter�wait)�self�kwargs� r �E/usr/local/CyberPanel/lib/python3.10/site-packages/botocore/waiter.pyr 6 s z'create_waiter_with_client.<locals>.waitF)� waiter_name�
event_emitter�
service_model�service_waiter_model�include_signaturez.Waiter.r )�
get_waiterr � operation�NormalizedOperationMethod�getattrr �meta�eventsr �__doc__�strr �typer
) r � waiter_model�client�single_waiter_config�operation_name�operation_methodr �waiter_class_name�documented_waiter_clsr r r �create_waiter_with_client s(
�� ��r% c C s$ | � d�}t|t�rd|v rdS dS )N�Error�CodeTF)�get�
isinstance�dict)�response�errorr r r �is_valid_waiter_errorO s
r- c @ � e Zd Zdd� Zdd� ZdS )r c C s
|| _ d S r )�_client_method)r �
client_methodr r r �__init__W s
z"NormalizedOperationMethod.__init__c
K s> z | j di |��W S ty } z |jW Y d }~S d }~ww )Nr )r/ r r+ )r r
�er r r �__call__Z s ��z"NormalizedOperationMethod.__call__N)�__name__�
__module__� __qualname__r1 r3 r r r r r V s r c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) � WaiterModel� c C s@ |d | _ |�dd�}| �|� || _tt|d �� ��| _dS )a�
Note that the WaiterModel takes ownership of the waiter_config.
It may or may not mutate the waiter_config. If this is a concern,
it is best to make a copy of the waiter config before passing it to
the WaiterModel.
:type waiter_config: dict
:param waiter_config: The loaded waiter config
from the <service>*.waiters.json file. This can be
obtained from a botocore Loader object as well.
�waiters�version�unknownN)�_waiter_configr( �_verify_supported_versionr: �list�sorted�keys� waiter_names)r �
waiter_configr: r r r r1 d s
zWaiterModel.__init__c C s& || j krtd| j � d|� �d��d S )Nz7Unsupported waiter version, supported version must be: z#, but version of waiter config is: �� error_msg)�SUPPORTED_VERSIONr )r r: r r r r= | s
����z%WaiterModel._verify_supported_versionc C s2 z
| j | }W t|�S ty td|� ���w )NzWaiter does not exist: )r< �KeyError�
ValueError�SingleWaiterConfig)r r r r r r r � s ��zWaiterModel.get_waiterN)r4 r5 r6 rE r1 r= r r r r r r7 a s
r7 c @ s$ e Zd ZdZdd� Zedd� �ZdS )rH z�Represents the waiter configuration for a single waiter.
A single waiter is considered the configuration for a single
value associated with a named waiter (i.e TableExists).
c C s6 || _ |�dd�| _|d | _|d | _|d | _d S )N� description� r �delay� maxAttempts)�_configr( rI r rK � max_attempts)r r r r r r1 � s
zSingleWaiterConfig.__init__c C s* g }| j d D ] }t|�}|�|� q|S )N� acceptors)rM �AcceptorConfig�append)r rO �acceptor_config�acceptorr r r rO � s
z SingleWaiterConfig.acceptorsN)r4 r5 r6 r r1 �propertyrO r r r r rH � s
rH c @ sP e Zd Zdd� Zedd� �Zdd� Zdd� Zd d
� Zd d � Z d
d� Z
dd� Z dS )rP c C s8 |d | _ |d | _|d | _|�d�| _| �� | _d S )N�state�matcher�expected�argument)rU rV rW r( rX �_create_matcher_func� matcher_func)r �configr r r r1 � s
zAcceptorConfig.__init__c C s� | j dkrd| j� d| j� d�S | j dkr d| j� d| j� d�S | j dkr0d| j� d| j� d�S | j d kr;d
| j� �S | j d krFd | j� �S d
| j � d�S )N�pathzFor expression "z " we matched expected path: "�"�pathAllz&" all members matched expected path: "�pathAnyz" at least once�statusz#Matched expected HTTP status code: r, z%Matched expected service error code: z)No explanation for unknown waiter type: ")rV rX rW �r r r r � explanation� s"
��
��
zAcceptorConfig.explanationc C sl | j dkr | �� S | j dkr| �� S | j dkr| �� S | j dkr$| �� S | j dkr-| �� S td| j � �d��)Nr\ r^ r_ r` r, zUnknown acceptor: rC )rV �_create_path_matcher�_create_path_all_matcher�_create_path_any_matcher�_create_status_matcher�_create_error_matcherr ra r r r rY � s
�z#AcceptorConfig._create_matcher_funcc �$ t �| j��| j� � �fdd�}|S )Nc s t | �rd S ��| �� kS r )r- �search�r+ �rW �
expressionr r �acceptor_matches� s z=AcceptorConfig._create_path_matcher.<locals>.acceptor_matches��jmespath�compilerX rW �r rm r rk r rc � s z#AcceptorConfig._create_path_matcherc rh )Nc sD t | �rd S ��| �}t|t�r|sdS |D ] }|� kr dS qdS �NFT�r- ri r) r> �r+ �result�elementrk r r rm � �
�zAAcceptorConfig._create_path_all_matcher.<locals>.acceptor_matchesrn rq r rk r rd � � z'AcceptorConfig._create_path_all_matcherc rh )Nc sD t | �rd S ��| �}t|t�r|sdS |D ] }|� kr dS qdS rr rs rt rk r r rm rw zAAcceptorConfig._create_path_any_matcher.<locals>.acceptor_matchesrn rq r rk r re � rx z'AcceptorConfig._create_path_any_matcherc � | j � � fdd�}|S )Nc s | � di �� d�}|� kS )N�ResponseMetadata�HTTPStatusCode�r( )r+ � status_code�rW r r rm s �z?AcceptorConfig._create_status_matcher.<locals>.acceptor_matchesr~ rq r r~ r rf s z%AcceptorConfig._create_status_matcherc ry )Nc sD � du rd| v o
d| d v S � du rd| vS | � di �� dd�� kS )NTr& r' FrJ r| rj r~ r r rm $ s
z>AcceptorConfig._create_error_matcher.<locals>.acceptor_matchesr~ rq r r~ r rg ! s z$AcceptorConfig._create_error_matcherN) r4 r5 r6 r1 rT rb rY rc rd re rf rg r r r r rP � s
rP c @ r. )r
c C s || _ || _|| _dS )a�
:type name: string
:param name: The name of the waiter
:type config: botocore.waiter.SingleWaiterConfig
:param config: The configuration for the waiter.
:type operation_method: callable
:param operation_method: A callable that accepts **kwargs
and returns a response. For example, this can be
a method from a botocore client.
N)�_operation_method�namer[ )r r� r[ r" r r r r1 9 s
zWaiter.__init__c K s0 t | jj�}d}|�di �}|�d| jj�}|�d| jj�}d }d} | jdi |��} |d7 }|D ]}
|
�| �r?|
}|
j } n q1t
| �r\t | j d�
| d �d
d �| d �d d ��| d
��|dkrgt�d� d S |dkryd|
j� �} t | j | | d
��||kr�|d u r�d} nd|
j� �} t | j | | d
��t�|� q#)N�waiting� WaiterConfig�Delay� MaxAttemptsr Tr zAn error occurred ({}): {}r& r' �Unknown�Message)r� �reason�
last_response�successz3Waiting complete, waiter matched the success state.�failurez-Waiter encountered a terminal failure state: zMax attempts exceededz2Max attempts exceeded. Previously accepted state: r )r> r[ rO �popr( rK rN r rZ rU r- r r� �format�logger�debugrb �time�sleep) r r
rO �
current_stater[ � sleep_amountrN �last_matched_acceptor� num_attemptsr+ rS r� r r r r N sf
���� ����
�z Waiter.waitN)r4 r5 r6 r1 r r r r r r
8 s r
)�loggingr� ro �botocore.docs.docstringr �botocore.utilsr rJ r �
exceptionsr r r � getLoggerr4 r� r% r- r r7 rH rP r
r r r r �<module> s
4 -