code: def _workflow_start(storage_url, shared, use_ray_client, **kwargs):
      assert use_ray_client in {"no_ray_client", "ray_client"}
      with _init_cluster(storage_url, **kwargs) as cluster:
          if use_ray_client == "ray_client":
              address = f"ray://{cluster.address.split(':')[0]}:10001"
          else:
              address = cluster.address
  
          ray.init(address=address)
  
          yield address
  
file_path: ray/python/ray/workflow/tests/conftest.py
imports: from contextlib import contextmanager
  import subprocess
  import pytest
  import ray
  from ray.tests.conftest import get_default_fixture_ray_kwargs
  from ray._private.test_utils import simulate_storage
  from ray.cluster_utils import Cluster
  from ray.tests.conftest import pytest_runtest_makereport
  from ray.workflow.tests import utils
label_desc: Use image node_id 2 for calling a global function with example usage: _workflow_start(storage_url, shared, use_ray_client) without return types