File: //proc/722141/root/lib/python3.6/site-packages/botocore/__pycache__/waiter.cpython-36.pyc
3
�T_�0 � @ s� d dl Z d dlZd dlZd dlmZ d dlmZ ddlmZm Z m
Z
ddl m Z ej
e�Zdd� ZG d d
� d
e�ZG d d � d e�ZG d
d� de�ZG dd� de�ZG dd� de�ZdS )� N)�get_service_module_name)�WaiterDocstring� )� WaiterError� ClientError�WaiterConfigError)�
xform_namec C s| |j | �}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
� /usr/lib/python3.6/waiter.pyr
4 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 �metaZeventsr �__doc__�strr �typer ) r Z waiter_modelZclient�single_waiter_configZoperation_name�operation_methodr
Zwaiter_class_nameZdocumented_waiter_clsr
r
r �create_waiter_with_client 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__O s z"NormalizedOperationMethod.__init__c K s4 y | j f |�S tk
r. } z|jS d }~X nX d S )N)r r �response)r r �er
r
r �__call__R s z"NormalizedOperationMethod.__call__N)�__name__�
__module__� __qualname__r r r
r
r
r r N s r c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) � WaiterModel� c C s@ |d | _ |jdd�}| j|� || _tt|d j� ��| _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_config�get�_verify_supported_versionr' �list�sorted�keysZ waiter_names)r Z
waiter_configr' r
r
r r \ 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 r' r
r
r r+ t s
z%WaiterModel._verify_supported_versionc C s8 y| j | }W n tk
r. td| ��Y nX t|�S )NzWaiter does not exist: %s)r) �KeyError�
ValueError�SingleWaiterConfig)r r r r
r
r r | s
zWaiterModel.get_waiterN)r! r" r# r0 r r+ r r
r
r
r r$ Y s r$ c @ s$ e Zd ZdZdd� Zedd� �ZdS )r3 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 || _ |jdd�| _|d | _|d | _|d | _d S )N� description� r �delayZ maxAttempts)�_configr* r4 r r6 � max_attempts)r r r
r
r r � s
zSingleWaiterConfig.__init__c C s. g }x$| j d D ]}t|�}|j|� qW |S )N� acceptors)r7 �AcceptorConfig�append)r r9 Zacceptor_config�acceptorr
r
r r9 � s
z SingleWaiterConfig.acceptorsN)r! r" r# r r �propertyr9 r
r
r
r r3 � s
r3 c @ sD e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
d� Z dS )r: c C s8 |d | _ |d | _|d | _|jd�| _| j� | _d S )N�state�matcher�expected�argument)r> r? r@ r* rA �_create_matcher_func� matcher_func)r �configr
r
r r � s
zAcceptorConfig.__init__c C sn | j dkr| j� S | j dkr$| j� S | j dkr6| j� S | j dkrH| j� S | j dkrZ| j� S td| j d��d S )N�pathZpathAllZpathAnyZstatus�errorzUnknown acceptor: %s)r/ )r? �_create_path_matcher�_create_path_all_matcher�_create_path_any_matcher�_create_status_matcher�_create_error_matcherr )r r
r
r rB � s
z#AcceptorConfig._create_matcher_funcc s$ t j| j��| j� � �fdd�}|S )Nc s d| kr d S �j | �� kS )N�Error)�search)r )r@ �
expressionr
r �acceptor_matches� s z=AcceptorConfig._create_path_matcher.<locals>.acceptor_matches)�jmespath�compilerA r@ )r rO r
)r@ rN r rG � s z#AcceptorConfig._create_path_matcherc s$ t j| j��| j� � �fdd�}|S )Nc sJ d| kr d S �j | �}t|t� s(| r,dS x|D ]}|� kr2dS q2W dS )NrL FT)rM �
isinstancer, )r �result�element)r@ rN r
r rO � s
zAAcceptorConfig._create_path_all_matcher.<locals>.acceptor_matches)rP rQ rA r@ )r rO r
)r@ rN r rH � s z'AcceptorConfig._create_path_all_matcherc s$ t j| j��| j� � �fdd�}|S )Nc sJ d| kr d S �j | �}t|t� s(| r,dS x|D ]}|� kr2dS q2W dS )NrL FT)rM rR r, )r rS rT )r@ rN r
r rO � s
zAAcceptorConfig._create_path_any_matcher.<locals>.acceptor_matches)rP rQ rA r@ )r rO r
)r@ rN r rI � s z'AcceptorConfig._create_path_any_matcherc s | j � � fdd�}|S )Nc s | j di �j d�}|� kS )NZResponseMetadataZHTTPStatusCode)r* )r Z status_code)r@ r
r rO � s z?AcceptorConfig._create_status_matcher.<locals>.acceptor_matches)r@ )r rO r
)r@ r rJ � s z%AcceptorConfig._create_status_matcherc s | j � � fdd�}|S )Nc s | j di �j dd�� kS )NrL ZCoder5 )r* )r )r@ r
r rO � s z>AcceptorConfig._create_error_matcher.<locals>.acceptor_matches)r@ )r rO r
)r@ r rK � s z$AcceptorConfig._create_error_matcherN)
r! r" r# r rB rG rH rI rJ rK r
r
r
r r: � s
r: 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�namerD )r rV rD r r
r
r r
s zWaiter.__init__c
K s� t | jj�}d}|jdi �}|jd| jj�}|jd| jj�}d}x�| jf |�}|d7 }xB|D ]} | j|�r\| j }P q\W d|kr�t
| j |d jdd �|d
��|d kr�t j
d � d S |d
kr�t
| j d|d
��||kr�t
| j d|d
��tj|� qBW d S )NZwaitingZ WaiterConfigZDelayZ MaxAttemptsr r rL ZMessageZUnknown)rV �reasonZ
last_response�successz3Waiting complete, waiter matched the success state.Zfailurez+Waiter encountered a terminal failure statezMax attempts exceeded)r, rD r9 �popr* r6 r8 rU rC r> r rV �logger�debug�timeZsleep)
r r r9 Z
current_staterD Z sleep_amountr8 Z num_attemptsr r< r
r
r r
s@
z Waiter.waitN)r! r" r# r r
r
r
r
r r s r )rP Zloggingr\ Zbotocore.utilsr Zbotocore.docs.docstringr �
exceptionsr r r r5 r Z getLoggerr! rZ r �objectr r$ r3 r: r r
r
r
r �<module>
s
4 +k