File: //lib/python3.6/site-packages/awscli/customizations/__pycache__/waiters.cpython-36.opt-1.pyc
3
�T_N& � @ s� d dl mZ d dlmZ d dlmZ d dlmZmZm Z dd� Z
dd� Z d d
� Z G d d � d e�Z
G d
d� de�ZG dd� de�ZG dd� de�ZG dd� de�ZG dd� de �ZdS )� )�
xform_name)�DataNotFoundError)�ServiceOperation)� BasicCommand� BasicHelp�BasicDocHandlerc C s | j dt� d S )Nzbuilding-command-table)�register� add_waiters)Zcli� r
� /usr/lib/python3.6/waiters.py�register_add_waiters s r c K sH t |dd �}|d k rDt||�}|d kr*d S |j}|rDt|||�| d< d S )N�
service_model�wait)�getattr�#get_waiter_model_from_service_model� waiter_names� WaitCommand)�
command_table�sessionZcommand_object�kwargsr
� waiter_modelr r
r
r r s r c C s. y| j |j|j�}W n tk
r( d S X |S )N)Zget_waiter_model� service_name� api_versionr )r r
�modelr
r
r r + s r c s@ e Zd ZdZdZ� fdd�Zdd� Z� fdd�Zd d
� Z� Z S ) r r zqWait until a particular condition is satisfied. Each subcommand polls an API until the listed requirement is met.c s4 || _ || _t|| j | jd�| _tt| �j|� d S )N)r r r
)�_model�_service_model�WaiterStateCommandBuilder�waiter_cmd_builder�superr �__init__)�selfr r r
)� __class__r
r r : s zWaitCommand.__init__c C s |j d krtd��d S )NzVusage: aws [options] <command> <subcommand> [parameters]
aws: error: too few arguments)Z
subcommand�
ValueError)r Z parsed_args�parsed_globalsr
r
r � _run_mainD s
zWaitCommand._run_mainc s( t t| �j� }| jj|� | j|� |S )N)r r �_build_subcommand_tabler �build_all_waiter_state_cmdsZ _add_lineage)r �subcommand_table)r! r
r r% I s
z#WaitCommand._build_subcommand_tablec C s t | j| | j| jtd�S )N)r � arg_tableZevent_handler_class)r �_sessionr' r( �WaiterCommandDocHandler)r r
r
r �create_help_commandO s z WaitCommand.create_help_command)
�__name__�
__module__� __qualname__�NAME� DESCRIPTIONr r$ r% r+ �
__classcell__r
r
)r! r r 4 s
r c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )r c C s || _ || _|| _d S )N)r) r r )r r r r
r
r
r r W s z"WaiterStateCommandBuilder.__init__c C s2 | j j}x$|D ] }t|d�}| j|�||< qW dS )z�This adds waiter state commands to the subcommand table passed in.
This is the method that adds waiter state commands like
``instance-running`` to ``ec2 wait``.
�-N)r r r �_build_waiter_state_cmd)r r' r � waiter_name�waiter_cli_namer
r
r r& \ s
z5WaiterStateCommandBuilder.build_all_waiter_state_cmdsc C s^ | j j|�}t|d�}|j}| jj|�}t|dt| j|�| j|d�}t |�}|j
� }||_ |S )Nr2 r )�name� parent_nameZoperation_callerr �operation_model) r �
get_waiterr � operationr r8 �WaiterStateCommand� WaiterCallerr) �WaiterStateDocBuilder� build_waiter_state_descriptionr0 ) r r4 �
waiter_configr5 �operation_namer8 Zwaiter_state_commandZwaiter_state_doc_builder� descriptionr
r
r r3 h s
z1WaiterStateCommandBuilder._build_waiter_state_cmdN)r, r- r. r r& r3 r
r
r
r r V s r c @ sD e Zd Zdddddd�Zdd� Zd d
� Zd d � Zd
d� Zdd� ZdS )r= z
%s is thrown z%s z%s for all elements z%s for any element z%s response is received )�error�path�pathAll�pathAnyZstatusc C s
|| _ d S )N)�_waiter_config)r r? r
r
r r � s z WaiterStateDocBuilder.__init__c C sj | j j}|sNd}x*| j jD ] }|jdkr|| j|�7 }P qW || j| j j�7 }|| j| j j| j j �7 }|S )Nz Wait until �success)
rF rA Z acceptors�state�_build_success_description� _build_operation_descriptionr: �_build_polling_description�delay� max_attempts)r rA �acceptorr
r
r r> � s
z4WaiterStateDocBuilder.build_waiter_state_descriptionc C s< |j }| j| }d }|dkr.d|j }|| }||j }|S )NrC rE rD zJMESPath query %s returns )rC rE rD )�matcher�SUCCESS_DESCRIPTIONSZargumentZexpected)r rN rO Zsuccess_descriptionZresource_descriptionZfull_success_descriptionr
r
r rI � s
z0WaiterStateDocBuilder._build_success_descriptionc C s t |�jdd�}d| S )N�_r2 zwhen polling with ``%s``.)r �replace)r r: r@ r
r
r rJ � s z2WaiterStateDocBuilder._build_operation_descriptionc C s d||f }|S )Nz� It will poll every %s seconds until a successful state has been reached. This will exit with a return code of 255 after %s failed checks.r
)r rL rM rA r
r
r rK � s
z0WaiterStateDocBuilder._build_polling_descriptionN) r, r- r. rP r r> rI rJ rK r
r
r
r r= � s r= c @ s e Zd Zdd� Zdd� ZdS )r< c C s || _ || _d S )N)r) � _waiter_name)r r r4 r
r
r r � s zWaiterCaller.__init__c C s: | j j||j|j|jd�}|jt| j��}|jf |� dS )N)Z region_name� endpoint_urlZverifyr ) r) Z
create_clientZregionrT Z
verify_sslr9 r rS r )r r r@ Z
parametersr# ZclientZwaiterr
r
r �invoke� s
zWaiterCaller.invokeN)r, r- r. r rU r
r
r
r r< � s r< c s e Zd ZdZ� fdd�Z� ZS )r; � c s$ t t| �j� }| j| j_d | j_|S )N)r r; r+ r0 Z_operation_modelZ
documentationZ output_shape)r � help_command)r! r
r r+ � s
z&WaiterStateCommand.create_help_command)r, r- r. r0 r+ r1 r
r
)r! r r; � s r; c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
S )r* c K s d S )Nr
)r rW r r
r
r �doc_synopsis_start� s z*WaiterCommandDocHandler.doc_synopsis_startc K s d S )Nr
)r �arg_namerW r r
r
r �doc_synopsis_option� s z+WaiterCommandDocHandler.doc_synopsis_optionc K s d S )Nr
)r rW r r
r
r �doc_synopsis_end� s z(WaiterCommandDocHandler.doc_synopsis_endc K s d S )Nr
)r rW r r
r
r �doc_options_start� s z)WaiterCommandDocHandler.doc_options_startc K s d S )Nr
)r rW r r
r
r �doc_options_end� s z'WaiterCommandDocHandler.doc_options_endc K s d S )Nr
)r rY rW r r
r
r �
doc_option� s z"WaiterCommandDocHandler.doc_optionN) r, r- r. rX rZ r[ r\ r] r^ r
r
r
r r* � s r* N)Zbotocorer Zbotocore.exceptionsr Zawscli.clidriverr Z awscli.customizations.commandsr r r r r r r �objectr r= r< r; r* r
r
r
r �<module>
s "1>