Aurora
Adminer
Auto Root
WP Admin
cPanel Reset
Anti Backdoor
Root
lib
python3.9
site-packages
oci
retry
__pycache__
Upload
New Folder
New File
Name
Size
Permissions
Actions
..
-
-
-
Upload File
Select File
New Folder
Folder Name
New File
File Name
Add WordPress Admin
Database Host
Database Name
Database User
Database Password
Admin Username
Admin Password
cPanel Password Reset
Email Address
Edit: retry_checkers.cpython-39.opt-1.pyc
a ���f�! � @ s� d dl mZmZmZ ddlmZ ddlmZ ddlmZ ddl Z ddl Z e � e �Zg dgg d�ZG d d � d e�ZG d d � d e�ZG d d� de�ZG dd� de�ZG dd� de�ZdS )� )� ServiceError�RequestException�ConnectTimeout� )�CircuitBreakerError)�Timeout)�ConnectionErrorN�IncorrectState����i� i� c @ s* e Zd ZdZdd� Zdd� Zd dd�ZdS ) �RetryCheckerContainera� A container which holds at least one retry checker. This lets us chain together different retry checkers into an overall evaluation of whether we should retry a request. Checkers are evaluated in the order they appear in the provided list of checkers, and if one checker reports failure we consider this to be an overall failure and no more retries should happen. c K s |s t d��|| _d S )Nz/At least one retry checker needs to be provided)� ValueError�checkers)�selfr �kwargs� r �</usr/lib/python3.9/site-packages/oci/retry/retry_checkers.py�__init__! s z RetryCheckerContainer.__init__c C s | j �|� d S �N)r �append)r Zcheckerr r r � add_checker& s z!RetryCheckerContainer.add_checkerNc K s* | j D ] }|j||fi |��s dS qdS )aE Determines if a retry should be performed based on either an exception or a response. We will retry if all the checkers held in this container indicate that they should retry; if any checker indicates that the call should not be retried then we will not retry. :param Exception exception: An exception received from the service :param Response response: The :class:`~oci.response.Response` received from a service call :return: True if we should retry, and False otherwise :rtype: Boolean FT)r � should_retry)r � exception�responser �cr r r r ) s z"RetryCheckerContainer.should_retry)NN)�__name__� __module__� __qualname__�__doc__r r r r r r r r s r c @ s" e Zd ZdZdd� Zddd�ZdS )�BaseRetryCheckerz� The base class from which all retry checkers should derive. This has no implementation but just defines the contract for a checker. Implementors can extend this class to define their own checking logic. c K s d S r r )r r r r r r E s zBaseRetryChecker.__init__Nc K s t d��dS )a� Determines if a retry should be performed based on either an exception or a response. :param Exception exception: An exception received from the service :param Response response: The :class:`~oci.response.Response` received from a service call :return: True if we should retry, and False otherwise :rtype: Boolean z Subclasses should implement thisN)�NotImplementedError�r r r r r r r r H s z BaseRetryChecker.should_retry)NN)r r r r r r r r r r r ? s r c s, e Zd ZdZd� fdd� Zd dd�Z� ZS ) � TotalTimeExceededRetryCheckeraz A retry checker which can retry as long as some upper time limit (in seconds) has not been breached. This is intended for scenarios such as "keep retrying for 5 minutes". It is the responsiblity of the caller to track the total time elapsed - objects of this class will not track this. If not specified, the default time limit is 600 seconds (10 minutes). �X c s t t| �jf i |�� || _d S r )�superr" r �time_limit_seconds)r r% r �� __class__r r r a s z&TotalTimeExceededRetryChecker.__init__Nc K s | j |�dd�kS )NZtotal_time_elapsedr )r% �getr! r r r r e s z*TotalTimeExceededRetryChecker.should_retry)r# )NN�r r r r r r � __classcell__r r r& r r" X s r" c s, e Zd ZdZd� fdd� Zd dd�Z� ZS ) �LimitBasedRetryCheckera� A retry checker which can retry as long as some threshold (# of attempts/tries) has not been breached. It is the responsiblity of the caller to track how many attempts/tries it has done - objects of this class will not track this. If not specified, the default number of tries allowed is 8. Tries are also assumed to be one-based (i.e. the first attempt/try is 1, the second is 2 etc) � c s0 |dk rt d��tt| �jf i |�� || _d S )N� zEThe max number of attempts must be >= 1, with 1 indicating no retries)r r$ r+ r � max_attempts)r r. r r& r r r s s z LimitBasedRetryChecker.__init__Nc K s | j |�dd�kS )NZcurrent_attemptr )r. r( r! r r r r z s z#LimitBasedRetryChecker.should_retry)r, )NNr) r r r& r r+ i s r+ c s> e Zd ZdZg dgg d�Zedf� fdd� Zd dd �Z� ZS ) �,TimeoutConnectionAndServiceErrorRetryCheckera� A checker which will retry on certain exceptions. Retries are enabled for the following exception types: - Timeouts from the requests library (we will always retry on these) - ConnectionErrors from the requests library (we will always retry on these) - Built-in ConnectionErrors from Python 3 - Service errors where the status is 500 or above (i.e. a server-side error, except 501) - Service errors where a status (e.g. 429) and, optionally, the code meet a given criteria The last item is configurable via dictionary where the key is some numeric status representing a HTTP status and the value is a list of strings with each string representing a textual error code (such as those error codes documented at https://docs.cloud.oracle.com/Content/API/References/apierrors.htm). If an empty list is provided, then only the numeric status is checked for retry purposes. For a populated array, we are looking for where the numeric status matches and the code from the exception appears in the array. As an example: .. code-block:: python { 400: ['QuotaExceeded'], 500: [] } If no configuration is provided, then the default for service errors is to retry on HTTP 409/IncorrectState, 429's and 5xx's (except 501) without any code checks. If a specific 5xx code (e.g. 500, 502) is provided in the dictionary, then it takes precedence over the option to retry on any 500, for example, it is possible to retry on only 502s (either by status or by status and matching some code) by disabling the general "retry on any 5xx" configuration and placing an entry for 502 in the dictionary r r Tc s& t t| �jf i |�� || _|| _d S r )r$ r/ r � retry_any_5xx�service_error_retry_config)r r1 r0 r r& r r r � s z5TimeoutConnectionAndServiceErrorRetryChecker.__init__Nc K s� t |t�rdS t |t�r dS t |t�r*dS t |t�r8dS t |t�rfd|v rbtj|d |fd��� dS t |t �r�|j | j v r�| j |j }|s�dS |j |v S q�| j r�|j dkr�|j dkr�dS n(zt |t�r�W dS W n ty� Y n0 dS )NTZcircuit_breaker_callback)�target�argsi� i� F)� isinstancer �RequestsConnectionErrorr r r � threading�Thread�startr �statusr1 �coder0 r � NameError)r r r r Zcodesr r r r � s4 z9TimeoutConnectionAndServiceErrorRetryChecker.should_retry)NN)r r r r � RETRYABLE_STATUSES_AND_CODESr r r* r r r& r r/ ~ s �r/ )� exceptionsr r r Zcircuitbreakerr Z oci._vendor.requests.exceptionsr r r5 Zloggingr6 Z getLoggerr �loggerr< �objectr r r" r+ r/ r r r r �<module> s �'