Waiter¶
The @concurrently() returns special object Waiter to control the
running functions, like a wait until complete, stop and other.
-
class
concurrently.engines.AbstractWaiter¶ -
__call__(*, suppress_exceptions: bool = False, fail_hard: bool = False)¶ The call blocks until the completion of all concurrent functions.
All exceptions in concurrent functions are captured and re-raise as
UnhandledExceptions.You can customize this behavior with following options:
Parameters: - suppress_exceptions – don’t raise
UnhandledExceptions - fail_hard – stop all functions and raise error if one of function abort with error
- suppress_exceptions – don’t raise
-
exceptions() → List[Exception]¶ Returns list of all exception.
Useful with option
suppress_exceptions.
-
stop()¶ Interrupts execution functions.
-