⚝
One Hat Cyber Team
⚝
Your IP:
216.73.216.159
Server IP:
97.74.87.16
Server:
Linux 16.87.74.97.host.secureserver.net 5.14.0-503.38.1.el9_5.x86_64 #1 SMP PREEMPT_DYNAMIC Fri Apr 18 08:52:10 EDT 2025 x86_64
Server Software:
Apache
PHP Version:
8.2.28
Buat File
|
Buat Folder
Eksekusi
Dir :
~
/
var
/
opt
/
nydus
/
ops
/
primordial
/
__pycache__
/
View File Name :
flow.cpython-39.pyc
a ���g� � @ s� d dl Z d dlmZ d dlmZmZmZmZmZ dZ dZ e � e �Z G dd� de�Zdeeeeed �d d �Zdd d� e efeeeeeee eee f ed�dd�ZdS )� N)�sleep)�Any�Callable�Tuple�Type�Uniong �?� c @ s e Zd ZdZdS )� RetryErrorz9A special type which signals the failure of a retry loop.N)�__name__� __module__� __qualname__�__doc__� r r �@/opt/nydus/tmp/pip-target-mke_irhy/lib/python/primordial/flow.pyr s r � � �?)� test_function� max_tests� sleep_secs� count_trues�returnc C s~ d}d}d}||kr"t �d� |}||k r\| � }|du rJ|d7 }||krJq\|d7 }t|� q"||k rttd|| f ��|||fS )a� Attempt test_function over and over, waiting for a true value. Try a maximum of max_tests times. Sleep sleep_secs in between each test. Receive count_trues before moving on. wait_for_true is designed specifically to handle a design principle behind AWS or other clustered services: that you might succeed when making a request once and then fail very soon after. For example, when you make a REST API call against S3 to see if a bucket exists, the fact that you get a "True" response does not guarantee that you will get that same response to a request made very soon after. In other words, it's for cases in which the goal is to produce a wait time for an eventually consistent external service to resolve your request. That's why wait_for_true lets you specify a threshold of how many trues you want to get before you're satisfied. :param test_function: a function to run whose result we will test for truthiness :param max_tests: limit to how many times we'll try test_function :param sleep_secs: how long to wait between tests :param count_trues: how many true results we need until we're totally true; this is useful with e.g. cluster tests, where we want a quorum of true answers before we're happy that the entire cluster is consistent (e.g. s3 put) :returns: the return value of the test function, the number of time it tried, and how many true results it found :raises RetryError: if the function "never" returned sufficiently many trues r Nz9count_trues > max_tests, bumping max_tests to count_truesT� z6wait_for_true never succeeded %s times for function %s)�LOGGER�warningr r )r r r r Z itercount�retZtruesr r r � wait_for_true s" r c C s | t S )N)�DELAY_INCREASE_SECS)�xr r r �<lambda>< � r )�action_functionr �backoff� max_attempts�exceptions_to_ignorer c C s� d}||k r�z| � W S |y� } zV|d7 }||krJt d| t|�f �|�t�d|| t|�� t|� ||�}W Y d}~qd}~0 0 qdS )a� Retry an e.g. network connection until it doesn't throw an exception of any kind. This is for single-success retry cases (e.g. wow, that TCP connection didn't get established because of high latency, let's dial back and try again in a bit). The action_function is expected to be of a sort that any expected exceptions are caught, as this will retry under /any/ exception. The return value, if any, from the action_function is returned by retry on success. sleep_secs is the number of seconds to sleep between failures, and backoff defaults to adding DELAY_INCREASE_SECS to the prior value each time. max_attempts is the limit of the number of retries in any case. On failure to complete the action_function without exception, raises RetryError. :param action_function: a function to run that we will retry if it raises any exception :param sleep_secs: how long to wait between tries :param backoff: a function that will expand the sleep duration based on what iteration we are on :param max_attempts: limit to how many times we'll try action_function :param exceptions_to_ignore: exception type or types to ignore; by default, ignores all Exception-derived exceptions :returns: the return value of the test function, the number of time it tried, and how many true results it found :raises RetryError: if the function "never" returned without an exception r r zFailure to retry %s: %sz.retry: pausing %s secs before retrying %s (%s)N)r �strr �debugr )r r r! r" r# Zattempts�er r r �retry: s r' )r r r )�logging�timer �typingr r r r r r Z MAX_RETRIES� getLoggerr r � Exceptionr �int�floatr r' r r r r �<module> s" *��