ڰjn9`SSKrSSKrSSKrSSKJr SSKJrJrJrJ r J r \R"\ 5r S\\\ \ /0rSrSrSSjrSSjrSS jrS rS rS r"S S5r"SS5r"SS\5r"SS\5r"SS\5r"SS\5r"SS\5r"SS\5rg)N)crc32) ChecksumErrorConnectionClosedErrorConnectionErrorEndpointConnectionErrorReadTimeoutErrorGENERAL_CONNECTION_ERRORczUS:Xa[R"5nOUS::a[SU35eXUS- --nU$)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. randrz.The 'base' param must be greater than 0, got: )random ValueError)base growth_factorattempts time_to_sleeps R/home/mande/repo/quber/.venv/lib/python3.13/site-packages/botocore/retryhandler.pydelay_exponentialr+sM v~}} B C:>JO*$++O<  !fjj&@&L#3J?%C OO23E3JK L:"'O*$++O< & 8}#HQKlKK$X. # %!&';!<  rc^SUS;a[USS5$SUS;a [5$g)Nresponse applies_when socket_errors)_create_single_response_checkerExceptionRaiser)r"s rr0r0sFVN++. > ": .   F>2 2   3rcSU;a[USUSS9nU$SU;a[USS9nU$SU;a[USS9nU$[S5e)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/00rcUSnSURS05;a[/$SU;a(/nUSHnUR[U5 M U$g)Nr?rHr>r@)r.rr2 EXCEPTION_MAP)r"r? exceptionsnames rr1r1sc.)Ll&&z266 L (  1D   mD1 22 )rc$\rSrSrSrSrSrSrg)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. cXlX lgN)_checker_action)selfrrs r__init__RetryHandler.__init__s   rc HUUUS.n[UR[5(a*USSRS5nUR SU05 UR"S 0UD6(a'UR US9n[ RSU5 U$[ RS5 g ) 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) isinstancerUr4r.updaterVloggerdebug)rWrr>r\kwargschecker_kwargsr`results r__call__RetryHandler.__call__s' 0  dmm%9 : :$^4Y?CCINO  ! !#4o"F G == *> *\\8\4F LL6 ?M '(r)rVrUN)__name__ __module__ __qualname____firstlineno____doc__rXri__static_attributes__rarrr!r!s )rr!c*\rSrSrSrSrSrSrSrg) BaseCheckerzBase class for retry checkers. Each class is responsible for checking a single criteria that determines whether or not a retry should not happen. chUbURX5$UbURX5$[S5e)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)rWr[r>r\s rriBaseChecker.__call__sE,  ''A A  )// KL LrcgrTrarWr[r>s rruBaseChecker._check_response rcgrTrarWr[r\s rrv#BaseChecker._check_caught_exceptionr{rraN) rkrlrmrnrorirurvrprarrrrrrsM>  rrrc.\rSrSrSrSSjrSrSrSrg) r4ia{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(XlX lX0lgrTrU _max_attempts_retryable_exceptions)rWrr,r-s rrXMaxAttemptsDecorator.__init__s )%9"rcU(a)[URSS5UR5US'URXU5nU(a?XR:a.UbSUS;a SUSSS'[R SU5 gU$g) NmaxrResponseMetadatar TMaxAttemptsReachedz0Reached the maximum number of retry attempts: %sF)rr.r _should_retryrdre)rWr[r>r\r` should_retrys rriMaxAttemptsDecorator.__call__s %(##E1-t/A/A&OE ")) &6  !3!33',>(1+,MQK 234HI F"##rcUR(a"XR:aURXU5$URXU5$!URan[R SUSS9 SnAgSnAff=f)Nz,retry needed, retryable exception caught: %sT)exc_info)rrrUrdre)rWr[r>r\es rr"MaxAttemptsDecorator._should_retry0s}  % %.;M;M*M }}".>==;KL L--  B!   sAA5A00A5rrT) rkrlrmrnrorXrirrprarrr4r4s: 8Mrr4c \rSrSrSrSrSrg)rKiCcXlgrT _status_code)rWrFs rrXHTTPStatusCodeChecker.__init__Ds'rcUSRUR:Xa![RSUR5 gg)Nrz5retry needed: retryable HTTP status code received: %sTF)rFrrdrerys rru%HTTPStatusCodeChecker._check_responseGs: A; " "d&7&7 7 LLG!! rrNrkrlrmrnrXrurprarrrKrKCs (rrKc \rSrSrSrSrSrg)rJiRcXlX lgrT)r _error_code)rWrFrGs rrX ServiceErrorCodeChecker.__init__Ss'%rcUSRUR:Xa_USRS05RS5nX0R:Xa,[R SURUR5 gg)Nrr ErrorCodez>retry needed: matching HTTP status and error code seen: %s, %sTF)rFrr.rrdre)rWr[r>actual_error_codes rru'ServiceErrorCodeChecker._check_responseWsq A; " "d&7&7 7 (  < @ @ H  $4$44 %%$$  r)rrNrrarrrJrJRs & rrJc \rSrSrSrSrSrg)r5iecXlgrT _checkers)rWr7s rrXMultiChecker.__init__fs!rcRURHnU"XU5nU(dMUs $ g)NFr)rWr[r>r\rchecker_responses rriMultiChecker.__call__is4~~G&*:   '' & rrN)rkrlrmrnrXrirprarrr5r5es "rr5c \rSrSrSrSrSrg)rLiscXlgrT _header_name)rWrIs rrXCRC32Checker.__init__ts"rc\USnURRUR5nUc![R SUR5 g[ USR 5S-nU[U5:Xd4[R S[U5U5 [S[U5US9eg)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.rrdrercontentintr)rWr[r> http_response expected_crc actual_crc32s rruCRC32Checker._check_responsexs  $,,001B1BC   LL(!!  !!!4!45 BL3|#44  %  $")&),&7$05rrNrrarrrLrLss #rrLc\rSrSrSrSrSrg)rBizXRaise any caught exceptions. This class will raise any non None ``caught_exception``. cUerTrar}s rrv'ExceptionRaiser._check_caught_exceptions rraN)rkrlrmrnrorvrprarrrBrBs  rrBrT)rloggingr binasciirbotocore.exceptionsrrrrr getLoggerrkrdrNrrr#r rr0rAr1r!rrr4rKrJr5rLrBrarrrs    8 $  ! . 8   D!$&)&)R+ + \<M;<M~ K k& ; ;<kr