code: def create_dask_client(scheduler_address):
      from cugraph.dask.comms import comms as Comms
  
      client = Client(scheduler_address)
      Comms.initialize(p2p=True)
      return client
  
file_path: cugraph/python/cugraph-dgl/examples/multi_trainer_MG_example/workflow.py
imports: import dgl
  import torch
  import time
  from distributed import Client, Event
  import tempfile
  from cugraph.dask.comms import comms
label_desc: Use image node_id 3 for calling a global function with example usage: create_dask_client(scheduler_address) and returns: client