code: def _launch_workers(func, args=(), n_workers=N_WORKERS):
      processes = []
      # TODO catch exceptions
      for rank in range(n_workers):
          p = ExceptionAwareProcess(target=func, args=(rank,) + args)
          p.start()
          processes.append(p)
  
      for p in processes:
          p.join()
  
imports: import sys
  import time
  import warnings
  import cupy
  from cupy import cuda
  from cupy.cuda import nccl
  from cupy import testing
  from cupyx.distributed import init_process_group
  from cupyx.distributed._nccl_comm import NCCLBackend
  from cupyx.distributed._store import ExceptionAwareProcess
  from cupyx.scipy import sparse
label_desc: Use image node_id 1 for calling a global function with example usage: _launch_workers(func, args, n_workers) without return types