Файловый менеджер - Редактировать - /opt/imh-python/lib/python3.9/site-packages/botocore/__pycache__/retryhandler.cpython-39.pyc
Ðазад
a p�h�5 � @ s$ d dl Z d dlZd dlZd dlmZ d dlmZmZmZm Z m Z e� e �Z de e eegiZdd� Zdd� Zd%d d �Zd&d d �Zd'd d�Zdd� Zdd� Zdd� ZG dd� de�ZG dd� de�ZG dd� de�ZG dd � d e�ZG d d � d e�Z G d d � d e�Z G d!d"� d"e�Z G d#d$� d$e�Z dS )(� N)�crc32)� ChecksumError�EndpointConnectionError�ReadTimeoutError�ConnectionError�ConnectionClosedErrorZGENERAL_CONNECTION_ERRORc C s: | dkrt � � } n| dkr&td| ��| ||d }|S )a1 Calculate 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. Zrandr z0The 'base' param must be greater than 0, got: %s� )�random� ValueError)�base� growth_factor�attemptsZ time_to_sleep� r ��/root/rpmbuild/BUILDROOT/imh-python39-modules-3.9.7-92.el8.x86_64/opt/imh-python/lib/python3.9/site-packages/botocore/retryhandler.py�delay_exponential' s �r c C s t jt| |d�S )z�Create an exponential delay function based on the attempts. This is used so that you only have to pass it the attempts parameter to calculate the delay. �r r )� functools�partialr r r r r �!create_exponential_delay_function= s �r c C s$ t | |d�}t| |d�}t||d�S )N)�operation_name)�checker�action)� create_checker_from_retry_config� create_retry_action_from_config� RetryHandler)�configr r r r r r �create_retry_handlerH s ��r c C s0 | d d }|d dkr,t |d |d d�S d S )N� __default__�delay�typeZ exponentialr r r )r )r r Z delay_configr r r r P s �r c C s g }d }g }d| v rj| d � dg �}| d d }|D ]4}|| }|�t|�� t|�}|d ur4|�|� q4|d ur�| � |�d ur�| | d } | D ]4}|�t| | �� t| | �}|d ur�|�|� q�t|�dkr�t|d |d�S t|�} t| |t|�d�S d S )Nr �policies� max_attemptsr r )r! )r! �retryable_exceptions) �get�append�_create_single_checker� _extract_retryable_exception�extend�len�MaxAttemptsDecorator� MultiChecker�tuple) r r �checkersr! r" r �keyZcurrent_configZretry_exceptionZoperation_policiesZ multi_checkerr r r r \ s8 � �r c C s2 d| d v r t | d d �S d| d v r.t� S d S )N�response� applies_when� socket_errors)� _create_single_response_checker�ExceptionRaiser)r r r r r% { s � r% c C s^ d| v r t | d | d d�}n<d| v r6t| d d�}n$d| v rNt| d d�}n tdt ��|S )NZservice_error_codeZhttp_status_code)� status_code� error_code)r3 � crc32body)�headerzUnknown retry policy: %s)�ServiceErrorCodeChecker�HTTPStatusCodeChecker� CRC32Checkerr r )r. r r r r r1 � s �� r1 c C sN | d }d|� di �v r tgS d|v rJg }|d D ]}|�t| � q2|S d S )Nr/ r5 r. r0 )r# r r' � EXCEPTION_MAP)r r/ � exceptions�namer r r r& � s r& c @ s e Zd ZdZdd� Zdd� ZdS )r a� Retry 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. c C s || _ || _d S �N)�_checker�_action)�selfr r r r r �__init__� s zRetryHandler.__init__c K s8 | � |||�r*| j|d�}t�d|� |S t�d� dS )z�Handler for a retry. Intended to be hooked up to an event handler (hence the **kwargs), this will process retries appropriately. )r zRetry needed, action of: %szNo retry needed.N)r> r? �logger�debug)r@ r r. �caught_exception�kwargs�resultr r r �__call__� s zRetryHandler.__call__N)�__name__� __module__� __qualname__�__doc__rA rG r r r r r � s r c @ s( e Zd ZdZdd� Zdd� Zdd� ZdS ) � BaseCheckerz�Base class for retry checkers. Each class is responsible for checking a single criteria that determines whether or not a retry should not happen. c C s4 |dur| � ||�S |dur(| �||�S td��dS )a� Determine 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. Nz,Both response and caught_exception are None.)�_check_response�_check_caught_exceptionr )r@ �attempt_numberr. rD r r r rG � s �zBaseChecker.__call__c C s d S r= r �r@ rO r. r r r rM � s zBaseChecker._check_responsec C s d S r= r �r@ rO rD r r r rN � s z#BaseChecker._check_caught_exceptionN)rH rI rJ rK rG rM rN r r r r rL � s rL c @ s* e Zd ZdZd dd�Zdd� Zdd� ZdS ) r) a� 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 C s || _ || _|| _d S r= )r> � _max_attempts�_retryable_exceptions)r@ r r! r" r r r rA � s z MaxAttemptsDecorator.__init__c C s^ | � |||�}|rV|| jkrP|d ur@d|d v r@d|d d d< t�d|� dS |S ndS d S )NZResponseMetadatar TZMaxAttemptsReachedz0Reached the maximum number of retry attempts: %sF)� _should_retryrR rB rC )r@ rO r. rD Z should_retryr r r rG � s � �z MaxAttemptsDecorator.__call__c C sn | j r\|| jk r\z| �|||�W S | j yX } z tjd|dd� W Y d }~dS d }~0 0 n| �|||�S d S )Nz,retry needed, retryable exception caught: %sT)�exc_info)rS rR r> rB rC )r@ rO r. rD �er r r rT s ��z"MaxAttemptsDecorator._should_retry)N)rH rI rJ rK rA rG rT r r r r r) � s r) c @ s e Zd Zdd� Zdd� ZdS )r8 c C s || _ d S r= )� _status_code)r@ r3 r r r rA s z HTTPStatusCodeChecker.__init__c C s* |d j | jkr"t�d| j� dS dS d S )Nr z5retry needed: retryable HTTP status code received: %sTF)r3 rW rB rC rP r r r rM s �z%HTTPStatusCodeChecker._check_responseN�rH rI rJ rA rM r r r r r8 s r8 c @ s e Zd Zdd� Zdd� ZdS )r7 c C s || _ || _d S r= )rW � _error_code)r@ r3 r4 r r r rA ' s z ServiceErrorCodeChecker.__init__c C sJ |d j | jkrF|d �di ��d�}|| jkrFt�d| j| j� dS dS )Nr r �ErrorZCodez>retry needed: matching HTTP status and error code seen: %s, %sTF)r3 rW r# rY rB rC )r@ rO r. Zactual_error_coder r r rM + s �z'ServiceErrorCodeChecker._check_responseNrX r r r r r7 & s r7 c @ s e Zd Zdd� Zdd� ZdS )r* c C s || _ d S r= �Z _checkers)r@ r, r r r rA 7 s zMultiChecker.__init__c C s( | j D ] }||||�}|r| S qdS )NFr[ )r@ rO r. rD r Zchecker_responser r r rG : s � zMultiChecker.__call__N)rH rI rJ rA rG r r r r r* 6 s r* c @ s e Zd Zdd� Zdd� ZdS )r9 c C s || _ d S r= )� _header_name)r@ r6 r r r rA D s zCRC32Checker.__init__c C st |d }|j �| j�}|d u r.t�d| j� nBt|d j�d@ }|t|�kspt�dt|�|� tdt|�|d��d S )Nr z?crc32 check skipped, the %s header is not in the http response.l �� z>retry needed: crc32 check failed, expected != actual: %s != %sr )Z checksum_typeZexpected_checksumZactual_checksum) �headersr# r\ rB rC r �content�intr )r@ rO r. � http_responseZ expected_crcZ actual_crc32r r r rM H s � ��z CRC32Checker._check_responseNrX r r r r r9 C s r9 c @ s e Zd ZdZdd� ZdS )r2 z`Raise any caught exceptions. This class will raise any non None ``caught_exception``. c C s |�d S r= r rQ r r r rN _ s z'ExceptionRaiser._check_caught_exceptionN)rH rI rJ rK rN r r r r r2 Y s r2 )N)N)N) r r �logging�binasciir Zbotocore.exceptionsr r r r r � getLoggerrH rB r: r r r r r r% r1 r& �objectr rL r) r8 r7 r* r9 r2 r r r r �<module> s4 �� ,.
| ver. 1.1 | |
.
| PHP 8.3.30 | Ð“ÐµÐ½ÐµÑ€Ð°Ñ†Ð¸Ñ Ñтраницы: 0 |
proxy
|
phpinfo
|
ÐаÑтройка