docstr: Run when a new graph / tasks enter the scheduler
docstr_tok: ["Run","when","a","new","graph","\/","tasks","enter","the","scheduler"]
code: def update_graph(self, scheduler, client=None, **kwargs):
      """Run when a new graph / tasks enter the scheduler"""
      self.socket.send("update_graph", {"client": client})
  
file_path: distributed/distributed/diagnostics/websocket.py
imports: from __future__ import annotations
  from dask.utils import key_split
  from distributed.diagnostics.plugin import SchedulerPlugin
  from distributed.diagnostics.task_stream import colors
label_desc: Use image node_id 7 for calling the WebsocketPlugin obj's underlying member method code with example usage: obj.update_graph(scheduler, client) without return types