code: def testMultiStartStop(self, sharding_policy):
      num_workers = 3
      # Set a shutdown quiet period to prevent workers from shutting down partway
      # through a round.
      cluster = data_service_test_base.TestCluster(
          num_workers, worker_shutdown_quiet_period_ms=2000
      )
      num_consumers = 5
      ds = self.make_coordinated_read_dataset(
          cluster, num_consumers, sharding_policy
      )
  
      get_next = self.getNext(ds, requires_initialization=True)
      results = []
  
      self.read(get_next, results, 20)
      for i in range(num_workers):
          cluster.workers[i].stop()
          self.read(get_next, results, 20)
          cluster.workers[i].restart()
          self.read(get_next, results, 20)
  
      cluster.add_worker()
      cluster.restart_dispatcher()
      for i in range(num_workers):
          cluster.workers[i].stop()
      self.read(get_next, results, 20)
  
      self.checkCoordinatedReadGroups(results, num_consumers)
      cluster.stop_workers()
  
file_path: tensorflow/tensorflow/python/data/experimental/kernel_tests/service/coordinated_read_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.framework import combinations
  from tensorflow.python.platform import test
label_desc: Use image node_id 3 for calling the CoordinatedReadFTTest obj's underlying member method code with example usage: obj.testMultiStartStop(sharding_policy) without return types