+ Iin9csb^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) ChecksumErrorConnectionClosedErrorConnectionErrorEndpointConnectionErrorReadTimeoutErrorZGENERAL_CONNECTION_ERRORcsVR8Xd\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. Zrandz.The 'base' param must be greater than 0, got: )random ValueError)base growth_factorattemptsZ time_to_sleep&&& :/usr/lib/python3.14/site-packages/botocore/retryhandler.pydelay_exponentialr+sM v~}} B C:>JO*$++O<  !fjj&@&L#3J?%C OO23E3JK L:"'O*$++O< & 8}#HQKlKK$X. # %!&';!<  rcsRVR,9d\VR,R,4#RVR,9d \4#R#)response applies_when socket_errorsN)_create_single_response_checkerExceptionRaiser)rs&r r!r!sFVN++. > ": .   F>2 2   3rcsRV9d\VR,VR,R7pV#RV9d\VR,R7pV#RV9d\VR,R7pV#\R4h)Zservice_error_codeZhttp_status_code) status_code error_code)r, crc32body)headerzUnknown retry policy)ServiceErrorCodeCheckerHTTPStatusCodeChecker CRC32Checkerr)r'rs& r r*r*sx') !34 45  N x '' !34  N  h{&;< N/00rcsVR,pRVPR/49d\.#RV9d1.pVR,FpVP\V,4K! V#R#)r(r.r'r)N)r rr# EXCEPTION_MAP)rr(Z exceptionsZnames& r r"r"sf.)Ll&&z266 L (  11D   mD1 22 )rcs0a]tRt^toRtRtRtRtVtR#)raRetry 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)selfrr&&&r __init__ZRetryHandler.__init__s   rc shRVRVRV/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_exceptionZ request_dictZcontextZretriesretries_context)r zRetry needed, action of: %szNo retry needed.N)Z isinstancer6r$r Zupdater7loggerdebug)r8r r'r<ZkwargsZchecker_kwargsr=Zresults&&&&, r __call__ZRetryHandler.__call__s h   0  dmm%9 : :$^4Y?CCINO  ! !#4o"F G == *> * *\\8\4F LL6 ?M '(r)r7r6N) __name__ __module__ __qualname____firstlineno____doc__r:rA__static_attributes____classdictcell__Z __classdict__@r rrs ))rrcs6a]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 slVeVPW4#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)r8r;r'r<&&&&r rAZBaseChecker.__call__sE,  ''A A  )// KL LrcR#r5r>r8r;r'r9r rLZBaseChecker._check_response rcrOr5r>r8r;r<r9r rMZ#BaseChecker._check_caught_exceptionrQrr>N) rBrCrDrErFrArLrMrGrHrIrJr rKrKsM>   rrKcs:a]tRtRtoRtRRltRtRtRtVt R#) r$ia{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. Ncs*WnW nW0nR#r5r6 _max_attempts_retryable_exceptions)r8rrrrNr r:ZMaxAttemptsDecorator.__init__s )%9"rcs:V'd*\VPR^4VP4VR&VPWV4pV'dPWP8d>Ve"RV^,9dRV^,R,R&\P RV4R#V#R#)maxZResponseMetadataTZMaxAttemptsReachedz0Reached the maximum number of retry attempts: %sF)rVr rT _should_retryr?r@)r8r;r'r<r=Z should_retrys&&&&& r rAZMaxAttemptsDecorator.__call__s %(##E1-t/A/A&OE ")) &6  !3!33',>(1+,MQK 234HI F"##rcsVP'd$WP8dVPWV4#VPWV4# TPd$p\P RTRR7Rp?R#Rp?ii;i)z,retry needed, retryable exception caught: %sT)Zexc_infoN)rUrTr6r?r@)r8r;r'r<Zes&&&& r rWZ"MaxAttemptsDecorator._should_retry0s  % % %.;M;M*M }}".>==;KL L--  B!   sAA<A77A<rSr5) rBrCrDrErFr:rArWrGrHrIrJr r$r$s : 8MMrr$c,a]tRtRtoRtRtRtVtR#)r1iCcWnR#r5 _status_code)r8r,rr r:ZHTTPStatusCodeChecker.__init__Ds'rcsV^,PVP8Xd#\PRVP4R#R#)rz5retry needed: retryable HTTP status code received: %sTF)r,r[r?r@rPr9r rLZ%HTTPStatusCodeChecker._check_responseGs: A; " "d&7&7 7 LLG!! rrZNrBrCrDrEr:rLrGrHrIrJr r1r1Cs(rr1crX)r0iRcr4r5)r[ _error_code)r8r,r-r9r r:Z ServiceErrorCodeChecker.__init__Ss'%rcsV^,PVP8XdfV^,PR/4PR4pW0P8Xd.\P RVPVP4R#R#)rZErrorZCodez>retry needed: matching HTTP status and error code seen: %s, %sTF)r,r[r r]r?r@)r8r;r'Zactual_error_coder r rLZ'ServiceErrorCodeChecker._check_responseWsq A; " "d&7&7 7 (  < @ @ H  $4$44 %%$$  r)r]r[Nr\rIrJr r0r0Rs&  rr0crX)r%iecrYr5Z _checkers)r8r&rr r:ZMultiChecker.__init__fs!rcsVVPFpV!WV4pV'gKVu# R#)Fr^)r8r;r'r<rZchecker_responses&&&& r rAZMultiChecker.__call__is4~~G&*:   '' & rr^N)rBrCrDrEr:rArGrHrIrJr r%r%es"rr%crX)r2iscrYr5 _header_name)r8r/rr r:ZCRC32Checker.__init__ts"rcsV^,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)Z checksum_typeZexpected_checksumZactual_checksum) Zheadersr r`r?r@rZcontentZintr)r8r;r'Z http_responseZ expected_crcZ actual_crc32s&&& r rLZCRC32Checker._check_responsexs  $,,001B1BC   LL(!!  !!!4!45 BL3|#44  %  $")&),&7$05rr_Nr\rIrJr r2r2ss#rr2cs*a]tRtRtoRtRtRtVtR#)r+izXRaise any caught exceptions. This class will raise any non None ``caught_exception``. csVhr5r>rRr9r rMZ'ExceptionRaiser._check_caught_exceptions rr>N)rBrCrDrErFrMrGrHrIrJr r+r+s rr+r5)rZloggingrZbinasciirZbotocore.exceptionsrrrrrZ getLoggerrBr?r3rrrrrr!r*r"rrKr$r1r0r%r2r+r>rr ras    8 $  ! . 8   D!$&)&)R+ + \<M;<M~ K k& ; ;<kr