Class CollectTaskMetaDataPlugin

Declaration

class CollectTaskMetaDataPlugin(SchedulerPlugin)

▷ def __init__(self, scheduler, name)
source link
▶ def transition(self, key, start, finish, *args, **kwargs) override
inherited doc Run whenever a task changes state
source link
This method overrides distributed.diagnostics.plugin.SchedulerPlugin.transition.
Parameters
- key : string
- start : string
```
Start state of the transition.
One of released, waiting, processing, memory, error.
```
- finish : string
```
Final state of the transition.
```
- *args, **kwargs : More options passed when transitioning
```
This may include worker ID, compute time, etc.
```
▶ def update_graph(self, scheduler, dsk=None, keys=None, restrictions=None, **kwargs) override
inherited doc Run when a new graph / tasks enter the scheduler
source link
This method overrides distributed.diagnostics.plugin.SchedulerPlugin.update_graph.