VhtddlmZ ddlmZdZGddZdde de fdZ y#e$rZdZeZYdZ["dZ[wwxYw) )deepcopyNc8eZdZdZdZedZdZdefdZ y)BaseWaiterFactorya  A helper class used for creating additional waiters. Unlike the waiters available directly from botocore these waiters will automatically retry on common (temporary) AWS failures. This class should be treated as an abstract class and subclassed before use. A subclass should: - override _BaseWaiterFactory._waiter_model_data to return the data defining the waiter Usage: waiter_factory = BaseWaiterFactory() waiter = waiter_factory.get_waiter(client, 'my_waiter_name') waiter.wait(**params) ctsy|j|j}tjt d||_y)N)versionwaiters) waiter_config)botocore_waiter_inject_ratelimit_retries_waiter_model_data WaiterModeldict_model)selfdatas j/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/amazon/aws/plugins/module_utils/waiter.py__init__zBaseWaiterFactory.__init__)s<  --d.E.EF%11q$7  ctS)at Subclasses should override this method to return a dictionary mapping waiter names to the waiter definition. This data is similar to the data found in botocore's waiters-2.json files (for example: botocore/botocore/data/ec2/2016-11-15/waiters-2.json) with two differences: 1) Waiter names do not have transformations applied during lookup 2) Only the 'waiters' data is required, the data is assumed to be version 2 for example: @property def _waiter_model_data(self): return dict( tgw_attachment_deleted=dict( operation='DescribeTransitGatewayAttachments', delay=5, maxAttempts=120, acceptors=[ dict(state='retry', matcher='pathAll', expected='deleting', argument='TransitGatewayAttachments[].State'), dict(state='success', matcher='pathAll', expected='deleted', argument='TransitGatewayAttachments[].State'), dict(state='success', matcher='path', expected=True, argument='length(TransitGatewayAttachments[]) == `0`'), dict(state='success', matcher='error', expected='InvalidRouteTableID.NotFound'), ] ), ) or @property def _waiter_model_data(self): return { "instance_exists": { "delay": 5, "maxAttempts": 40, "operation": "DescribeInstances", "acceptors": [ { "matcher": "path", "expected": true, "argument": "length(Reservations[]) > `0`", "state": "success" }, { "matcher": "error", "expected": "InvalidInstanceID.NotFound", "state": "retry" } ] }, } )r)rs rr z$BaseWaiterFactory._waiter_model_data5s pv rcgd}g}|D]}|jtdd|!t|}|D]}||dj||S)N)RequestLimitExceeded UnavailableServiceUnavailableInternalFailure InternalErrorTooManyRequestsException Throttlingretryerror)statematcherexpected acceptors)appendrrextend)r model_data extra_retriesr$r _model_data waiter_names rr z+BaseWaiterFactory._inject_ratelimit_retriesosu  " SE   T5Q R Sz* & DK  $[ 1 8 8 C Drr*ctrt|jj}||vrtd|d|t j ||j|S)NzUnable to find waiter z. Available_waiters: ) import_errorr waiter_namesNotImplementedErrorr create_waiter_with_client)rclientr*r s r get_waiterzBaseWaiterFactory.get_waiters`  ++** g %%(>{mKabiaj&kl l88  KK   rN) __name__ __module__ __qualname____doc__rpropertyr r strr1rrrrs2  77r*  c  rrtimeout default_pausec~|}||dzkrtd|dz}d||zz}|dz |z|kr|dz }t||S)a- Generates the waiter_config dict that allows configuring a custom wait_timeout Where the pause and the timeouts aren't perfectly divisible, this will default to waiting slightly longer than the configured timeout so that we give at least the timeout time for a change to happen. )Delay MaxAttempts)maxr)r9r:pauseattemptss rcustom_waiter_configrCs^ E-!#$Aw!|$Gu$%H1 'A  e 22r)r) copyrbotocore.waiterwaiterr r, ImportErrorerintrCr8rrrJsT-L y y x3#3c3COLs$727