code: def test_connecting_to_cluster(shutdown_only, storage_type):
      with simulate_storage(storage_type) as storage_uri:
          try:
              subprocess.check_call(
                  ["ray", "start", "--head", "--storage", storage_uri]
              )
              ray.init(address="auto")
              from ray._private.storage import _storage_uri
  
              # make sure driver is using the same storage when connecting to a cluster
              assert _storage_uri == storage_uri
          finally:
              subprocess.check_call(["ray", "stop"])
  
imports: import os
  import sys
  import subprocess
  import urllib
  from pathlib import Path
  from packaging.version import parse
  import pyarrow.fs
  import pytest
  import ray
  import ray._private.storage
  from ray._private.test_utils import simulate_storage
  from ray._private.utils import _add_creatable_buckets_param_if_s3_uri, _get_pyarrow_version
  from ray.tests.conftest import *
label_desc: Use image node_id 14 for calling a global function with example usage: test_connecting_to_cluster(shutdown_only, storage_type) without return types