Class WorkerStatusPlugin

An plugin to share worker status with a remote observer

Declaration

class WorkerStatusPlugin(SchedulerPlugin)

This is used in cluster managers to keep updated about the status of the
scheduler.

▷ def __init__(self, scheduler, comm)
source link
▶ def add_worker(self, worker=None, **kwargs) override
inherited doc Run when a new worker enters the cluster
source link
This method overrides distributed.diagnostics.plugin.SchedulerPlugin.add_worker.
▶ def remove_worker(self, worker=None, **kwargs) override
inherited doc Run when a worker leaves the cluster
source link
This method overrides distributed.diagnostics.plugin.SchedulerPlugin.remove_worker.
▷ def teardown(self)
source link