U n/e1@sddlZddlmZddlmZddlmZddlmZ ddlm Z ddlm Z m Z m Z mZmZdd ZGd d d e ZGd d d e ZdS)N)WaiterDocstring) ClientError)get_service_module_name)NormalizedOperationMethod) WaiterModel)Waiter WaiterErroris_valid_waiter_errorlogger xform_namec Cs|||}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. cstj|f|IdHSN) AIOWaiterwait)selfkwargsr6/tmp/pip-unpacked-wheel-8mnez3y6/aiobotocore/waiter.pyr0sz'create_waiter_with_client..waitF) waiter_nameZ event_emitter service_modelZservice_waiter_modelZinclude_signaturez %s.Waiter.%sr)Z get_waiterr Z operationrgetattrrmetaeventsr__doc__strrtyper) rZ waiter_modelclientZsingle_waiter_configZoperation_nameZoperation_methodrZwaiter_class_nameZdocumented_waiter_clsrrrcreate_waiter_with_clients0   rc@seZdZddZdS)rc sFz|jf|IdHWStk r@}z|jWYSd}~XYnXdSr )Z_client_methodrresponse)rrerrr__call__Ksz"NormalizedOperationMethod.__call__N)__name__ __module__ __qualname__rrrrrrJsrc@seZdZddZdS)r c s:t|jj}d}|di}|d|jj}|d|jj}d}d}|jf|IdH} |d7}|D]} | | rb| }| j }qqbt | rt |j d| dd d | dd d f| d |d krt d| S|dkrd| j} t |j | | d ||kr$|dkr d} n d| j} t |j | | d t|IdHqDdS)NZwaitingZ WaiterConfigZDelayZ MaxAttemptsrzAn error occurred (%s): %sErrorZCodeUnknownMessage)namereasonZ last_responsesuccessz3Waiting complete, waiter matched the success state.Zfailurez/Waiter encountered a terminal failure state: %szMax attempts exceededz4Max attempts exceeded. Previously accepted state: %s)listconfig acceptorspopgetdelay max_attemptsZ_operation_methodZ matcher_funcstater rr'r debugZ explanationasynciosleep) rrr,Z current_stater+Z sleep_amountr0Zlast_matched_acceptorZ num_attemptsrZacceptorr(rrrrSsf      zAIOWaiter.waitN)r r!r"rrrrrr Rsr )r3Zbotocore.docs.docstringrZbotocore.exceptionsrZbotocore.utilsrZbotocore.waiterrZ_NormalizedOperationMethodrrrr r r rr rrrrs      5