Skip to content
Snippets Groups Projects
Commit 170a719c authored by Piotr Maślanka's avatar Piotr Maślanka
Browse files

v2.17.10

parent 3e8b0f48
No related branches found
No related tags found
No related merge requests found
__version__ = '2.17.10a1'
__version__ = '2.17.10'
from ..exceptions import WouldWaitMore
from concurrent.futures._base import Future
import typing as tp
import time
import copy
import inspect
import warnings
from concurrent.futures import Future
from functools import wraps # import from functools to prevent circular import exception
TimeSignal = tp.Callable[[], float]
......
import copy
import inspect
import time
import typing as tp
import warnings
from concurrent.futures import Future
from functools import wraps # import from functools to prevent circular import exception
__all__ = ['measure', 'time_as_int', 'time_ms', 'sleep', 'time_us', 'ExponentialBackoff',
'parse_time_string']
__all__ = ['time_as_int', 'time_ms', 'sleep', 'time_us', 'ExponentialBackoff']
from satella.coding.concurrent.thread import Condition
from satella.exceptions import WouldWaitMore
from .parse import parse_time_string
from .measure import measure
def sleep(y: tp.Union[str, float], abort_on_interrupt: bool = False) -> bool:
......@@ -141,8 +137,6 @@ class ExponentialBackoff:
:param timeout: maximum amount of seconds to wait. If waited more than that,
WouldWaitMore will be raised
:param sleep_function: a function which will be called with a single argument,
the number of seconds to sleep. This should sleep by that many seconds.
:raises WouldWaitMore: waited for timeout and service still was not healthy
"""
with measure(timeout=timeout) as m:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment