message: handle failing tests
diff: @@ -530,7 +530,7 @@ class DataServiceOpsTest(data_service_test_base.TestBase,
  @combinations.generate(test_base.eager_only_combinations())
  def testZipDifferentProcessingModesDatasets(self):
  - cluster = self.create_cluster(num_workers=2)
  + cluster = self.create_cluster(num_workers=1)
  num_elements = 100
  ds1 = dataset_ops.Dataset.range(num_elements)
  ds1 = self.make_distributed_dataset(
  @@ -538,14 +538,14 @@ class DataServiceOpsTest(data_service_test_base.TestBase,
  ds2 = dataset_ops.Dataset.range(num_elements)
  ds2 = self.make_distributed_dataset(
  ds2, cluster, processing_mode="parallel_epochs")
  - ds = dataset_ops.Dataset.zip(ds1, ds2)
  + ds = dataset_ops.Dataset.zip((ds1, ds2))
  self.assertDatasetProduces(
  ds, list(zip(range(num_elements), range(num_elements))),
  assert_items_equal=True)
  @combinations.generate(test_base.eager_only_combinations())
  def testZipDifferentProcessingModesDatasetsSharedJobName(self):
  - cluster = self.create_cluster(num_workers=2)
  + cluster = self.create_cluster(num_workers=1)
  num_elements = 100
  ds1 = dataset_ops.Dataset.range(num_elements)
  ds1 = self.make_distributed_dataset(
  @@ -553,7 +553,10 @@ class DataServiceOpsTest(data_service_test_base.TestBase,
  ds2 = dataset_ops.Dataset.range(num_elements)
  ds2 = self.make_distributed_dataset(
  ds2, cluster, processing_mode="parallel_epochs", job_name="job_name")
  - ds = dataset_ops.Dataset.zip(ds1, ds2)
  + ds = dataset_ops.Dataset.zip((ds1, ds2))
  + with self.assertRaisesRegex(errors.FailedPreconditionError,
  + "but there is already an existing job"):
  +
  self.assertDatasetProduces(
  ds, list(zip(range(num_elements), range(num_elements))),
  assert_items_equal=True)
  