File: //opt/alt/python37/lib/python3.7/site-packages/botocore/__pycache__/waiter.cpython-37.pyc
B
�P�e�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| f|� d S )N)�Waiter�wait)�self�kwargs� r
�@/opt/alt/python37/lib/python3.7/site-packages/botocore/waiter.pyr
6 s z'create_waiter_with_client.<locals>.waitF)� waiter_nameZ
event_emitter�
service_modelZservice_waiter_modelZinclude_signaturez %s.Waiter.%sr
)�
get_waiterr � operation�NormalizedOperationMethod�getattrr �meta�eventsr �__doc__�strr �typer ) r Z waiter_model�client�single_waiter_configZoperation_name�operation_methodr
Zwaiter_class_nameZdocumented_waiter_clsr
r
r �create_waiter_with_client s"
r c C s$ | � d�}t|t�r d|kr dS dS )N�Error�CodeTF)�get�
isinstance�dict)�response�errorr
r
r �is_valid_waiter_errorP s
r% c @ s e Zd Zdd� Zdd� ZdS )r c C s
|| _ d S )N)�_client_method)r Z
client_methodr
r
r �__init__X s z"NormalizedOperationMethod.__init__c
K s6 y | j f |�S tk
r0 } z|jS d }~X Y nX d S )N)r& r r# )r r �er
r
r �__call__[ s z"NormalizedOperationMethod.__call__N)�__name__�
__module__� __qualname__r' r) 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_versionr0 �list�sorted�keysZ waiter_names)r Z
waiter_configr0 r
r
r r' e s
zWaiterModel.__init__c C s" || j kr td| 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 r0 r
r
r r3 } s
z%WaiterModel._verify_supported_versionc C s8 y| j | }W n tk
r. td| ��Y nX t|�S )NzWaiter does not exist: %s)r2 �KeyError�
ValueError�SingleWaiterConfig)r r r r
r
r r � s
zWaiterModel.get_waiterN)r* r+ r, r8 r' r3 r r
r
r
r r- b s
r- c @ s$ e Zd ZdZdd� Zedd� �ZdS )r; 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 �delayZ maxAttempts)�_configr r< r r> � max_attempts)r r r
r
r r' � s
zSingleWaiterConfig.__init__c C s. g }x$| j d D ]}t|�}|�|� qW |S )N� acceptors)r? �AcceptorConfig�append)r rA Zacceptor_config�acceptorr
r
r rA � s
z SingleWaiterConfig.acceptorsN)r* r+ r, r r' �propertyrA r
r
r
r r; � s
r; c @ sP e Zd Zdd� Zedd� �Zdd� Zdd� Zd d
� Zd d � Z d
d� Z
dd� Z dS )rB c C s8 |d | _ |d | _|d | _|�d�| _| �� | _d S )N�state�matcher�expected�argument)rF rG rH r rI �_create_matcher_func� matcher_func)r �configr
r
r r' � s
zAcceptorConfig.__init__c C s� | j dkrd�| j| j�S | j dkr4d| j| jf S | j dkrNd| j| jf S | j dkrbd| j S | j d krvd
| j S d | j S d 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")rG �formatrI rH )r r
r
r � explanation� s
zAcceptorConfig.explanationc C sn | j dkr| �� S | j dkr$| �� S | j dkr6| �� S | j dkrH| �� S | j dkrZ| �� S td| j d��d S )NrM rN rO rP r$ zUnknown acceptor: %s)r7 )rG �_create_path_matcher�_create_path_all_matcher�_create_path_any_matcher�_create_status_matcher�_create_error_matcherr )r r
r
r rJ � s
z#AcceptorConfig._create_matcher_funcc s$ t �| j��| j� � �fdd�}|S )Nc s t | �r d S ��| �� kS )N)r% �search)r# )rH �
expressionr
r �acceptor_matches� s z=AcceptorConfig._create_path_matcher.<locals>.acceptor_matches)�jmespath�compilerI rH )r rZ r
)rH rY r rS � s z#AcceptorConfig._create_path_matcherc s$ t �| j��| j� � �fdd�}|S )Nc sF t | �r d S ��| �}t|t�r$|s(dS x|D ]}|� kr.dS q.W dS )NFT)r% rX r! r4 )r# �result�element)rH rY r
r rZ � s
zAAcceptorConfig._create_path_all_matcher.<locals>.acceptor_matches)r[ r\ rI rH )r rZ r
)rH rY r rT � s z'AcceptorConfig._create_path_all_matcherc s$ t �| j��| j� � �fdd�}|S )Nc sF t | �r d S ��| �}t|t�r$|s(dS x|D ]}|� kr.dS q.W dS )NFT)r% rX r! r4 )r# r] r^ )rH rY r
r rZ s
zAAcceptorConfig._create_path_any_matcher.<locals>.acceptor_matches)r[ r\ rI rH )r rZ r
)rH rY r rU s z'AcceptorConfig._create_path_any_matcherc s | j � � fdd�}|S )Nc s | � di �� d�}|� kS )NZResponseMetadataZHTTPStatusCode)r )r# � status_code)rH r
r rZ s z?AcceptorConfig._create_status_matcher.<locals>.acceptor_matches)rH )r rZ r
)rH r rV s z%AcceptorConfig._create_status_matcherc s | j � � fdd�}|S )Nc s | � di �� dd�� kS )Nr r r= )r )r# )rH r
r rZ * s z>AcceptorConfig._create_error_matcher.<locals>.acceptor_matches)rH )r rZ r
)rH r rW ' s z$AcceptorConfig._create_error_matcherN) r* r+ r, r' rE rR rJ rS rT rU rV rW r
r
r
r rB � s rB c @ s e Zd Zdd� Zdd� ZdS )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�namerL )r ra rL r r
r
r r' 7 s zWaiter.__init__c K s4 t | jj�}d}|�di �}|�d| jj�}|�d| jj�}d }d}x�| jf |�} |d7 }xZ|D ]}
|
�| �r`|
}|
j }P q`W t
| �r�t | j d| d �d d
�| d �d d
�f | d ��|d
kr�t
�d� d S |dkr�d|
j } t | j | | d ��||k�r"|d k�rd} n
d|
j } t | j | | d ��t�|� qFW d S )NZwaitingZ WaiterConfigZDelayZ MaxAttemptsr r zAn error occurred (%s): %sr r �Unknown�Message)ra �reasonZ
last_response�successz3Waiting complete, waiter matched the success state.Zfailurez/Waiter encountered a terminal failure state: %szMax attempts exceededz4Max attempts exceeded. Previously accepted state: %s)r4 rL rA �popr r> r@ r` rK rF r% r ra �logger�debugrR �time�sleep) r r rA Z
current_staterL Z sleep_amountr@ Zlast_matched_acceptorZ num_attemptsr# rD rd r
r
r r
L sV
z Waiter.waitN)r* r+ r, r' r
r
r
r
r r 6 s r )�loggingri r[ Zbotocore.docs.docstringr Zbotocore.utilsr r= r �
exceptionsr r r � getLoggerr* rg r r% r r- r; rB r r
r
r
r �<module>
s
5 -