Website : rimsha.abasa.com
backdoor
Home
Console
Upload
information
Create File
Create Folder
About
Tools
:
/
lib
/
python3
/
dist-packages
/
botocore
/
__pycache__
/
Filename :
waiter.cpython-310.pyc
back
Copy
o .&�a�6 � @ s� d dl Z d dlZd dlZd dlmZ d dlmZ ddlmZm Z m Z ddl m Z e� e�Zdd� Zd d � ZG d d � d e�ZG d d� de�ZG dd� de�ZG dd� de�ZG dd� de�ZdS )� N)�get_service_module_name)�WaiterDocstring� )� WaiterError� ClientError�WaiterConfigError)� xform_namec 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| fi |�� d S �N)�Waiter�wait)�self�kwargs� r �1/usr/lib/python3/dist-packages/botocore/waiter.pyr 4 s z'create_waiter_with_client.<locals>.waitF)� waiter_name� event_emitter� service_model�service_waiter_model�include_signaturez %s.Waiter.%sr )� get_waiterr � operation�NormalizedOperationMethod�getattrr �meta�eventsr �__doc__�strr �typer ) r � waiter_model�client�single_waiter_config�operation_name�operation_methodr �waiter_class_name�documented_waiter_clsr r r �create_waiter_with_client s. �� � ��r% c C s$ | � d�}t|t�rd|v rdS dS )N�Error�CodeTF)�get� isinstance�dict)�response�errorr r r �is_valid_waiter_errorN s r- c @ � e Zd Zdd� Zdd� ZdS )r c C s || _ d S r )�_client_method)r � client_methodr r r �__init__V s z"NormalizedOperationMethod.__init__c K s> z | j di |��W S ty } z |jW Y d }~S d }~ww )Nr )r/ r r+ )r r �er r r �__call__Y s ��z"NormalizedOperationMethod.__call__N)�__name__� __module__� __qualname__r1 r3 r r r r r U 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_versionr: �list�sorted�keys� waiter_names)r � waiter_configr: r r r r1 c s zWaiterModel.__init__c C s" || j krtd| 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= { s ����z%WaiterModel._verify_supported_versionc C s0 z | j | }W t|�S ty td| ��w )NzWaiter does not exist: %s)r< �KeyError� ValueError�SingleWaiterConfig)r r r r r r r � s � �zWaiterModel.get_waiterN)r4 r5 r6 rE r1 r= r r r r r r7 ` s r7 c @ s$ e Zd ZdZdd� Zedd� �ZdS )rH 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 �delay� maxAttempts)�_configr( rI r rK � max_attempts)r r r r r r1 � s zSingleWaiterConfig.__init__c C s* g }| j d D ] }t|�}|�|� q|S )N� acceptors)rM �AcceptorConfig�append)r rO �acceptor_config�acceptorr r r rO � s z SingleWaiterConfig.acceptorsN)r4 r5 r6 r r1 �propertyrO r r r r rH � s rH c @ sP e Zd Zdd� Zedd� �Zdd� Zdd� Zd d � Zd d � Z d d� Z dd� Z dS )rP c C s8 |d | _ |d | _|d | _|�d�| _| �� | _d S )N�state�matcher�expected�argument)rU rV rW r( rX �_create_matcher_func� matcher_func)r �configr r r r1 � s zAcceptorConfig.__init__c C s� | j dkr d| j| jf S | j dkrd| j| jf S | j dkr'd| j| jf S | j dkr1d| j S | j d kr;d | j S d | j S ) N�pathz2For expression "%s" we matched expected path: "%s"�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")rV rX rW �r r r r � explanation� s zAcceptorConfig.explanationc C sj | j dkr | �� S | j dkr| �� S | j dkr| �� S | j dkr$| �� S | j dkr-| �� S td| j d��)Nr\ r] r^ r_ r, zUnknown acceptor: %srC )rV �_create_path_matcher�_create_path_all_matcher�_create_path_any_matcher�_create_status_matcher�_create_error_matcherr r` r r r rY � s �z#AcceptorConfig._create_matcher_funcc �$ t �| j��| j� � �fdd�}|S )Nc s t | �rd S ��| �� kS r )r- �search�r+ �rW � expressionr r �acceptor_matches� s z=AcceptorConfig._create_path_matcher.<locals>.acceptor_matches��jmespath�compilerX rW �r rl r rj r rb � s z#AcceptorConfig._create_path_matcherc rg )Nc sD t | �rd S ��| �}t|t�r|sdS |D ] }|� kr dS qdS �NFT�r- rh r) r> �r+ �result�elementrj r r rl � � �zAAcceptorConfig._create_path_all_matcher.<locals>.acceptor_matchesrm rp r rj r rc � � z'AcceptorConfig._create_path_all_matcherc rg )Nc sD t | �rd S ��| �}t|t�r|sdS |D ] }|� kr dS qdS rq rr rs rj r r rl � rv zAAcceptorConfig._create_path_any_matcher.<locals>.acceptor_matchesrm rp r rj r rd � rw z'AcceptorConfig._create_path_any_matcherc � | j � � fdd�}|S )Nc s | � di �� d�}|� kS )N�ResponseMetadata�HTTPStatusCode�r( )r+ � status_code�rW r r rl s �z?AcceptorConfig._create_status_matcher.<locals>.acceptor_matchesr} rp r r} r re s z%AcceptorConfig._create_status_matcherc rx )Nc s | � di �� dd�� kS )Nr& r' rJ r{ ri r} r r rl s z>AcceptorConfig._create_error_matcher.<locals>.acceptor_matchesr} rp r r} r rf s z$AcceptorConfig._create_error_matcherN) r4 r5 r6 r1 rT ra rY rb rc rd re rf r r r r rP � s rP c @ r. )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�namer[ )r r r[ r" r r r r1 s zWaiter.__init__c K s, t | jj�}d}|�di �}|�d| jj�}|�d| jj�}d }d} | jdi |��} |d7 }|D ]} | �| �r?| }| j } n q1t | �r\t | j d| d �d d �| d �d d �f | d ��|dkrgt �d� d S |dkrxd| j } t | j | | d ��||kr�|d u r�d} nd| j } t | j | | d ��t�|� q#)N�waiting� WaiterConfig�Delay� MaxAttemptsr Tr zAn error occurred (%s): %sr& r' �Unknown�Message)r �reason� last_response�successz3Waiting complete, waiter matched the success state.�failurez/Waiter encountered a terminal failure state: %szMax attempts exceededz4Max attempts exceeded. Previously accepted state: %sr )r> r[ rO �popr( rK rN r~ rZ rU r- r r �logger�debugra �time�sleep) r r rO � current_stater[ � sleep_amountrN �last_matched_acceptor� num_attemptsr+ rS r� r r r r 5 sd ��� ���� �z Waiter.waitN)r4 r5 r6 r1 r r r r r r s r )rn �loggingr� �botocore.utilsr �botocore.docs.docstringr � exceptionsr r r rJ r � getLoggerr4 r� r% r- �objectr r7 rH rP r r r r r �<module> s 4 +z