Class TaskStreamPlugin

Declaration

class TaskStreamPlugin(SchedulerPlugin)

▷ def __init__(self, scheduler, maxlen=None)
source link
▷ def collect(self, start=None, stop=None, count=None)
source link
▷ def rectangles(self, istart, istop=None, workers=None, start_boundary=0)
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.
```