Файловый менеджер - Редактировать - /usr/lib/rads/venv/lib/python3.13/site-packages/botocore/retries/__pycache__/standard.cpython-313.pyc
Ðазад
� � �iN � � � S r SSKrSSKrSSKJrJrJrJr SSKJ r J r SSK J r J r Sr\R " \5 r\4S jr " S S 5 r " S S 5 r " S S 5 r " S S5 r " S S\ 5 r " S S\ 5 r " S S\ 5 r " S S\ 5 r " S S\ 5 r " S S5 r " S S 5 r " S S \ 5 r " S S!\ 5 r " S" S#5 r g)$aC Standard 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)�ConnectionError�ConnectTimeoutError�HTTPClientError�ReadTimeoutError)�quota�special)�BaseRetryableChecker�BaseRetryBackoff� c �� � [ [ R " 5 5 nU R R R nUR 5 nU R R R SU 3UR 5 [ [ [ US9[ 5 S9[ 5 US9nSU 3nU R R R SU 3UR US9 U$ )Nz after-call.)� max_attempts)� retry_checker� retry_backoff)� retry_policy�retry_event_adapter� retry_quotaz retry-config-z needs-retry.)� unique_id)�RetryQuotaCheckerr � RetryQuota�meta� service_model� service_id� hyphenize�events�register�release_retry_quota� RetryHandler� RetryPolicy�StandardRetryConditions�ExponentialBackoff�RetryEventAdapter� needs_retry)�clientr r r �service_event_name�handlerr s �L/usr/lib/rads/venv/lib/python3.13/site-packages/botocore/retries/standard.py�register_retry_handlerr' + s� � �#�E�$4�$4�$6�7�K����*�*�5�5�J�#�-�-�/�� �K�K��� � � �(�)�*�K�,K�,K�� � �1�|�L�,�.� � .� /� � �G� � 2� 3�4�I� �K�K��� � � �)�*�+����� � � �N� c �$ � \ rS rSrSrS rS rSrg)r �F z�Bridge between botocore's event system and this module. This class is intended to be hooked to botocore's event system as an event handler. c �( � Xl X l X0l g �N)� _retry_policy�_retry_event_adapter� _retry_quota)�selfr r r s r& �__init__�RetryHandler.__init__M s � � )��$7�!� '�r( c � � SnU R R " S0 UD6nU R R U5 ( ah U R R U5 ( a2 U R R U5 n[ R SU5 O+[ R S5 O[ R S5 U R R U5 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.zNot retrying request.� ) r. �create_retry_contextr- � should_retryr/ �acquire_retry_quota�compute_retry_delay�logger�debug�!adapt_retry_response_from_context)r0 �kwargs� retry_delay�contexts r& r" �RetryHandler.needs_retryR s� � �� ��+�+�@�@�J�6�J�� � � � *� *�7� 3� 3� � � �4�4�W�=�=� "� 0� 0� D� D�W� M� �� � �G� �� � � �,�� �L�L�0� 1� �!�!�C�C�G�L��r( )r. r- r/ N)�__name__� __module__� __qualname__�__firstlineno__�__doc__r1 r" �__static_attributes__r4 r( r& r r F s � �� (� r( r c �$ � \ rS rSrSrS rS rSrg)r! �j ac Adapter 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 �b � US nUc SnSnOUu p4[ US US UUUS US S S9nU$ ) z+Create context based on needs-retry kwargs.�responseN�attempts� operation�caught_exception� request_dictr> )�attempt_number�operation_model� http_response�parsed_responserL �request_context)� RetryContext)r0 r< rI rP rQ r> s r& r5 �&RetryEventAdapter.create_retry_contextu se � ��*�%�� � � !�M� "�O�-5� *�M� �!�*�-� "�;� /�'� +� #�$6� 7� "�>� 2�9� =� �� �r( c � � UR 5 nUR b, UR R S0 5 R U5 gg)z/Modify response back to user back from context.N�ResponseMetadata)�get_retry_metadatarQ � setdefault�update)r0 r> �metadatas r& r; �3RetryEventAdapter.adapt_retry_response_from_context� sH � � �-�-�/�� � "� "� .� � #� #� .� .�/A�2� F� M� M�� � /r( r4 N)r@ rA rB rC rD r5 r; rE r4 r( r& r! r! j s � ���2 r( r! c �> � \ rS rSrSr S S jrS rS rS rSr g) rS � aQ Normalize 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. Nc �d � Xl X l X0l X@l XPl Uc 0 nX`l 0 U l g r, )rN rO rQ rP rL rR �_retry_metadata)r0 rN rO rQ rP rL rR s r& r1 �RetryContext.__init__� sA � � -�� .� � /� � *�� !1� � � "� �O� .� � !�� r( c � � U R c gU R R S0 5 n[ U[ 5 ( d gUR S5 $ )zwCheck if there was a parsed response with an error code. If we could not find any error codes, ``None`` is returned. N�Error�Code)rQ �get� isinstance�dict)r0 �errors r& �get_error_code�RetryContext.get_error_code� sJ � � � � � '� ��$�$�(�(��"�5���%��&�&� ��y�y�� � r( c �< � U R R " S0 UD6 g)z�Add 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. Nr4 )r_ rY )r0 r< s r& �add_retry_metadata� RetryContext.add_retry_metadata� s � � � � �#�#�-�f�-r( c �6 � U R R 5 $ r, )r_ �copy�r0 s r& rW � RetryContext.get_retry_metadata� s � ��#�#�(�(�*�*r( )r_ rN rL rP rO rQ rR )NNNNN) r@ rA rB rC rD r1 rh rk rW rE r4 r( r& rS rS � s, � ��4 � �� � �"�> !� .�+r( rS c �& � \ rS rSrS rS rS rSrg)r �� c � � Xl X l g r, )�_retry_checker�_retry_backoff)r0 r r s r& r1 �RetryPolicy.__init__� s � � +�� +�r( c �8 � U R R U5 $ r, )rt � is_retryable�r0 r> s r& r6 �RetryPolicy.should_retry� � � ��"�"�/�/��8�8r( c �8 � U R R U5 $ r, )ru � delay_amountry s r& r8 � RetryPolicy.compute_retry_delay� r{ r( )ru rt N)r@ rA rB rC r1 r6 r8 rE r4 r( r& r r � s � �,�9�9r( r c �D � \ rS rSrSrSrS\R 4S jrS rSr g)r � � � c �> � U R U l Xl X l g r, )�_BASE�_base� _max_backoff�_random)r0 � max_backoff�randoms r& r1 �ExponentialBackoff.__init__ s � ��Z�Z�� � '�� � r( c � � U R 5 [ U R UR S- - U R 5 - $ )z�Calculates 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� �minr� rN r� ry s r& r} � ExponentialBackoff.delay_amount s> � � �|�|�~�� �Z�Z�G� 2� 2�Q� 6� 7� � � �! � � r( )r� r� r� N) r@ rA rB rC r� � _MAX_BACKOFFr� r1 r} rE r4 r( r& r r � s � � �E��L�#%�f�m�m� � r( r c � � \ rS rSrS rS rSrg)�MaxAttemptsCheckeri c � � Xl g r, �� _max_attempts�r0 r s r& r1 �MaxAttemptsChecker.__init__ s � � )�r( c �: � UR U R : nUR R S5 nU( a) [ UR SS5 U R 5 US' U( d/ [ R SU R 5 UR SS9 U$ )N�retries�maxr zMax attempts of %s reached.T)�MaxAttemptsReached)rN r� rR rd r� r9 r: rk )r0 r> �under_max_attempts�retries_contexts r& rx � MaxAttemptsChecker.is_retryable s� � � $� 3� 3�d�6H�6H� H��!�1�1�5�5�i�@�� �%(� �#�#�E�1�-�t�/A�/A�&�O�E� "� "� �L�L�6��8J�8J� K� � &� &�$� &� ?�!�!r( r� N�r@ rA rB rC r1 rx rE r4 r( r& r� r� s � �*� "r( r� c �B � \ rS rSr/ SQr/ SQr\\4r SS jr S r Sr g) �TransientRetryableCheckeri* )�RequestTimeout�RequestTimeoutException�PriorRequestNotComplete)i� i� i� i� Nc � � Uc U R S S nUc U R S S nUc U R nXl X l X0l g r, )�_TRANSIENT_ERROR_CODES�_TRANSIENT_STATUS_CODES�_TRANSIENT_EXCEPTION_CLS�_transient_error_codes�_transient_status_codes�_transient_exception_cls)r0 �transient_error_codes�transient_status_codes�transient_exception_clss r& r1 �"TransientRetryableChecker.__init__6 sV � � !� (�$(�$?�$?��$B� !� !� )�%)�%A�%A�!�%D� "� "� *�&*�&C�&C� #�&;�#�'=�$�(?�%r( c � � UR 5 U R ; a gUR b% UR R U R ; a gUR b [ UR U R 5 $ g)NTF)rh r� rP � status_coder� rL re r� ry s r& rx �&TransientRetryableChecker.is_retryableF sy � � � !� !� #�t�'B�'B� B�� � � � ,��%�%�1�1��/�/�0� � � #� #� /� ��(�(�$�*G�*G�� � r( )r� r� r� )NNN) r@ rA rB rC r� r� r r r� r1 rx rE r4 r( r& r� r� * s6 � � �� 3���� � � #� #� $� @� r( r� c �, � \ rS rSr/ SQrSS jrS rSrg)�ThrottledRetryableCheckeriV )� Throttling�ThrottlingException�ThrottledException�RequestThrottledException�TooManyRequestsException�&ProvisionedThroughputExceededException� TransactionInProgressException�RequestLimitExceeded�BandwidthLimitExceeded�LimitExceededException�RequestThrottled�SlowDownr� �EC2ThrottledExceptionNc �4 � Uc U R S S nXl g r, )�_THROTTLED_ERROR_CODES�_throttled_error_codes)r0 �throttled_error_codess r& r1 �"ThrottledRetryableChecker.__init__j s � � � (�$(�$?�$?��$B� !�&;�#r( c �< � UR 5 U R ; $ r, )rh r� ry s r& rx �&ThrottledRetryableChecker.is_retryableo s � � �%�%�'�4�+F�+F�F�Fr( )r� r, )r@ rA rB rC r� r1 rx rE r4 r( r& r� r� V s � � ��"<� Gr( r� c �$ � \ rS rSrSrS rS rSrg)�ModeledRetryableCheckeriu z0Check if an error has been modeled as retryable.c �" � [ 5 U l g r, )�ModeledRetryErrorDetector�_error_detectorro s r& r1 � ModeledRetryableChecker.__init__x s � � 8� :�� r( c �d � UR 5 nUc gU R R U5 S L$ )NF)rh r� �detect_error_type)r0 r> � error_codes r& rx �$ModeledRetryableChecker.is_retryable{ s5 � � �+�+�-� � � ���#�#�5�5�g�>�d�J�Jr( )r� N)r@ rA rB rC rD r1 rx rE r4 r( r& r� r� u s � �:�;�Kr( r� c �& � \ rS rSrSrSrSrS rSrg)r� i� z<Checks whether or not an error is a modeled retryable error.�TRANSIENT_ERROR�THROTTLING_ERRORc �� � UR 5 nUR nUb UR ( d gUR H� nUR R S5 c M! UR R S0 5 R S5 =( d UR nX%:X d Mf UR S R S5 ( a U R s $ U R s $ g)a Detect the error type associated with an error code and model. This will either return: * ``self.TRANSIENT_ERROR`` - If the error is a transient error * ``self.THROTTLING_ERROR`` - If the error is a throttling error * ``None`` - If the error is neither type of error. N� retryablerg �code� throttling)rh rO � error_shapesrZ rd �namer� r� )r0 r> r� �op_model�shape�error_code_to_checks r& r� �+ModeledRetryErrorDetector.detect_error_type� s� � � �+�+�-� ��*�*�� � �8�#8�#8� � �*�*�E��~�~�!�!�+�.�:� �N�N�&�&�w��3�7�7��?�M�5�:�:� $� �4� �~�~�k�2�6�6�|�D�D� #� 4� 4�4� �/�/�/� +r( r4 N) r@ rA rB rC rD r� r� r� rE r4 r( r& r� r� � s � �F� (�O�)�� 0r( r� c � � \ rS rSrS rS rSrg)�ThrottlingErrorDetectori� c �L � [ 5 U l [ 5 U l Xl g r, )r� �_modeled_error_detectorr� �_fixed_error_code_detectorr. )r0 r s r& r1 � ThrottlingErrorDetector.__init__� s � �'@�'B��$�*C�*E��'�$7�!r( c �� � U R R " S0 UD6nU R R U5 ( a gU R R U5 nX0R R :H $ )NTr4 )r. r5 r� rx r� r� r� )r0 r< r> � error_types r& �is_throttling_error�+ThrottlingErrorDetector.is_throttling_error� s` � ��+�+�@�@�J�6�J�� � *� *� 7� 7�� @� @���1�1�C�C�G�L� �� 9� 9� J� J�J�Jr( )r� r� r. N)r@ rA rB rC r1 r� rE r4 r( r& r� r� � s � �8� Kr( r� c �* � \ rS rSrSr\4S jrS rSrg)r i� z�Concrete class that implements the standard retry policy checks. Specifically: not max_attempts and (transient or throttled or modeled_retry) c �� � [ U5 U l [ [ 5 [ 5 [ 5 [ [ R " 5 [ R " 5 /5 /5 U l g r, ) r� �_max_attempts_checker�OrRetryCheckerr� r� r� r �RetryIDPCommunicationError�RetryDDBChecksumError�_additional_checkersr� s r& r1 � StandardRetryConditions.__init__� sZ � � &8� �%E��"�$2�)�+�)�+�'�)� � �:�:�<� �5�5�7��� � % ��!r( c �| � U R R U5 =( a U R R U5 $ r, )r� rx r� ry s r& rx �$StandardRetryConditions.is_retryable� s7 � ��)�)�6�6� � � >��'�'�4�4�W�=� >r( )r� r� N) r@ rA rB rC rD �DEFAULT_MAX_ATTEMPTSr1 rx rE r4 r( r& r r � s � �� %9� �$>r( r c � � \ rS rSrS rS rSrg)r� i� c � � Xl g r, �� _checkers)r0 �checkerss r& r1 �OrRetryChecker.__init__� s � �!�r( c �B ^� [ U4S jU R 5 5 $ )Nc 3 �D ># � U H oR T5 v � M g 7fr, )rx )�.0�checkerr> s �r& � <genexpr>�.OrRetryChecker.is_retryable.<locals>.<genexpr>� s �� � �O��W�'�'��0�0��s � )�anyr� ry s `r& rx �OrRetryChecker.is_retryable� s �� ��O����O�O�Or( r� Nr� r4 r( r& r� r� � s � �"�Pr( r� c �@ � \ rS rSrSrSrSr\\4r S r S r S r S r S rg ) r i� � r� � c � � Xl S U l g r, )�_quota�_last_amount_acquired)r0 r s r& r1 �RetryQuotaChecker.__init__� s � �� �%)��"r( c �� � U R U5 ( a U R nO U R nU R R U5 nU( a X!R S' gUR SS9 g)N�retry_quota_capacityT)�RetryQuotaReachedF)�_is_timeout_error�_TIMEOUT_RETRY_REQUEST� _RETRY_COSTr �acquirerR rk )r0 r> �capacity_amount�successs r& r7 �%RetryQuotaChecker.acquire_retry_quota� si � � � !� !�'� *� *� "� 9� 9�O� "� .� .�O��+�+�%�%�o�6�� � ?N� #� #�$:� ;���"�"�T�"�:�r( c �B � [ UR U R 5 $ r, )re rL �_TIMEOUT_EXCEPTIONSry s r& r �#RetryQuotaChecker._is_timeout_error� s � ��'�2�2�D�4L�4L�M�Mr( c �� � Uc g UR nSUs=:: a S: aP O g SU; a& U R R U R 5 g US nU R R U5 g g )N�� i, r )r� r �release�_NO_RETRY_INCREMENT)r0 r> rP r< r� r s r& r �%RetryQuotaChecker.release_retry_quota sg � � � � �#�/�/� � �+� #�� #�%�W�4�� � �#�#�D�$<�$<�=�")�*@�"A��� � �#�#�O�4� $r( )r r N)r@ rA rB rC r r r r r r r1 r7 r r rE r4 r( r& r r � s4 � ��K��� ��.�0@�A��*� � N�5r( r )!rD �loggingr� �botocore.exceptionsr r r r �botocore.retriesr r �botocore.retries.baser r r� � getLoggerr@ r9 r' r r! rS r r r� r� r� r� r� r� r r� r r4 r( r& �<module>r s� ���4 � �� � ,� H�� � � � �8� $�� 1E� �6!� !�H-� -�fP+� P+�f 9� 9� �)� �:"�-� "�")� 4� )�X G� 4� G�> K� 2� K�"0� "0�J K� K� >� 2� >�BP�)� P�55� 55r(
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка