code: def __init__(self, *callbacks):
      self.callbacks = [normalize_ray_callback(c) for c in callbacks]
      RayDaskCallback.ray_active.update(self.callbacks)
  
imports: import contextlib
  from collections import namedtuple, defaultdict
  from datetime import datetime
  from dask.callbacks import Callback
label_desc: Use image node_id 1 to create a new add_ray_callbacks object  with example: obj = add_ray_callbacks()