Vh|JddlZddlZddlZGddZdZGddZy)Nc$eZdZdZddZdZdZy)BackoffIteratoraiterate sleep value based on the exponential or jitter back-off algorithm. Args: delay (int or float): initial delay. backoff (int or float): backoff multiplier e.g. value of 2 will double the delay each retry. max_delay (int or None): maximum amount of time to wait between retries. jitter (bool): if set to true, add jitter to the generate value. Nc<||_||_||_||_yNdelaybackoff max_delayjitter)selfrr r r s i/home/dcms/DCMS/lib/python3.12/site-packages/ansible_collections/amazon/aws/plugins/module_utils/cloud.py__init__zBackoffIterator.__init__,s  " c(|j|_|Sr)r current_delay)r s r __iter__zBackoffIterator.__iter__2s!ZZ rc|j |jnt|j|j}|jrt j d|}|xj|j zc_|S)Ng)r rminr randomuniformr )r return_values r __next__zBackoffIterator.__next__6s^-1^^-Ct))TM_M_aeaoaoIp ;;!>>#|sG*   6M   qLG'!*S*"=3C8K{$;< :&' s A)AA$$A)cveZdZdZedZedZeddZe dZ e d dZ e d dZ y) CloudRetryzx The base class to be used by other cloud providers to provide a backoff/retry decorator based on status codes. Nct)z Returns the Error 'code' from an exception. Args: error: The Exception from which the error code is to be extracted. error will be an instance of class.base_class. )NotImplementedError)errors r status_code_from_exceptionz%CloudRetry.status_code_from_exceptionYs "##rc(fd}|xr|vS)Nc< ty#t$rYywxYw)NTF)iter TypeError)r'sr _is_iterablez&CloudRetry.found.._is_iterablees* ,-    s  r) response_coder'r:s ` r foundzCloudRetry.foundcs ~J-3J"JJrc&fd}|S)NcPtjfd}|S)Nc ntjg|i|}t| jS)N)r$r%r&r'r(r)r*) functoolspartialr/r*) argskwargs partial_funcr'clsr<r$r&r%r5s r _retry_wrapperzJCloudRetry.base_decorator..retry_decorator.._retry_wrappertsC(00GGG "%)=#,C!.H"~~r)r@wraps)r$rFr'rEr<r&r%r5s` r retry_decoratorz2CloudRetry.base_decorator..retry_decoratorss+ __T "  # " !rr)rEr&r<r5r'r%rHs`````` r base_decoratorzCloudRetry.base_decoratorqs " " rcrt|||}|j||j|j||S)a#Wrap a callable with retry behavior. Args: retries (int): Number of times to retry a failed request before giving up default=10 delay (int or float): Initial delay between retries in seconds default=3 backoff (int or float): backoff multiplier e.g. value of 2 will double the delay each retry default=2 max_delay (int or None): maximum amount of time to wait between retries. default=60 catch_extra_error_codes: Additional error messages to catch, in addition to those which may be defined by a subclass of CloudRetry default=None Returns: Callable: A generator that calls the decorated function using an exponential backoff. )rr r r&r<r5r'r%rrIr<r5rEr&rr r r'r%s r exponential_backoffzCloudRetry.exponential_backoffsE" /UGW`a!!))'*'E'E$;!5 "  rctt|||d}|j||j|j||S)a0Wrap a callable with retry behavior. Args: retries (int): Number of times to retry a failed request before giving up default=10 delay (int or float): Initial delay between retries in seconds default=3 backoff (int or float): backoff multiplier e.g. value of 2 will double the delay each retry default=2.0 max_delay (int or None): maximum amount of time to wait between retries. default=60 catch_extra_error_codes: Additional error messages to catch, in addition to those which may be defined by a subclass of CloudRetry default=None Returns: Callable: A generator that calls the decorated function using using a jittered backoff strategy. TrrKrLrMs r jittered_backoffzCloudRetry.jittered_backoffsH" /UGW`imn!!))'*'E'E$;!5 "  rr) <N)rQrRg@rTN) rrrrtyper* staticmethodr5r< classmethodrIrNrPrrr r1r1RsvdJ$$ K K&  2  rr1)r@rr"rr/r1rrr rXs+< 6(e e r