Class WebsocketPlugin

Declaration

Methods

• ▷ def __init__(self, socket, scheduler)

  source link
• ▶ def add_client(self, scheduler=None, client=None, **kwargs) override

  Run when a new client connects

  source link

  This method overrides distributed.diagnostics.plugin.SchedulerPlugin.add_client.

• ▶ def add_worker(self, scheduler=None, worker=None, **kwargs) override

  Run when a new worker enters the cluster

  source link

  This method overrides distributed.diagnostics.plugin.SchedulerPlugin.add_worker.

• ▶ def remove_client(self, scheduler=None, client=None, **kwargs) override

  Run when a client disconnects

  source link

  This method overrides distributed.diagnostics.plugin.SchedulerPlugin.remove_client.

• ▶ def remove_worker(self, scheduler=None, worker=None, **kwargs) override

  Run when a worker leaves the cluster

  source link

  This method overrides distributed.diagnostics.plugin.SchedulerPlugin.remove_worker.

• ▶ def restart(self, scheduler, **kwargs) override

  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

  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, client=None, **kwargs) override

  Run when a new graph / tasks enter the scheduler

  source link

  This method overrides distributed.diagnostics.plugin.SchedulerPlugin.update_graph.

Generated by nedoc v0.9 at 2020-12-29 14:05