File: //home/arjun/projects/env/lib/python3.10/site-packages/botocore/__pycache__/waiter.cpython-310.pyc
o
*we�7 � @ 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
dt |jj�| f �}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 �H/home/arjun/projects/env/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 %s.Waiter.%sr )�
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_errorP s
r- c @ � e Zd Zdd� Zdd� ZdS )r c C s
|| _ d S r )�_client_method)r �
client_methodr r r �__init__X 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__[ s ��z"NormalizedOperationMethod.__call__N)�__name__�
__module__� __qualname__r1 r3 r r r r r W 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 e s
zWaiterModel.__init__c C s" || j krtd| j |f d��d S )Nz^Unsupported waiter version, supported version must be: %s, but version of waiter config is: %s�� error_msg)�SUPPORTED_VERSIONr )r r: r r r r= } s
���z%WaiterModel._verify_supported_versionc C s0 z
| j | }W t|�S ty td| ��w )NzWaiter does not exist: %s)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 b 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 dkr
d�| j| j�S | j dkrd| j| jf S | j dkr'd| j| jf S | j dkr1d| j S | j d kr;d
| j S d | j S ) N�pathz2For expression "{}" we matched expected path: "{}"�pathAllz;For expression "%s" all members matched excepted path: "%s"�pathAnyz@For expression "%s" we matched expected path: "%s" at least once�statusz%Matched expected HTTP status code: %sr, z'Matched expected service error code: %sz,No explanation for unknown waiter type: "%s")rV �formatrX rW �r r r r � explanation� s*
�
��
��
�zAcceptorConfig.explanationc C sj | 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: %srC )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 � z%AcceptorConfig._create_status_matcherc ry )Nc s | � di �� dd�� kS )Nr& r' rJ r| rj r~ r r rm * s z>AcceptorConfig._create_error_matcher.<locals>.acceptor_matchesr~ rq r r~ r rg ' r 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 7 s
zWaiter.__init__c K s, 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 �f | d
��|dkrgt
�d� d S |dkrxd|
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 (%s): %sr& r' �Unknown�Message)r� �reason�
last_response�successz3Waiting complete, waiter matched the success state.�failurez/Waiter encountered a terminal failure state: %szMax attempts exceededz4Max attempts exceeded. Previously accepted state: %sr )r> r[ rO �popr( rK rN r� rZ rU r- r r� �logger�debugrb �time�sleep) r r
rO �
current_stater[ � sleep_amountrN �last_matched_acceptor� num_attemptsr+ rS r� r r r r L sl
���� ������
�z Waiter.waitN)r4 r5 r6 r1 r r r r r r
6 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
5 -