Pel9ZddlZddlZddlZddlmZddlmZmZmZm Z m Z eje Z deee e giZdZdZddZddZdd Zd Zd Zd ZGd dZGddZGddeZGddeZGddeZGddeZGddeZGddeZy)N)crc32) ChecksumErrorConnectionClosedErrorConnectionErrorEndpointConnectionErrorReadTimeoutErrorGENERAL_CONNECTION_ERRORcv|dk(rtj}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 7/usr/lib/python3/dist-packages/botocore/retryhandler.pydelay_exponentialr+sO v~}} B C:>JO*$++O<  = !fjj&@&L#N3J?% =C OO23Ec3JK L:"3'O*$++O<  = 8}#HQKlKK$X. # %!&';!<  rcVd|dvrt|ddSd|dvr tSy)Nresponse applies_when socket_errors)_create_single_response_checkerExceptionRaiser)r"s rr0r0sFVN++. > ": .   F>2 2   3rcd|vrt|d|d}|Sd|vrt|d}|Sd|vrt|d}|Std)Nservice_error_codehttp_status_code) status_code error_code)rF crc32body)headerzUnknown retry policy)ServiceErrorCodeCheckerHTTPStatusCodeChecker CRC32Checkerr)r>rs rrArAsx') !34 45  N x '' !34  N  h{&;< N/00rc|d}d|jdivrtgSd|vr&g}|dD]}|jt||Sy)Nr?rHr>r@)r.rr2 EXCEPTION_MAP)r"r? exceptionsnames rr1r1sh.)Ll&&z266 L (  1 3D   mD1 2 3 )rceZdZdZdZdZy)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 ||_||_yN)_checker_action)selfrrs r__init__zRetryHandler.__init__s  rc :|||d}t|jtr*|ddjd}|j d|i|jd i|r*|j |}t jd||St jdy ) 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  dmm%9 :$^4Y?CCINO  ! !#4o"F G 4== *> *\\8\4F LL6 ?M '(rN)__name__ __module__ __qualname____doc__rWrgr_rrr!r!s )rr!c"eZdZdZdZdZdZy) BaseCheckerzBase class for retry checkers. Each class is responsible for checking a single criteria that determines whether or not a retry should not happen. ch||j||S||j||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. z,Both response and caught_exception are None.)_check_response_check_caught_exceptionr)rVrYr>rZs rrgzBaseChecker.__call__sJ,  ''A A  )// 0 KL LrcyrSr_rVrYr>s rrozBaseChecker._check_response rcyrSr_rVrYrZs rrpz#BaseChecker._check_caught_exceptionrsrN)rhrirjrkrgrorpr_rrrmrmsM>  rrmc$eZdZdZddZdZdZy)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. Nc.||_||_||_yrS)rT _max_attempts_retryable_exceptions)rVrr,r-s rrWzMaxAttemptsDecorator.__init__s )%9"rc|r)t|jdd|j|d<|j|||}|r<||jk\r+|d|dvr d|ddd<tj d|y|Sy) NmaxrResponseMetadatar TMaxAttemptsReachedz0Reached the maximum number of retry attempts: %sF)r{r.rx _should_retryrbrc)rVrYr>rZr^ should_retrys rrgzMaxAttemptsDecorator.__call__s %(##E1-t/A/A&OE ")) H&6  !3!33',>(1+,MQK 23, F"##rc|jr#||jkr |j|||S|j|||S#|j$r"}tj d|dYd}~yd}~wwxYw)Nz,retry needed, retryable exception caught: %sT)exc_info)ryrxrTrbrc)rVrYr>rZes rr~z"MaxAttemptsDecorator._should_retry0s  % %.4;M;M*M }}"H.>==;KL L--  B!   sAA4A//A4rS)rhrirjrkrWrgr~r_rrr4r4s: 8Mrr4ceZdZdZdZy)rKc||_yrS) _status_code)rVrFs rrWzHTTPStatusCodeChecker.__init__Ds 'rc~|dj|jk(r!tjd|jyy)Nrz5retry needed: retryable HTTP status code received: %sTF)rFrrbrcrrs rroz%HTTPStatusCodeChecker._check_responseGs: A; " "d&7&7 7 LLG!! rNrhrirjrWror_rrrKrKCs (rrKceZdZdZdZy)rJc ||_||_yrS)r _error_code)rVrFrGs rrWz ServiceErrorCodeChecker.__init__Ss'%rc|dj|jk(r_|djdijd}||jk(r,tj d|j|jyy)Nrr ErrorCodez>retry needed: matching HTTP status and error code seen: %s, %sTF)rFrr.rrbrc)rVrYr>actual_error_codes rroz'ServiceErrorCodeChecker._check_responseWss A; " "d&7&7 7 (  < @ @ H  D$4$44 %%$$  rNrr_rrrJrJRs & rrJceZdZdZdZy)r5c||_yrS _checkers)rVr7s rrWzMultiChecker.__init__fs !rcF|jD]}||||}|s|cSy)NFr)rVrYr>rZrchecker_responses rrgzMultiChecker.__call__is8~~ (G&*:   ''  ( rN)rhrirjrWrgr_rrr5r5es "rr5ceZdZdZdZy)rLc||_yrS) _header_name)rVrIs rrWzCRC32Checker.__init__ts "rc^|d}|jj|j}|!tj d|jyt |dj dz}|t|k(s7tj dt||tdt||y)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  $,,001B1BC   LL(!!  !!!4!45 BL3|#44  %  $")&),&7$05rNrr_rrrLrLss #rrLceZdZdZdZy)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 $  ! . 8   D!$&)&)R+ + \<M;<M~ K k& ; ;<kr