⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.144
Server IP:
157.245.143.252
Server:
Linux www 6.11.0-9-generic #9-Ubuntu SMP PREEMPT_DYNAMIC Mon Oct 14 13:19:59 UTC 2024 x86_64
Server Software:
nginx/1.26.0
PHP Version:
8.3.11
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
lib
/
python3
/
dist-packages
/
botocore
/
__pycache__
/
View File Name :
waiter.cpython-312.pyc
Pe7 d dl Z d dlZd dlZd dlmZ d dlmZ ddlmZ ddl m Z m Z m Z e j e Zd Zd Z G d d Z G d d Z G d d Z G d d Z G d d Zy) N)WaiterDocstring)get_service_module_name ) xform_name) ClientErrorWaiterConfigError WaiterErrorc |j | }t |j }t t || }d }t | |j j |j j |d |_ t t |j j d| }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 0 t j | fi | y N)Waiterwait)selfkwargss 1/usr/lib/python3/dist-packages/botocore/waiter.pyr z'create_waiter_with_client.<locals>.wait6 s D#F# F) waiter_name event_emitter service_modelservice_waiter_modelinclude_signaturez.Waiter.r ) get_waiterr operationNormalizedOperationMethodgetattrr metaeventsr __doc__strr typer ) r waiter_modelclientsingle_waiter_configoperation_nameoperation_methodr waiter_class_namedocumented_waiter_clss r create_waiter_with_clientr( s $ (22;? 4 > >?N0'$ # kk(( kk// ) DL "6;;#<#< ={ L !!2VI~ N !)+; r c P | j d }t |t rd|v ryy)NErrorCodeTF)get isinstancedict)responseerrors r is_valid_waiter_errorr1 P s& LL !E% 6U? r c e Zd Zd Zd Zy)r c || _ y r )_client_method)r client_methods r __init__z"NormalizedOperationMethod.__init__X s +r c l | j di |S # t $ r}|j cY d }~S d }~ww xY w)N )r4 r r/ )r r es r __call__z"NormalizedOperationMethod.__call__[ s7 &4&&00 0 :: s 3 .33N)__name__ __module__ __qualname__r6 r: r8 r r r r W s , r r c " e Zd ZdZd Zd Zd Zy) WaiterModel c |d | _ |j dd }| j | || _ t t |d j | _ y)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. waitersversionunknownN)_waiter_configr, _verify_supported_versionrC listsortedkeys waiter_names)r waiter_configrC s r r6 zWaiterModel.__init__e sZ ,I 6 ##Iy9 &&w/ i(@(E(E(G!H Ir c Z || j k7 r t d| j d| y )Nz7Unsupported waiter version, supported version must be: z#, but version of waiter config is: error_msg)SUPPORTED_VERSIONr )r rC s r rF z%WaiterModel._verify_supported_version} s5 d,, ,# !% 6 6A -r c n | j | }t | S # t $ r t d|z w xY w)NzWaiter does not exist: %s)rE KeyError ValueErrorSingleWaiterConfig)r r r# s r r zWaiterModel.get_waiter sK H#'#6#6{#C ""677 H 8; FG G Hs 4N)r; r< r= rO r6 rF r r8 r r r? r? b s J08r r? c & e Zd ZdZd Zed Zy)rS zRepresents 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 | || _ |j dd | _ |d | _ |d | _ |d | _ y )N description r delay maxAttempts)_configr, rV r rX max_attempts)r r# s r r6 zSingleWaiterConfig.__init__ sE + 033M2F-k:)'2 0 ?r c j g }| j d D ] }t | }|j | |S )N acceptors)rZ AcceptorConfigappend)r r] acceptor_configacceptors r r] z SingleWaiterConfig.acceptors s: #||K 8O%o6H X & 9 r N)r; r< r= r r6 propertyr] r8 r r rS rS s! @ r rS c F e Zd Zd Zed Zd Zd Zd Zd Z d Z d Z y ) r^ c |d | _ |d | _ |d | _ |j d | _ | j | _ y )Nstatematcherexpectedargument)re rf rg r, rh _create_matcher_func matcher_func)r configs r r6 zAcceptorConfig.__init__ sF G_ i( z* :. 5 5 7r c | j dk( r&dj | j | j S | j dk( r d| j d| j dS | j dk( r d| j d| j d S | j d k( rd | j z S | j d k( rd | j z S d| j z S )Npathz2For expression "{}" we matched expected path: "{}"pathAllzFor expression "z&" all members matched excepted path: ""pathAnyz " we matched expected path: "z" at least oncestatusz%Matched expected HTTP status code: %sr0 z'Matched expected service error code: %sz,No explanation for unknown waiter type: "%s")rf formatrh rg r s r explanationzAcceptorConfig.explanation s <<6 !GNN \\Y & ==$--1 \\Y & ==$--1 \\X %:T]]J J \\W $<t}}L L ? M r c j | j dk( r| j S | j dk( r| j S | j dk( r| j S | j dk( r| j S | j dk( r| j S t d| j z )Nrm rn rp rq r0 zUnknown acceptor: %srM )rf _create_path_matcher_create_path_all_matcher_create_path_any_matcher_create_status_matcher_create_error_matcherr rs s r ri z#AcceptorConfig._create_matcher_func s <<6 !,,. . \\Y &002 2 \\Y &002 2 \\X %..0 0 \\W $--/ /#04<<? r c l t j | j | j fd}|S )Nc D t | ry j | k( S r )r1 search)r/ rg expressions r acceptor_matchesz=AcceptorConfig._create_path_matcher.<locals>.acceptor_matches s$ $X. $$X.(: :r jmespathcompilerh rg r r rg r~ s @@r rv z#AcceptorConfig._create_path_matcher s- %%dmm4 == ; r c l t j | j | j fd}|S )Nc t | ry j | }t |t r|sy|D ] }|k7 s y yNFTr1 r} r- rG r/ resultelementrg r~ s r r zAAcceptorConfig._create_path_all_matcher.<locals>.acceptor_matches sI $X. &&x0F fd+6 !h& " r r r s @@r rw z'AcceptorConfig._create_path_all_matcher s- %%dmm4 == r c l t j | j | j fd}|S )Nc t | ry j | }t |t r|sy|D ] }|k( s y yr r r s r r zAAcceptorConfig._create_path_any_matcher.<locals>.acceptor_matches sI $X. &&x0F fd+6 !h& " r r r s @@r rx z'AcceptorConfig._create_path_any_matcher s- %%dmm4 == r c * | j fd}|S )Nc P | j di j d }|k( S )NResponseMetadataHTTPStatusCoder, )r/ status_coderg s r r z?AcceptorConfig._create_status_matcher.<locals>.acceptor_matches s1 #,,'92>BB K (* *r rg r r rg s @r ry z%AcceptorConfig._create_status_matcher s == + r c * | j fd}|S )Nc N | j di j dd k( S )Nr* r+ rW r )r/ rg s r r z>AcceptorConfig._create_error_matcher.<locals>.acceptor_matches* s( <<,00<H Hr r r s @r rz z$AcceptorConfig._create_error_matcher' s == I r N) r; r< r= r6 rb rt ri rv rw rx ry rz r8 r r r^ r^ s9 8 20 * * r r^ c e Zd Zd Zd Zy)r c . || _ || _ || _ y)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_methodnamerk )r r rk r% s r r6 zWaiter.__init__7 s "2 r c D t | j j }d}|j di }|j d| j j }|j d| j j }d }d} | j di |} |dz }|D ]# } | j | s| }| j } nP t | rDt | j d| d j d d d | d j d d | |dk( rt j d y |dk( r'd j z } t | j | | ||k\ r,|d} nd j z } t | j | | t! j" | )Nwaiting WaiterConfigDelay MaxAttemptsr r zAn error occurred (r* r+ Unknownz): Message)r reason last_responsesuccessz3Waiting complete, waiter matched the success state.failurez/Waiter encountered a terminal failure state: %szMax attempts exceededz4Max attempts exceeded. Previously accepted state: %sr8 )rG rk r] popr, rX r[ r rj re r1 r r loggerdebugrt timesleep) r r r] current_staterk sleep_amountr[ last_matched_acceptor num_attemptsr/ ra r s r r z Waiter.waitL s ../ ! NB/ zz'4;;+<+<= zz-1I1IJ $ -t--77H A L %((2,4)$,NNM & )2 & !YY %W - 1 1&) D $W - 1 1)Y G '/ ) L )J (( " !"* |+(0 4F O#//1 " !"* JJ| $g r N)r; r< r= r6 r r8 r r r r 6 s *=%r r )loggingr r botocore.docs.docstringr botocore.utilsr rW r exceptionsr r r getLoggerr; r r( r1 r r? rS r^ r r8 r r <module>r st 3 2 C C 8 $2j *8 *8Z 6I I XS% S%r