class_docstr: Fault tolerance tests for tf.data service cross-trainer cache.
code: def _create_cluster(
      self, num_workers, cross_trainer_cache_size_bytes=10 * (2**30)
  ):
      cluster = data_service_test_base.TestCluster(num_workers=0)
      for _ in range(num_workers):
          worker = data_service_test_base.TestWorker(
              dispatcher_address=cluster.dispatcher_address(),
              shutdown_quiet_period_ms=0,
              cross_trainer_cache_size_bytes=cross_trainer_cache_size_bytes,
          )
          worker.start()
          cluster.workers.append(worker)
      return cluster
  
file_path: tensorflow-upstream/tensorflow/python/data/experimental/kernel_tests/service/cross_trainer_cache_ft_test.py
imports: from absl.testing import parameterized
  from tensorflow.python.data.experimental.kernel_tests.service import test_base
  from tensorflow.python.data.experimental.ops import data_service_ops
  from tensorflow.python.data.kernel_tests import test_base
  from tensorflow.python.data.ops import dataset_ops
  from tensorflow.python.framework import combinations
  from tensorflow.python.platform import test
label_desc: Use image node_id 4 for calling the CrossTrainerCacheFtTest obj's underlying member method code with example usage: obj._create_cluster(num_workers, cross_trainer_cache_size_bytes) and returns: cluster