File: //lib/python3/dist-packages/awscli/customizations/__pycache__/waiters.cpython-38.pyc
U
<�^ & � @ 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 | � dt� d S )Nzbuilding-command-table)�register� add_waiters)Zcli� r
�?/usr/lib/python3/dist-packages/awscli/customizations/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 s0 z| � |j|j�}W n tk
r* Y 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| ��|� 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�|� | �|� |S r )r r �_build_subcommand_tabler �build_all_waiter_state_cmdsZ _add_lineage)r! �subcommand_tabler" 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 r )r+ r r )r! r r r
r
r
r r W s z"WaiterStateCommandBuilder.__init__c C s. | j j}|D ] }t|d�}| �|�||< q 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 �|�}t|d�}|j}| j�|�}t|dt| j|�| j|d�}t |�}|�
� }||_ |S )Nr4 r )�name� parent_nameZoperation_callerr �operation_model) r �
get_waiterr � operationr r: �WaiterStateCommand� WaiterCallerr+ �WaiterStateDocBuilder� build_waiter_state_descriptionr2 ) r! r6 �
waiter_configr7 �operation_namer: Zwaiter_state_commandZwaiter_state_doc_builder� descriptionr
r
r r5 h s
� z1WaiterStateCommandBuilder._build_waiter_state_cmdN)r. r/ r0 r r( r5 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 r )�_waiter_config)r! rA r
r
r r � s z WaiterStateDocBuilder.__init__c C sh | j j}|sLd}| j jD ] }|jdkr|| �|�7 } q:q|| �| j j�7 }|| �| j j| j j �7 }|S )Nz Wait until Zsuccess)
rH rC Z acceptors�state�_build_success_description� _build_operation_descriptionr< �_build_polling_description�delay� max_attempts)r! rC �acceptorr
r
r r@ � s
� �z4WaiterStateDocBuilder.build_waiter_state_descriptionc C s< |j }| j| }d }|dkr.d|j }|| }||j }|S )N)rE rG rF zJMESPath query %s returns )�matcher�SUCCESS_DESCRIPTIONSZargumentZexpected)r! rO rP Zsuccess_descriptionZresource_descriptionZfull_success_descriptionr
r
r rJ � s
�
z0WaiterStateDocBuilder._build_success_descriptionc C s t |��dd�}d| S )N�_r4 zwhen polling with ``%s``.)r �replace)r! r< rB r
r
r rK � 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! rM rN rC r
r
r rL � s
��z0WaiterStateDocBuilder._build_polling_descriptionN) r. r/ r0 rQ r r@ rJ rK rL r
r
r
r r? � s �r? c @ s e Zd Zdd� Zdd� ZdS )r> c C s || _ || _d S r )r+ � _waiter_name)r! r r6 r
r
r r � s zWaiterCaller.__init__c C s: | j j||j|j|jd�}|�t| j��}|jf |� dS )N)Z region_name� endpoint_urlZverifyr ) r+ Z
create_clientZregionrU Z
verify_sslr; r rT r )r! r rB Z
parametersr% ZclientZwaiterr
r
r �invoke� s � zWaiterCaller.invokeN)r. r/ r0 r rV r
r
r
r r> � s r> c s e Zd ZdZ� fdd�Z� ZS )r= � c s$ t t| ��� }| j| j_d | j_|S r )r r= r- r2 Z_operation_modelZ
documentationZ output_shape)r! � help_commandr" r
r r- � s
z&WaiterStateCommand.create_help_command)r. r/ r0 r2 r- r3 r
r
r" r r= � s r= c @ s4 e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd S ) r, c K s d S r r
�r! rX r r
r
r �doc_synopsis_start� s z*WaiterCommandDocHandler.doc_synopsis_startc K s d S r r
�r! Zarg_namerX r r
r
r �doc_synopsis_option� s z+WaiterCommandDocHandler.doc_synopsis_optionc K s d S r r
rY r
r
r �doc_synopsis_end� s z(WaiterCommandDocHandler.doc_synopsis_endc K s d S r r
rY r
r
r �doc_options_start� s z)WaiterCommandDocHandler.doc_options_startc K s d S r r
r[ r
r
r �
doc_option� s z"WaiterCommandDocHandler.doc_optionN)r. r/ r0 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>