code: def test_create_timeout():
      _load_docker_env()
      api_client = k8s_config.new_client_from_config()
  
      cluster = None
      try:
          extra_vol_config = HostPathVolumeConfig(
              "mars-src-path", "/mnt/mars", MARS_ROOT
          )
          with pytest.raises(TimeoutError):
              cluster = new_cluster(
                  api_client,
                  image="pseudo_image",
                  supervisor_cpu=0.5,
                  supervisor_mem="1G",
                  worker_cpu=0.5,
                  worker_mem="1G",
                  extra_volumes=[extra_vol_config],
                  timeout=1,
              )
      finally:
          if cluster:
              cluster.stop(wait=True)
          _collect_coverage()
  
imports: import glob
  import os
  import shutil
  import subprocess
  import tempfile
  import uuid
  from contextlib import contextmanager
  from distutils.spawn import find_executable
  import numpy
  import pytest
  from ....None import tensor
  from ....tests.core import mock
  from ..None import new_cluster
  from ..config import HostPathVolumeConfig
label_desc: Use image node_id 7 for calling a global function with example usage: test_create_timeout() without return types