};

TEST_F(SessionClusterTensorflowDialectTest, ClustersTf) {
  CellReader<int64_t> compilation_status(kCompilationStreamz);

  TF_ASSERT_OK(CreateMlirModule("empty_func.mlir"));

  TF_EXPECT_OK(
      RunSessionTf2xlaClusteringBridge(*mlir_module_,
                                       /*is_in_fallback_enabled_mode=*/false));
  EXPECT_EQ(compilation_status.Delta(mlir::TF::kMlirPh1BridgeCounterReplicated,

        /*error_prefix=*/"Bridge Errored running clustering pipeline:",
        is_in_fallback_enabled_mode, clustering_pipeline_status));
  }

  return absl::OkStatus();
}

tensorflow::Status RunSessionTf2xlaClusteringBridge(
    ModuleOp module, bool is_in_fallback_enabled_mode) {
  VLOG(2) << "TPU Sessions Bridge called stack trace is "
          << "(NOTE: this is not an error; rather the stack trace for "