Class EventStream

distributed.diagnostics.eventstream.EventStream

Maintain a copy of worker events

Declaration

class EventStream(SchedulerPlugin)

Documentation

Methods

▷ def __init__(self, scheduler=None)
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.
```

Inherited methods

Methods inherited from distributed.diagnostics.plugin.SchedulerPlugin:
add_client, add_worker, remove_client, remove_worker, restart, update_graph

Reexports

Imported in distributed.diagnostics.tests.test_eventstream.