code: def test_run_in_kubernetes(use_test_docker_file):
      with _start_kube_cluster(
          supervisor_cpu=0.5,
          supervisor_mem="1G",
          worker_cpu=0.5,
          worker_mem="1G",
          worker_cache_mem="64m",
          extra_labels={"mars-test/group": "test-label-name"},
          extra_env={"MARS_K8S_GROUP_LABELS": "mars-test/group"},
          use_test_docker_file=use_test_docker_file,
      ):
          a = mt.ones((100, 100), chunk_size=30) * 2 * 1 + 1
          b = mt.ones((100, 100), chunk_size=20) * 2 * 1 + 1
          c = (a * b * 2 + 1).sum()
          r = c.execute().fetch()
  
          expected = (np.ones(a.shape) * 2 * 1 + 1) ** 2 * 2 + 1
          np.testing.assert_array_equal(r, expected.sum())
  
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 6 for calling a global function with example usage: test_run_in_kubernetes(use_test_docker_file) without return types