code: def cluster():
      cluster = LocalCUDACluster(
          protocol="tcp",
          scheduler_port=0,
          worker_class=IncreasedCloseTimeoutNanny,
      )
      yield cluster
      cluster.close()
  
file_path: cuml/python/cuml/benchmark/automated/dask/conftest.py
imports: import pytest
  from dask_cuda import initialize
  from dask_cuda import LocalCUDACluster
  from dask_cuda.utils_test import IncreasedCloseTimeoutNanny
  from dask.distributed import Client
label_desc: Use image node_id 1 for calling a global function with example usage: cluster() without return types