| Server IP : 74.91.139.10 / Your IP : 10.45.147.122 Web Server : Apache/2.4.67 (Unix) System : Linux prod-iad-shwpweb1001f 5.14.0-687.26.1.el9_8.x86_64 #1 SMP PREEMPT_DYNAMIC Tue Jul 14 16:32:02 EDT 2026 x86_64 User : FAsyXTyKGY ( 3004) PHP Version : 8.2.30 Disable Function : passthru,shell_exec,system MySQL : ON | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : ON Directory : /usr/libexec/oracle-cloud-agent/plugins/osms/ |
Upload File : |
a
ٓ�f�( � @ s8 d dl mZ d dl mZ d dl mZ d dl mZ d dlmZ d dlmZmZ d dl m
Z
m Z d dl m
Z
mZ d d lmZmZ zd d
lmZ W n ey� d d
lmZ Y n0 z
efZW n ey� eefZY n0 d Zd Zd
Z dd� Z dd� Z G dd� de �Z G dd� de!�Z"G dd� de �Z#ddddde fdd�Z$dS )� )�unicode_literals)�division)�print_function)�absolute_import)�wraps)�datetime� timedelta)�isgeneratorfunction�isclass)�AnyStr�Iterable)�ceil�floor)� monotonic�closed�open� half_openc s � fdd�}|S )zOBuild a predicate function that checks if an exception is a subtype from a listc s
t | � �S �N)�
issubclass)� thrown_type�_�� exc_types� �r/sparta/input/_build_configuration/image_build+validate/lib/bmcenv/lib64/python3.9/site-packages/circuitbreaker.py�
matches_types s z(in_exception_list.<locals>.matches_typesr )r r r r r �in_exception_list s r c C sv t | �r t| t�r t| �}nVz&t| � t| t�r8td��t| � }W n. typ t | �r`t | �rhtd��| }Y n0 |S )az Build a failure predicate_function.
The returned function has the signature (Type[Exception], Exception) -> bool.
Return value True indicates a failure in the underlying function.
:param expected_exception: either an type of Exception, iterable of Exception types, or a predicate function.
If an Exception type or iterable of Exception types, the failure predicate will return True when a thrown
exception type matches one of the provided types.
If a predicate function, it will just be returned as is.
:return: callable (Type[Exception], Exception) -> bool
z9expected_exception cannot be a string. Did you mean name?z1expected_exception does not look like a predicate)
r
r � Exceptionr �iter�
isinstance� STRING_TYPES�
ValueError� TypeError�callable)�expected_exception�failure_predicater r r �build_failure_predicate& s
r& c @ s� e Zd ZdZdZeZdZd*dd�Zdd� Z dd � Z
d
d � Z d d
� Z dd� Z
dd� Zdd� Zdd� Zedd� �Zedd� �Zedd� �Zed d � �Zed d � �Zed d!� �Zed"d#� �Zed$d%� �Zed&d'� �Zd(d)� ZdS )+�CircuitBreaker� � Nc C s� d| _ d| _|p| j| _|p | j| _|sTzt| �jd }W n tyR t j
}Y n0 t |�| _ |pf| j
| _|| _t| _t� | _dS )a�
Construct a circuit breaker.
:param failure_threshold: break open after this many failures
:param recovery_timeout: close after this many seconds
:param expected_exception: either an type of Exception, iterable of Exception types, or a predicate function.
:param name: name for this circuitbreaker
:param fallback_function: called when the circuit is opened
:return: Circuitbreaker instance
:rtype: Circuitbreaker
Nr �EXPECTED_EXCEPTION)�
_last_failure�_failure_count�FAILURE_THRESHOLD�_failure_threshold�RECOVERY_TIMEOUT�_recovery_timeout�type�__dict__�KeyErrorr' r* r& �
is_failure�FALLBACK_FUNCTION�_fallback_function�_name� STATE_CLOSED�_stater �_opened)�self�failure_threshold�recovery_timeoutr$ �name�fallback_functionr r r �__init__N s
zCircuitBreaker.__init__c C s
| � |�S r )�decorate)r; �wrappedr r r �__call__y s zCircuitBreaker.__call__c C s d S r r �r; r r r � __enter__| s zCircuitBreaker.__enter__c C s, |r | � ||�r || _| �� n| �� dS )NF)r4 r+ � _CircuitBreaker__call_failed� _CircuitBreaker__call_succeeded)r; �exc_type� exc_value�
_tracebackr r r �__exit__ s
zCircuitBreaker.__exit__c sn �j du r2z �j�_ W n ty0 �j�_ Y n0 t��� t��rL�j� n�j� t ��� ��fdd��}|S )z;
Applies the circuit breaker to a function
Nc s: �j r$�jr �j| i |��S t���� �g| �R i |��S r )�openedr? �CircuitBreakerError)�args�kwargs��call�functionr; r r �wrapper� s
z(CircuitBreaker.decorate.<locals>.wrapper)
r7 � __qualname__�AttributeError�__name__�CircuitBreakerMonitor�registerr �call_generatorrQ r )r; rR rS r rP r rA � s
zCircuitBreaker.decoratec O s6 | � ||i |��W d � S 1 s(0 Y dS )z�
Calls the decorated function and applies the circuit breaker
rules on success or failure
:param func: Decorated function
Nr )r; �funcrN rO r r r rQ � s zCircuitBreaker.callc o sB | �* ||i |��D ]
}|V qW d � n1 s40 Y dS )z�
Calls the decorated generator function and applies the circuit breaker
rules on success or failure
:param func: Decorated generator function
Nr )r; rZ rN rO �elr r r rY � s z CircuitBreaker.call_generatorc C s t | _d| _d| _dS )zR
Close circuit after successful execution and reset failure count
Nr )r8 r9 r+ r, rD r r r �__call_succeeded� s z CircuitBreaker.__call_succeededc C s, | j d7 _ | j | jkr(t| _t� | _dS )zO
Count failure and open circuit, if threshold has been reached
� N)r, r. �
STATE_OPENr9 r r: rD r r r �
__call_failed� s z CircuitBreaker.__call_failedc C s | j tkr| jdkrtS | j S �Nr )r9 r^ �open_remaining�STATE_HALF_OPENrD r r r �state� s zCircuitBreaker.statec C s t �� t| jd� S )zq
The approximate datetime when the circuit breaker will try to recover
:return: datetime
)�seconds)r �utcnowr ra rD r r r �
open_until� s zCircuitBreaker.open_untilc C s* | j | j t� }|dkr"t|�S t|�S )zk
Number of seconds remaining, the circuit breaker stays in OPEN state
:return: int
r )r: r0 r r
r )r; �remainr r r ra � s z CircuitBreaker.open_remainingc C s | j S r )r, rD r r r �
failure_count� s z CircuitBreaker.failure_countc C s
| j tkS r )rc r8 rD r r r r � s zCircuitBreaker.closedc C s
| j tkS r )rc r^ rD r r r rL � s zCircuitBreaker.openedc C s | j S r �r7 rD r r r r> � s zCircuitBreaker.namec C s | j S r )r+ rD r r r � last_failure� s zCircuitBreaker.last_failurec C s | j S r )r6 rD r r r r? � s z CircuitBreaker.fallback_functionc O s | j S r ri �r; rN rO r r r �__str__� s zCircuitBreaker.__str__)NNNNN) rV �
__module__rT r- r/ r r* r5 r@ rC rE rK rA rQ rY rG rF �propertyrc rf ra rh r rL r> rj r? rl r r r r r' H sJ �
+
r' c s$ e Zd Z� fdd�Zdd� Z� ZS )rM c s t t| �j|i |�� || _dS )zf
:param circuit_breaker:
:param args:
:param kwargs:
:return:
N)�superrM r@ �_circuit_breaker)r; �circuit_breakerrN rO �� __class__r r r@ � s z CircuitBreakerError.__init__c O s* d| j j| j j| j jt| j j�| j jf S )NzMCircuit "%s" OPEN until %s (%d failures, %d sec remaining) (last_failure: %r))rp r> rf rh �roundra rj rk r r r rl s
�zCircuitBreakerError.__str__)rV rm rT r@ rl �
__classcell__r r rr r rM � s
rM c @ sX e Zd Zi Zedd� �Zedd� �Zedd� �Zedd� �Zed d
� �Z ed d � �Z
d
S )rW c C s || j |j< d S r )�circuit_breakersr> )�clsrq r r r rX s z CircuitBreakerMonitor.registerc C s t t| �� ��dkS r` )�len�list�get_open�rw r r r �
all_closed s z CircuitBreakerMonitor.all_closedc C s
| j �� S r )rv �valuesr{ r r r � get_circuits s z"CircuitBreakerMonitor.get_circuitsc C s | j �|�S r )rv �get)rw r> r r r r s zCircuitBreakerMonitor.getc c s | � � D ]}|jr|V qd S r )r~ rL �rw �circuitr r r rz % s z CircuitBreakerMonitor.get_openc c s | � � D ]}|jr|V qd S r )r~ r r� r r r �
get_closed, s z CircuitBreakerMonitor.get_closedN) rV rm rT rv � classmethodrX r| r~ r rz r� r r r r rW s
rW Nc C s* t | �r|� �| �S || ||||d�S d S )N)r< r= r$ r> r? )r# rA )r< r= r$ r> r? rw r r r r� 4 s �r� )%�
__future__r r r r � functoolsr r r �inspectr r
�typingr r �mathr
r �timer � ImportError�
basestringr � NameError�bytes�strr8 r^ rb r r& �objectr' r rM rW r� r r r r �<module> s@
" 3%�