+ in9b^RIt^RIt^RIt^RIHt^RIHtHtHtH t H t ]P!] 4t R]]] ] ./tRtRtRRltRRltRR ltR tR tR t!R R4t!RR4t!RR]4t!RR]4t!RR]4t!RR]4t!RR]4t!RR]4tR#)N)crc32) ChecksumErrorConnectionClosedErrorConnectionErrorEndpointConnectionErrorReadTimeoutErrorGENERAL_CONNECTION_ERRORcVR8Xd\P!4pMV^8:d\RV 24hWV^, ,,pV#)aCalculate 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. randz.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+sM v~}} B C:>JO*$++O<  !fjj&@&L#3J?%C OO23E3JK L:"'O*$++O< & 8}#HQKlKK$X. # %!&';!<  rcRVR,9d\VR,R,4#RVR,9d \4#R#)response applies_when socket_errorsN)_create_single_response_checkerExceptionRaiser)r!s&rr/r/sFVN++. > ": .   F>2 2   3rcRV9d\VR,VR,R7pV#RV9d\VR,R7pV#RV9d\VR,R7pV#\R4h)service_error_codehttp_status_code) status_code error_code)rE crc32body)headerzUnknown retry policy)ServiceErrorCodeCheckerHTTPStatusCodeChecker CRC32Checkerr )r=rs& rr@r@sx') !34 45  N x '' !34  N  h{&;< N/00rcVR,pRVPR/49d\.#RV9d1.pVR,FpVP\V,4K! V#R#)r>rGr=r?N)r-rr1 EXCEPTION_MAP)r!r> exceptionsnames& rr0r0sf.)Ll&&z266 L (  11D   mD1 22 )rc0a]tRt^toRtRtRtRtVtR#)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. cWnW nR#N)_checker_action)selfrrs&&&r__init__RetryHandler.__init__s   rc hRVRVRV/p\VP\4'd3VR,R,PR4pVP RV/4VP!R /VB'd+VP VR7p\ PR V4V#\ PR 4R #) 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) isinstancerSr3r-updaterTloggerdebug)rUrr=rZkwargschecker_kwargsr^results&&&&, r__call__RetryHandler.__call__s h   0  dmm%9 : :$^4Y?CCINO  ! !#4o"F G == *> * *\\8\4F LL6 ?M '(r)rTrSN) __name__ __module__ __qualname____firstlineno____doc__rVrg__static_attributes____classdictcell__ __classdict__s@rr r s ))rr c6a]tRt^toRtRtRtRtRtVt R#) 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 lVeVPW4#VeVPW4#\R4h)adDetermine 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 )rUrYr=rZs&&&&rrgBaseChecker.__call__sE,  ''A A  )// KL LrcR#rRr_rUrYr=s&&&rruBaseChecker._check_response rcR#rRr_rUrYrZs&&&rrv#BaseChecker._check_caught_exceptionr{rr_N) rirjrkrlrmrgrurvrnrorps@rrsrssM>   rrsc:a]tRtRtoRtRRltRtRtRtVt R#) r3ia{Allow 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*WnW nW0nR#rRrS _max_attempts_retryable_exceptions)rUrr+r,s&&&&rrVMaxAttemptsDecorator.__init__s )%9"rc:V'd*\VPR^4VP4VR&VPWV4pV'dPWP8d>Ve"RV^,9dRV^,R,R&\P RV4R#V#R#)maxResponseMetadataTMaxAttemptsReachedz0Reached the maximum number of retry attempts: %sF)rr-r _should_retryrbrc)rUrYr=rZr^ should_retrys&&&&& rrgMaxAttemptsDecorator.__call__s %(##E1-t/A/A&OE ")) &6  !3!33',>(1+,MQK 234HI F"##rcVP'd$WP8dVPWV4#VPWV4# TPd$p\P RTRR7Rp?R#Rp?ii;i)z,retry needed, retryable exception caught: %sT)exc_infoN)rrrSrbrc)rUrYr=rZes&&&& rr"MaxAttemptsDecorator._should_retry0s  % % %.;M;M*M }}".>==;KL L--  B!   sAA<A77A<rrR) rirjrkrlrmrVrgrrnrorps@rr3r3s : 8MMrr3c,a]tRtRtoRtRtRtVtR#)rJiCcWnR#rR _status_code)rUrEs&&rrVHTTPStatusCodeChecker.__init__Ds'rcV^,PVP8Xd#\PRVP4R#R#)rz5retry needed: retryable HTTP status code received: %sTF)rErrbrcrys&&&rru%HTTPStatusCodeChecker._check_responseGs: A; " "d&7&7 7 LLG!! rrNrirjrkrlrVrurnrorps@rrJrJCs(rrJc,a]tRtRtoRtRtRtVtR#)rIiRcWnW nR#rR)r _error_code)rUrErFs&&&rrV ServiceErrorCodeChecker.__init__Ss'%rcV^,PVP8XdfV^,PR/4PR4pW0P8Xd.\P RVPVP4R#R#)rErrorCodez>retry needed: matching HTTP status and error code seen: %s, %sTF)rErr-rrbrc)rUrYr=actual_error_codes&&& rru'ServiceErrorCodeChecker._check_responseWsq A; " "d&7&7 7 (  < @ @ H  $4$44 %%$$  r)rrNrrps@rrIrIRs&  rrIc,a]tRtRtoRtRtRtVtR#)r4iecWnR#rR _checkers)rUr6s&&rrVMultiChecker.__init__fs!rcVVPFpV!WV4pV'gKVu# R#)Fr)rUrYr=rZrchecker_responses&&&& rrgMultiChecker.__call__is4~~G&*:   '' & rrN)rirjrkrlrVrgrnrorps@rr4r4es"rr4c,a]tRtRtoRtRtRtVtR#)rKiscWnR#rR _header_name)rUrHs&&rrVCRC32Checker.__init__ts"rcV^,pVPPVP4pVf#\P RVP4R#\ V^,P 4R,pV\V48Xg8\P R\V4V4\R\V4VR7hR#)rNz?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)rUrYr= http_response expected_crc actual_crc32s&&& rruCRC32Checker._check_responsexs  $,,001B1BC   LL(!!  !!!4!45 BL3|#44  %  $")&),&7$05rrNrrps@rrKrKss#rrKc*a]tRtRtoRtRtRtVtR#)rAizXRaise any caught exceptions. This class will raise any non None ``caught_exception``. cVhrRr_r}s&&&rrv'ExceptionRaiser._check_caught_exceptions rr_N)rirjrkrlrmrvrnrorps@rrArAs rrArR)rloggingr binasciirbotocore.exceptionsrrrrr getLoggerrirbrMrrr"rrr/r@r0r rsr3rJrIr4rKrAr_rrrs    8 $  ! . 8   D!$&)&)R+ + \<M;<M~ K k& ; ;<kr