File: //lib/python3/dist-packages/awscli/customizations/__pycache__/waiters.cpython-310.pyc
o
.&�aN& � @ 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)�cli� r �?/usr/lib/python3/dist-packages/awscli/customizations/waiters.py�register_add_waiters s r
c K sP t |dd �}|d ur$t||�}|d u rd S |j}|r&t|||�| d< d S d S d S )N�
service_model�wait)�getattr�#get_waiter_model_from_service_model� waiter_names� WaitCommand)�
command_table�session�command_object�kwargsr � waiter_modelr r r r r s � ��r c C s, z | � |j|j�}W |S ty Y d S w �N)�get_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 u r td��d S )NzVusage: aws [options] <command> <subcommand> [parameters]
aws: error: too few arguments)�
subcommand�
ValueError)r$ � 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_cmds� _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_table�event_handler_class)r �_sessionr/ r0 �WaiterCommandDocHandler)r$ r r r �create_help_commandO s
�z WaitCommand.create_help_command)
�__name__�
__module__� __qualname__�NAME� DESCRIPTIONr# r+ r, r4 �
__classcell__r r r% r r 4 s
r c @ s$ e Zd Zdd� Zdd� Zdd� ZdS )r c C s || _ || _|| _d S r )r2 r r )r$ r r r r r r r# W s
z"WaiterStateCommandBuilder.__init__c C s. | j j}|D ]}t|d�}| �|�||< qdS )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 )Nr; r )�name� parent_name�operation_callerr �operation_model) r �
get_waiterr � operationr rB �WaiterStateCommand� WaiterCallerr2 �WaiterStateDocBuilder� build_waiter_state_descriptionr9 ) r$ r= �
waiter_configr> �operation_namerB �waiter_state_command�waiter_state_doc_builder� descriptionr r r r< h s
� z1WaiterStateCommandBuilder._build_waiter_state_cmdN)r5 r6 r7 r# r- r< r r r r r V s r c @ sD e Zd Zdddddd�Zdd� Zd d
� Zd d � Zd
d� Zdd� ZdS )rG z
%s is thrown z%s z%s for all elements z%s for any element z%s response is received )�error�path�pathAll�pathAny�statusc C s
|| _ d S r )�_waiter_config)r$ rI r r r r# � s
z WaiterStateDocBuilder.__init__c C sh | j j}|s&d}| j jD ]}|jdkr || �|�7 } nq || �| j j�7 }|| �| j j| j j �7 }|S )Nz Wait until �success)
rS rM � acceptors�state�_build_success_description� _build_operation_descriptionrD �_build_polling_description�delay� max_attempts)r$ rM �acceptorr r r rH � s
�� �z4WaiterStateDocBuilder.build_waiter_state_descriptionc C s< |j }| j| }d }|dv rd|j }|| }||j }|S )N)rO rQ rP zJMESPath query %s returns )�matcher�SUCCESS_DESCRIPTIONS�argument�expected)r$ r\ r] �success_description�resource_description�full_success_descriptionr r r rW � s
�
z0WaiterStateDocBuilder._build_success_descriptionc C s t |��dd�}d| S )N�_r; zwhen polling with ``%s``.)r �replace)r$ rD rJ r r r rX � 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$ rZ r[ rM r r r rY � s
��z0WaiterStateDocBuilder._build_polling_descriptionN) r5 r6 r7 r^ r# rH rW rX rY r r r r rG � s � rG c @ s e Zd Zdd� Zdd� ZdS )rF c C s || _ || _d S r )r2 � _waiter_name)r$ r r= r r r r# � s
zWaiterCaller.__init__c C s> | j j||j|j|jd�}|�t| j��}|jdi |�� dS )N)� region_name� endpoint_url�verifyr r ) r2 �
create_client�regionrh �
verify_sslrC r rf r )r$ r rJ �
parametersr* �client�waiterr r r �invoke� s �zWaiterCaller.invokeN)r5 r6 r7 r# rp r r r r rF � s rF c s e Zd ZdZ� fdd�Z� ZS )rE � c s$ t t| ��� }| j| j_d | j_|S r )r" rE r4 r9 �_operation_model�
documentation� output_shape)r$ � help_commandr% r r r4 � s
z&WaiterStateCommand.create_help_command)r5 r6 r7 r9 r4 r: r r r% r rE � s rE c @ s< e Zd Zdd� Zdd� Zdd� Zdd� Zd d
� Zd d � Zd
S )r3 c K � d S r r �r$ ru r r r r �doc_synopsis_start� � z*WaiterCommandDocHandler.doc_synopsis_startc K rv r r �r$ �arg_nameru r r r r �doc_synopsis_option� ry z+WaiterCommandDocHandler.doc_synopsis_optionc K rv r r rw r r r �doc_synopsis_end� ry z(WaiterCommandDocHandler.doc_synopsis_endc K rv r r rw r r r �doc_options_start� ry z)WaiterCommandDocHandler.doc_options_startc K rv r r rw r r r �doc_options_end� ry z'WaiterCommandDocHandler.doc_options_endc K rv r r rz r r r �
doc_option� ry z"WaiterCommandDocHandler.doc_optionN) r5 r6 r7 rx r| r} r~ r r� r r r r r3 � s r3 N)�botocorer �botocore.exceptionsr �awscli.clidriverr � awscli.customizations.commandsr r r r
r r r �objectr rG rF rE r3 r r r r �<module> s "1>