۰jlSrSSKrSSKrSSKrSSKJr SSKJrJrJ r J r SSK J r J r SSKJrJr SrSSS .r\R&"\5rS)S jr"S S 5r"S S5r"SS5r"SS5r"SS5r"SS\5r"SS\5r"SS\5r"SS\5r"SS\5r "SS 5r!"S!S"5r""S#S$\5r#"S%S&\5r$"S'S(5r%g)*aCStandard retry behavior. This contains the default standard retry behavior. It provides consistent behavior with other AWS SDKs. The key base classes uses for retries: * ``BaseRetryableChecker`` - Use to check a specific condition that indicates a retry should happen. This can include things like max attempts, HTTP status code checks, error code checks etc. * ``RetryBackoff`` - Use to determine how long we should backoff until we retry a request. This is the class that will implement delay such as exponential backoff. * ``RetryPolicy`` - Main class that determines if a retry should happen. It can combine data from a various BaseRetryableCheckers to make a final call as to whether or not a retry should happen. It then uses a ``BaseRetryBackoff`` to determine how long to delay. * ``RetryHandler`` - The bridge between botocore's event system used by endpoint.py to manage retries and the interfaces defined in this module. This allows us to define an API that has minimal coupling to the event based API used by botocore. N)NEW_RETRIES_ENABLED)ConnectionErrorConnectTimeoutErrorHTTPClientErrorReadTimeoutError)quotaspecial)BaseRetryableCheckerBaseRetryBackoffdynamodbzdynamodb-streamsc VURRRnUR5n[ 5n[ (aUcU[ ;a [ UnO Uc[nURRRSU3[U5RSU3S9 [U5n[[R"5U5n[![#[%US9['UUS9S9UUUS9nOM[[R"55n[![#[%U=(d [S9['5S9UUS9nURRRS U3UR(5 S U3nURRRS U3UR*US9 U$) Nzrequest-created.zseed-max-attempts-) unique_id) max_attempts) service_namethrottling_detector) retry_checker retry_backoff) retry_policyretry_event_adapter retry_quotar)rrrz after-call.z retry-config-z needs-retry.)meta service_model service_id hyphenizeRetryEventAdapterr_SERVICE_MAX_ATTEMPTSDEFAULT_MAX_ATTEMPTSeventsregisterMaxAttemptsSeederseed_max_attemptsThrottlingErrorDetectorRetryQuotaCheckerr RetryQuota RetryHandler RetryPolicyStandardRetryConditionsExponentialBackoffrelease_retry_quota needs_retry) clientrrservice_event_namerrrhandlerrs V/home/mande/repo/quber/.venv/lib/python3.13/site-packages/botocore/retries/standard.pyregister_retry_handlerr24s**55J#--/+-  "&;;01CDL  !/L  ##12 3 l + = =*+=*>? $ 66IJ'     3 $5!-1!3(; !4#+  ((8(8(:; $5!-!E1E12  !4#   KK ()*K,K,K 234I KK )*+  Nc$\rSrSrSrSrSrSrg)r#xzAdds the resolved max attempts to the retries context. The ``max`` value is otherwise only added to the retries context by ``MaxAttemptsChecker`` when a retry is evaluated, which means it's absent from the initial attempt's ``amz-sdk-request`` header. cXlgN _max_attemptsselfrs r1__init__MaxAttemptsSeeder.__init__)r3c ZURRS05nURUS'g)Nretriesmax)context setdefaultr9)r;requestkwargsretries_contexts r1r$#MaxAttemptsSeeder.seed_max_attemptss(!//44YC!%!3!3r3r8N)__name__ __module__ __qualname____firstlineno____doc__r<r$__static_attributes__r3r1r#r#xs*4r3r#cZ\rSrSrSrS1S1SS1S.rS\R4S jrS r S r S r g) r(zBridge between botocore's event system and this module. This class is intended to be hooked to botocore's event system as an event handler. ReceiveMessageGetActivityTaskPollForActivityTaskPollForDecisionTask)sqssfnswfNc@XlX lX0lX@lXPlgr7) _retry_policy_retry_event_adapter _retry_quota _service_name_sleep)r;rrrrsleeps r1r<RetryHandler.__init__s!*$7!') r3c SnURR"S0UD6nURRU5(aURR U5(a2URR U5n[RSU5 O[(asURU5(a]URR U5nURU5 [RS5 URRU5 g[RS5 O[RS5 URRU5 U$)z.Connect as a handler to the needs-retry event.Nz1Retry needed, retrying request after delay of: %sz;Retry needed but retry quota reached, not retrying request.FzNot retrying request.rN) rZcreate_retry_contextrY should_retryr[acquire_retry_quotacompute_retry_delayloggerdebugr_is_long_polling_operationr]!adapt_retry_response_from_context)r;rE retry_delayrB polling_delays r1r-RetryHandler.needs_retrys! ++@@J6J    * *7 3 3  44W=="00DDWM  G '&66w??(,(:(:(N(N#)  M2 411SS# % , LL0 1 !!CCGLr3cURb URcgURRUR5nUSL=(a URRU;$NF)r\operation_model_LONG_POLLING_OPERATIONSgetname)r;rB operationss r1rg'RetryHandler._is_long_polling_operations`    %)@)@)H2266t7I7IJ d " ;'',, : r3)rZrYr[r\r]) rHrIrJrKrLrotimer^r<r-rgrMrNr3r1r(r(sB!!!"%'<= jj &P  r3r(c$\rSrSrSrSrSrSrg)racAdapter to existing retry interface used in the endpoints layer. This existing interface for determining if a retry needs to happen is event based and used in ``botocore.endpoint``. The interface has grown organically over the years and could use some cleanup. This adapter converts that interface into the interface used by the new retry strategies. c bUSnUcSnSnOUup4[USUSUUUSUSSS9nU$) z+Create context based on needs-retry kwargs.responseNattempts operationcaught_exception request_dictrB)attempt_numberrn http_responseparsed_responser{request_context) RetryContext)r;rErxr~rrBs r1ra&RetryEventAdapter.create_retry_contextse*%   !M"O-5 *M!*-";/'+#$67">29=  r3cUR5nURb,URRS05RU5 gg)z/Modify response back to user back from context.NResponseMetadata)get_retry_metadatarrCupdate)r;rBmetadatas r1rh3RetryEventAdapter.adapt_retry_response_from_contextsH --/  " " .  # # . ./A2 F M M  /r3rNN)rHrIrJrKrLrarhrMrNr3r1rrs2 r3rc>\rSrSrSrS SjrSrSrSrSr g) riaQNormalize a response that we use to check if a retry should occur. This class smoothes over the different types of responses we may get from a service including: * A modeled error response from the service that contains a service code and error message. * A raw HTTP response that doesn't contain service protocol specific error keys. * An exception received while attempting to retrieve a response. This could be a ConnectionError we receive from our HTTP layer which could represent that we weren't able to receive a response from the service. This class guarantees that at least one of the above attributes will be non None. This class is meant to provide a read-only view into the properties associated with a possible retryable response. None of the properties are meant to be modified directly. NcdXlX lX0lX@lXPlUc0nX`l0Ulgr7)r}rnrr~r{r_retry_metadata)r;r}rnrr~r{rs r1r<RetryContext.__init__&sA-. /*!1  " O.!r3cURcgURRS05n[U[5(dgURS5$)zwCheck if there was a parsed response with an error code. If we could not find any error codes, ``None`` is returned. NErrorCode)rrp isinstancedict)r;errors r1get_error_codeRetryContext.get_error_codeEsJ    ' $$(("5%&& yy  r3c <URR"S0UD6 g)zAdd key/value pairs to the retry metadata. This allows any objects during the retry process to add metadata about any checks/validations that happened. This gets added to the response metadata in the retry handler. NrN)rr)r;rEs r1add_retry_metadataRetryContext.add_retry_metadataRs ##-f-r3c6URR5$r7)rcopyr;s r1rRetryContext.get_retry_metadata]s##((**r3)rr}r{r~rnrr)NNNNN) rHrIrJrKrLr<rrrrMrNr3r1rrs,4"> ! .+r3rc&\rSrSrSrSrSrSrg)r)iacXlX lgr7)_retry_checker_retry_backoff)r;rrs r1r<RetryPolicy.__init__bs++r3c8URRU5$r7)r is_retryabler;rBs r1rbRetryPolicy.should_retryf""//88r3c8URRU5$r7)r delay_amountrs r1rdRetryPolicy.compute_retry_delayirr3)rrN)rHrIrJrKr<rbrdrMrNr3r1r)r)as,99r3r)cx\rSrSrSrSrSrSrSSS.rS S 0S S 0S .r S\ RS S 4S jr Sr Sr SrSrg )r+imzx-amz-retry-afterg?)throttling_base_scalenon_throttling_base_scalerg?rNcVURUlXlX lX0lX@lgr7)_BASE_base _max_backoff_randomr\_throttling_detector)r; max_backoffrandomrrs r1r<ExponentialBackoff.__init__}s&ZZ ' )$7!r3c[(aUR5[URU5URUR S- --UR 5-nURU5nUb"[U[X0RU-55$U$UR5[URUR S- -UR 5-$)zCalculates delay based on exponential backoff. This class implements truncated binary exponential backoff with jitter:: t_i = rand(0, 1) * min(2 ** attempt, MAX_BACKOFF) where ``i`` is the request attempt (0 based). r) rrmin_get_base_scalerr}r_get_retry_after_delayrA_RETRY_AFTER_MAX_ADDITIONAL)r;rBt_i retry_afters r1rExponentialBackoff.delay_amounts  ,,.3$$W-::'"8"81"<=?!!$C55g>K& %E%E%KL J<<>C 6 6 :;!!% r3c UR(a/URRU5(aURS$URUR;aURURS$URS$)Nrr)r is_throttling_error_from_context_DEFAULT_BACKOFF_CONFIGr\_SERVICE_BACKOFF_CONFIGrs r1r"ExponentialBackoff._get_base_scales  % %))JJ//0GH H   !=!= =//0B0BC+ ++,GHHr3cFURcgURRRUR5nUcg[ U5S- nUS:a [ S5eU$![ [ 4a,n[RSURUU5 SnAgSnAff=f)Ng@@rzNegative retry-after valuez0Invalid %s header value: %s, ignoring. Error: %s) r~headersrp_RETRY_AFTER_HEADERint ValueError OverflowErrorrerf)r;rBretry_after_msvaluees r1r)ExponentialBackoff._get_retry_after_delays  ( ..66::  $ $   ! '&0Eqy !=>>LM*  LLB((    s A$$B 4"BB )rrrr\r)rHrIrJrKr _MAX_BACKOFFrrrrrr<rrrrMrNr3r1r+r+msj EL-"#"#%) 1%88%@}} 8#J Ir3r+c \rSrSrSrSrSrg)MaxAttemptsCheckericXlgr7r8r:s r1r<MaxAttemptsChecker.__init__r>r3c:URUR:nURRS5nU(a)[ URSS5UR5US'U(d/[ R SUR5 URSS9 U$)Nr@rArzMax attempts of %s reached.T)MaxAttemptsReached)r}r9rrprArerfr)r;rBunder_max_attemptsrFs r1rMaxAttemptsChecker.is_retryables$33d6H6HH!1155i@ %(##E1-t/A/A&OE "" LL68J8J K  & &$ & ?!!r3r8NrHrIrJrKr<rrMrNr3r1rrs * "r3rcB\rSrSr/SQr/SQr\\4rSSjr Sr Sr g) TransientRetryableCheckeri)RequestTimeoutRequestTimeoutExceptionPriorRequestNotComplete)iiiiNcUcURSSnUcURSSnUc URnXlX lX0lgr7)_TRANSIENT_ERROR_CODES_TRANSIENT_STATUS_CODES_TRANSIENT_EXCEPTION_CLS_transient_error_codes_transient_status_codes_transient_exception_cls)r;transient_error_codestransient_status_codestransient_exception_clss r1r<"TransientRetryableChecker.__init__sV ! ($($?$?$B ! ! )%)%A%A!%D " " *&*&C&C #&;#'=$(?%r3cUR5UR;agURb%URRUR;agUR b [ UR UR5$g)NTF)rrr~ status_coderr{rrrs r1r&TransientRetryableChecker.is_retryablesy  ! ! #t'B'B B  ,%%11//0  # # /(($*G*G r3)rrr)NNN) rHrIrJrKrrrrrr<rrMrNr3r1rrs6 3 ## $ @ r3rc,\rSrSr/SQrSSjrSrSrg)ThrottledRetryableCheckeri) ThrottlingThrottlingExceptionThrottledExceptionRequestThrottledExceptionTooManyRequestsException&ProvisionedThroughputExceededExceptionTransactionInProgressExceptionRequestLimitExceededBandwidthLimitExceededLimitExceededExceptionRequestThrottledSlowDownrEC2ThrottledExceptionNc4UcURSSnXlgr7)_THROTTLED_ERROR_CODES_throttled_error_codes)r;throttled_error_codess r1r<"ThrottledRetryableChecker.__init__%s ($($?$?$B !&;#r3c<UR5UR;$r7)rrrs r1r&ThrottledRetryableChecker.is_retryable*s%%'4+F+FFFr3)rr7)rHrIrJrKrr<rrMrNr3r1rrs"< Gr3rc$\rSrSrSrSrSrSrg)ModeledRetryableCheckeri0z0Check if an error has been modeled as retryable.c"[5Ulgr7)ModeledRetryErrorDetector_error_detectorrs r1r< ModeledRetryableChecker.__init__3s 8:r3cdUR5nUcgURRU5SL$rm)rrdetect_error_type)r;rB error_codes r1r$ModeledRetryableChecker.is_retryable6s5++-  ##55g>dJJr3)rN)rHrIrJrKrLr<rrMrNr3r1rr0s:;Kr3rc&\rSrSrSrSrSrSrSrg)ri=zKr3r%c*\rSrSrSr\4SjrSrSrg)r*itzConcrete class that implements the standard retry policy checks. Specifically: not max_attempts and (transient or throttled or modeled_retry) c [U5Ul[[5[ 5[ 5[[ R"5[ R"5/5/5Ul gr7) r_max_attempts_checkerOrRetryCheckerrrrr RetryIDPCommunicationErrorRetryDDBChecksumError_additional_checkersr:s r1r< StandardRetryConditions.__init__}sZ&8 %E"$2)+)+')::<557  % !r3c|URRU5=(a URRU5$r7)r&rr*rs r1r$StandardRetryConditions.is_retryables7))66  >''44W= >r3)r*r&N) rHrIrJrKrLr r<rrMrNr3r1r*r*ts%9 $>r3r*c \rSrSrSrSrSrg)r'icXlgr7 _checkers)r;checkerss r1r<OrRetryChecker.__init__s!r3cB^[U4SjUR55$)Nc3D># UHoRT5v M g7fr7)r).0checkerrBs r1 .OrRetryChecker.is_retryable..sOW''00s )anyr1rs `r1rOrRetryChecker.is_retryablesOOOOr3r0NrrNr3r1r'r's "Pr3r'cR\rSrSrSrSrSrSrSr\ \ 4r S Sjr Sr S rS rS rS rg)r&irr Nc*XlX lSUlgr7)_quotar_last_amount_acquired)r;rrs r1r<RetryQuotaChecker.__init__s $7!%)"r3cX[(a0URU5(a URnOr`s4 8 ,H   8 $AH44"O O d--fP+P+f 9 9d)dN"-"") 4)XG 4G> K2 K"0"0JKK$>2>BP)PE5E5r3