tff.async_utils.OrderedTasks

Stay organized with collections Save and categorize content based on your preferences.

A group of asynchronous tasks to be run sequentially.

tff.async_utils.OrderedTasks()

Newly added awaitables or functions will be added to a new task to be run as soon as all previously-scheduled tasks have completed.

Any exceptions encountered during the execution of an awaitable or task will be logged, and concurrent or subsequent tasks will continue to run unaffected.

Methods

aclose

View source

aclose()

Alias for wait to be used with Python 3.10+'s aclosing function.

add

View source

add(
    awaitable
)

Add an awaitable to run after previously-added tasks have completed.

add_all

View source

add_all(
    *awaitables
)

Add awaitables run concurrently after previous tasks have completed.

add_callable

View source

add_callable(
    function: Callable[[], None]
)

Add function to run after previous tasks have completed.

wait

View source

wait()

Waits for all previously-scheduled tasks to complete.