7xjn9ddlZddlZddlZddlmZddlmZmZmZm Z m Z ej e Z deee e giZdZdZddZddZdd Zd Zd Zd ZGd dZGddZGddeZGddeZGddeZGddeZGddeZGddeZdS)N)crc32) ChecksumErrorConnectionClosedErrorConnectionErrorEndpointConnectionErrorReadTimeoutErrorGENERAL_CONNECTION_ERRORc|dkrtj}n|dkrtd||||dz zz}|S)a1Calculate time to sleep based on exponential function. The format is:: base * growth_factor ^ (attempts - 1) If ``base`` is set to 'rand' then a random number between 0 and 1 will be used as the base. Base must be greater than 0, otherwise a ValueError will be raised. randrz.The 'base' param must be greater than 0, got: )random ValueError)base growth_factorattempts time_to_sleeps FC:\Projects\Historical\venv\Lib\site-packages\botocore/retryhandler.pydelay_exponentialr+s[ v~~}  CT C C   Mhl;BB C C C:>JJO*$++O<<<!fjj&@&@&L#N3J?% = =C OO23Ec3JKK L L L:"3'O*$++O<<< 8}}#HQKlKKKK$X.. # %!&';! ": .    F>2 2 2    3 2rcd|vrt|d|d}nEd|vrt|d}n*d|vrt|d}ntd|S)Nservice_error_codehttp_status_code) status_code error_code)rF crc32body)headerzUnknown retry policy)ServiceErrorCodeCheckerHTTPStatusCodeChecker CRC32Checkerr)r>rs rrArAsx'') !34 45    x ' '' !34     h{&;<<</000 Nrc|d}d|divrtgSd|vr/g}|dD]"}|t|#|SdS)Nr?rHr>r@)r.rr2 EXCEPTION_MAP)r"r? exceptionsnames rr1r1s}.)Ll&&z26666 L ( (  1 3 3D   mD1 2 2 2 2 ) (rceZdZdZdZdZdS)r!aRetry handler. The retry handler takes two params, ``checker`` object and an ``action`` object. The ``checker`` object must be a callable object and based on a response and an attempt number, determines whether or not sufficient criteria for a retry has been met. If this is the case then the ``action`` object (which also is a callable) determines what needs to happen in the event of a retry. c"||_||_dSN)_checker_action)selfrrs r__init__zRetryHandler.__init__s  rc j|||d}t|jtr8|ddd}|d|i|jd i|r3||}t d||St dd S) zHandler for a retry. Intended to be hooked up to an event handler (hence the **kwargs), this will process retries appropriately. )attempt_numberr>caught_exception request_dictcontextretriesretries_context)rzRetry needed, action of: %szNo retry needed.N) isinstancerTr4r.updaterUloggerdebug)rVrr>rZkwargschecker_kwargsr^results r__call__zRetryHandler.__call__s' 0   dm%9 : : H$^4Y?CCINNO  ! !#4o"F G G G 4= * *> * * \\8\44F LL6 ? ? ?M '(((((rN)__name__ __module__ __qualname____doc__rWrgr_rrr!r!s<  )))))rr!c$eZdZdZdZdZdZdS) BaseCheckerzBase class for retry checkers. Each class is responsible for checking a single criteria that determines whether or not a retry should not happen. c||||S||||Std)aDetermine if retry criteria matches. Note that either ``response`` is not None and ``caught_exception`` is None or ``response`` is None and ``caught_exception`` is not None. :type attempt_number: int :param attempt_number: The total number of times we've attempted to send the request. :param response: The HTTP response (if one was received). :type caught_exception: Exception :param caught_exception: Any exception that was caught while trying to send the HTTP response. :return: True, if the retry criteria matches (and therefore a retry should occur. False if the criteria does not match. Nz,Both response and caught_exception are None.)_check_response_check_caught_exceptionr)rVrYr>rZs rrgzBaseChecker.__call__sU,  ''AA A  )// 0 KLL LrcdSrSr_rVrYr>s rrozBaseChecker._check_response rcdSrSr_rVrYrZs rrpz#BaseChecker._check_caught_exceptionrsrN)rhrirjrkrgrorpr_rrrmrmsNMMM>        rrmc&eZdZdZddZdZdZdS)r4aAllow retries up to a maximum number of attempts. This will pass through calls to the decorated retry checker, provided that the number of attempts does not exceed max_attempts. It will also catch any retryable_exceptions passed in. Once max_attempts has been exceeded, then False will be returned or the retryable_exceptions that was previously being caught will be raised. Nc0||_||_||_dSrS)rT _max_attempts_retryable_exceptions)rVrr,r-s rrWzMaxAttemptsDecorator.__init__s )%9"""rc"|r,t|dd|j|d<||||}|rG||jkr:|d|dvrd|ddd<td|dS|SdS) NmaxrResponseMetadatar TMaxAttemptsReachedz0Reached the maximum number of retry attempts: %sF)r{r.rx _should_retryrbrc)rVrYr>rZr^ should_retrys rrgzMaxAttemptsDecorator.__call__s  %(##E1--t/A&&OE ")) H&6    !333',>(1+,M,MQK 234HI F"u##5rc|jrX||jkrM ||||S#|j$r(}td|dYd}~dSd}~wwxYw||||S)Nz,retry needed, retryable exception caught: %sT)exc_info)ryrxrTrbrc)rVrYr>rZes rr~z"MaxAttemptsDecorator._should_retry0s  % M.4;M*M*M }}"H.>-    B! ttttt  ==;KLL Ls+ AAArS)rhrirjrkrWrgr~r_rrr4r4sU:::: 8MMMMMrr4ceZdZdZdZdS)rKc||_dSrS) _status_code)rVrFs rrWzHTTPStatusCodeChecker.__init__Ds'rcv|dj|jkr"td|jdSdS)Nrz5retry needed: retryable HTTP status code received: %sTF)rFrrbrcrrs rroz%HTTPStatusCodeChecker._check_responseGsB A; "d&7 7 7 LLG!   45rNrhrirjrWror_rrrKrKCs2(((rrKceZdZdZdZdS)rJc"||_||_dSrS)r _error_code)rVrFrGs rrWz ServiceErrorCodeChecker.__init__Ss'%rc|dj|jkrb|ddid}||jkr(td|j|jdSdS)Nrr ErrorCodez>retry needed: matching HTTP status and error code seen: %s, %sTF)rFrr.rrbrc)rVrYr>actual_error_codes rroz'ServiceErrorCodeChecker._check_responseWs~ A; "d&7 7 7 (  < < @ @ H H  D$444 %$  turNrr_rrrJrJRs2&&&     rrJceZdZdZdZdS)r5c||_dSrS _checkers)rVr7s rrWzMultiChecker.__init__fs !rc@|jD]}||||}|r|cSdS)NFr)rVrYr>rZrchecker_responses rrgzMultiChecker.__call__isM~ ( (G&w*:     ('''' (urN)rhrirjrWrgr_rrr5r5es2"""rr5ceZdZdZdZdS)rLc||_dSrS) _header_name)rVrIs rrWzCRC32Checker.__init__ts"rc|d}|j|j}|"td|jdSt |djdz}|t|ksHtdt||tdt||dS)Nrz?crc32 check skipped, the %s header is not in the http response.lz>retry needed: crc32 check failed, expected != actual: %s != %sr) checksum_typeexpected_checksumactual_checksum) headersr.rrbrcrcontentintr)rVrYr> http_response expected_crc actual_crc32s rrozCRC32Checker._check_responsexs  $,001BCC   LL(!      !!!455 BL3|#4#444  %%  $")&),&7&7$054rNrr_rrrLrLss2###rrLceZdZdZdZdS)rBz`Raise any caught exceptions. This class will raise any non None ``caught_exception``. c|rSr_rus rrpz'ExceptionRaiser._check_caught_exceptions rN)rhrirjrkrpr_rrrBrBs- rrBrS)rloggingr binasciirbotocore.exceptionsrrrrr getLoggerrhrbrNrrr#r rr0rAr1r!rmr4rKrJr5rLrBr_rrrs   8 $ $  ! .   8888         D!!!$&)&)&)&)&)&)&)&)R+ + + + + + + + \<M<M<M<M<M;<M<M<M~     K   k&     ;   ;<kr