Class GroupProgress

Keep track of all keys, grouped by key_split

Declaration

class GroupProgress(SchedulerPlugin)

▷ def __init__(self, scheduler)
source link
▷ def create(self, key, k)
source link
▶ def restart(self, scheduler) override
inherited doc Run when the scheduler restarts itself
source link
This method overrides distributed.diagnostics.plugin.SchedulerPlugin.restart.
▶ 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.
```