class_docstr: An extension for the scheduler to manage collections
  
  *  publish_list
  *  publish_put
  *  publish_get
  *  publish_delete
class_docstr_tok: ["An","extension","for","the","scheduler","to","manage","collections","*","publish_list","*","publish_put","*","publish_get","*","publish_delete"]
code: def __init__(self, scheduler):
      self.scheduler = scheduler
      self.datasets = dict()
  
      handlers = {
          "publish_list": self.list,
          "publish_put": self.put,
          "publish_get": self.get,
          "publish_delete": self.delete,
      }
  
      self.scheduler.handlers.update(handlers)
  
file_path: distributed/distributed/publish.py
imports: from __future__ import annotations
  from collections.abc import MutableMapping
  from dask.utils import stringify
  from distributed.utils import log_errors
label_desc: Use image node_id 1 to create a new PublishExtension object  with example: obj = PublishExtension(scheduler)