code: def test_nonstreaming_shuffle(set_kill_interval):
      (
          lineage_reconstruction_enabled,
          kill_interval,
          _,
      ) = set_kill_interval
      try:
          # Create our own tracker so that it gets scheduled onto the head node.
          tracker = ShuffleStatusTracker.remote()
          ray.get(tracker.get_progress.remote())
          assert len(ray.nodes()) == 1, (
              "Tracker actor may have been scheduled to remote node "
              "and may get killed during the test"
          )
  
          shuffle.run(
              ray_address="auto",
              no_streaming=True,
              num_partitions=200,
              partition_size=1e6,
              tracker=tracker,
          )
      except (RayTaskError, ObjectLostError):
          assert kill_interval is not None
          assert not lineage_reconstruction_enabled
  
imports: import sys
  import random
  import string
  import ray
  import pytest
  import time
  from ray.experimental import shuffle
  from ray.tests.conftest import _ray_start_chaos_cluster
  from ray.data._internal.progress_bar import ProgressBar
  from ray.util.placement_group import placement_group
  from ray._private.test_utils import NodeKillerActor, get_log_message, get_and_run_resource_killer, WorkerKillerActor, wait_for_condition
  from ray.exceptions import RayTaskError, ObjectLostError
  from ray.util.state.common import ListApiOptions, StateResource
  from ray.util.state.api import StateApiClient, list_nodes
  from ray.cluster_utils import AutoscalingCluster
label_desc: Use image node_id 6 for calling a global function with example usage: test_nonstreaming_shuffle(set_kill_interval) without return types