code: def _init_dask_client(args):
      _workaround_multiprocessing_cycle()
      try:
          from dask.distributed import Client, LocalCluster
      except ImportError as e:
          raise SystemExit(
              "dask.distributed not available - "
              "install it first using 'pip install dask[distributed]'"
          ) from e
      else:
          dashboard_address = _dashboard_address(args)
          resources = _cluster_resources(args)
          log.info(
              "Initializing Dask cluster%s",
              _workers_log_entry_suffix(args),
          )
          cluster = LocalCluster(
              n_workers=1,
              threads_per_worker=args.workers,
              processes=False,
              silence_logs=_dask_loglevel(args),
              dashboard_address=dashboard_address,
              resources=resources,
          )
          dashboard_disabled = dashboard_address is None
          client = Client(cluster)
          return client, dashboard_disabled, resources
  
imports: import argparse
  import logging
  import time
  from guild import _api
  from guild import util
  from .None import gen_queue
label_desc: Use image node_id 4 for calling a global function with example usage: _init_dask_client(args) and returns: client,  dashboard_disabled,  resources