Class get_task_metadata

distributed.client.get_task_metadata

Collect task metadata within a context block

Declaration

class get_task_metadata

Documentation

This gathers ``TaskState`` metadata and final state from the scheduler
for tasks which are submitted and finished within the scope of this
context manager.

Examples

>>> with get_task_metadata() as tasks:
...     x.compute()
>>> tasks.metadata
{...}
>>> tasks.state
{...}

Methods

▷ def __enter__(self)
source link
▷ def __exit__(self, typ, value, traceback)
source link
▷ def __init__(self)
source link

Reexports

Imported in distributed.tests.test_client.
Imported in distributed.