File manager - Edit - /opt/saltstack/salt/lib/python3.10/site-packages/libcloud/utils/__pycache__/retry.cpython-310.pyc
Back
o ;j� � @ s� d dl Z d dlZd dlZd dlZd dlmZmZ d dlmZ d dlm Z d dl m Z ddgZ e� e�ZdZG d d � d e j�Zd Zd Zd Ze ejeje je jefZG d d� d�ZG dd� de�Z G dd� de �Z dS )� N)�datetime� timedelta��wraps)�httplib)�RateLimitReachedError�Retry� RetryForeverOnRateLimitErrorz The read operation timed outc @ s e Zd ZdZdS )�TransientSSLErrorz-Represent transient SSL errors, e.g. timeoutsN)�__name__� __module__� __qualname__�__doc__� r r �H/opt/saltstack/salt/lib/python3.10/site-packages/libcloud/utils/retry.pyr % s r � � c @ s, e Zd Zeeefdd�Zdd� Zdd� ZdS )� MinimalRetryc C sD |du rt }|du r t}|du rt}t|d�}|| _|| _|| _dS )a� Wrapper around retrying that helps to handle common transient exceptions. This minimalistic version only retries SSL errors and rate limiting. :param retry_delay: retry delay between the attempts. :param timeout: maximum time to wait. :param backoff: multiplier added to delay between attempts. :Example: retry_request = MinimalRetry(timeout=1, retry_delay=1, backoff=1) retry_request(self.connection.request)() Nr )� DEFAULT_DELAY�DEFAULT_TIMEOUT�DEFAULT_BACKOFF�max� retry_delay�timeout�backoff)�selfr r r r r r �__init__; s zMinimalRetry.__init__c �$ dd� �t � �� ��fdd��}|S )Nc _ �F z| |i |��W S t jy" } z tt|�v r t|j� �|�d }~ww �N��ssl�SSLError�TRANSIENT_SSL_ERROR�strr �args��functionr% �kwargs�excr r r �transform_ssl_error_ � ��z2MinimalRetry.__call__.<locals>.transform_ssl_errorc s� �j }t�� t�jd� }d }t�� |k rhz �� g| �R i |��W S tya } z4|}t|t�rFt� d� |j r;|j nd}t � |� �j }n�� |�rVt � |� |�j9 }n� W Y d }~nd }~ww t�� |k s|�)N��secondsz*You are being rate limited, backing off...� )r r �nowr r � Exception� isinstancer �_logger�debug� retry_after�time�sleep� should_retryr )r% r( � current_delay�end�last_excr) r4 ��funcr r* r r � retry_looph s* �� �z)MinimalRetry.__call__.<locals>.retry_loopr �r r< r= r r; r �__call__^ s zMinimalRetry.__call__c C s dS )NFr �r � exceptionr r r r7 � s zMinimalRetry.should_retryN) r r r r r r r r? r7 r r r r r : s �# -r c s. e Zd Zeeeef� fdd� Zdd� Z� Z S )r c s( t � j|||d� |du rt}|| _dS )a� Wrapper around retrying that helps to handle common transient exceptions. This version retries the errors that `libcloud.utils.retry:MinimalRetry` retries and all errors of the exception types that are given. :param retry_exceptions: types of exceptions to retry on. :param retry_delay: retry delay between the attempts. :param timeout: maximum time to wait. :param backoff: multiplier added to delay between attempts. :Example: retry_request = Retry(retry_exceptions=(httplib.NotConnected,), timeout=1, retry_delay=1, backoff=1) retry_request(self.connection.request)() )r r r N)�superr �RETRY_EXCEPTIONS�retry_exceptions)r rD r r r �� __class__r r r � s zRetry.__init__c C s t |t| j��S r )r1 �tuplerD r@ r r r r7 � s zRetry.should_retry) r r r rC r r r r r7 � __classcell__r r rE r r � s � c @ s e Zd ZdZdd� ZdS )r a� This class is only here for backward compatibility reasons with pre-Libcloud v3.3.2. If works by ignoring timeout argument and retrying forever until API is returning 429 RateLimitReached errors. In most cases using this class is not a good idea since it can cause code to hang and retry for ever in case API continues to return retry limit reached. c r )Nc _ r r r r& r r r r* � r+ zBRetryForeverOnRateLimitError.__call__.<locals>.transform_ssl_errorc s� �j }t�� t�jd� } z �� g| �R i |��W S ty` } z:t|t�r>t� |j � �j }t�� t|j �j d� }nt�� |krE� �� |�rUt� |� |�j 9 }n� W Y d }~nd }~ww q)Nr, ) r r r/ r r r0 r1 r r5 r6 r4 r7 r )r% r( r8 r9 r) r; r r r= � s& ���z9RetryForeverOnRateLimitError.__call__.<locals>.retry_loopr r> r r; r r? � s z%RetryForeverOnRateLimitError.__call__N)r r r r r? r r r r r � s ) r! r5 �socket�loggingr r � functoolsr Zlibcloud.utils.py3r Zlibcloud.common.exceptionsr �__all__� getLoggerr r2 r# r" r r r r �error�gaierror� NotConnected�ImproperConnectionStaterC r r r r r r r �<module> s6 � � U%
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings