Attend the Women in ML Symposium on December 7 Register now

tff.async_utils.OrderedTasks

A group of asynchronous tasks to be run sequentially.

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

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

add

View source

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

add_all

View source

Add awaitables run concurrently after previous tasks have completed.

add_callable

View source

Add function to run after previous tasks have completed.

wait

View source

Waits for all previously-scheduled tasks to complete.