class_docstr: Common utilities for kubeflow engine.
class_docstr_tok: ["Common","utilities","for","kubeflow","engine","."]
code: def _check_telemetry_label(self):
      file_path = os.path.join(
          self._project_dir, "{}.tar.gz".format(self._pipeline_name)
      )
      self.assertTrue(fileio.exists(file_path))
  
      with tarfile.TarFile.open(file_path).extractfile(
          "pipeline.yaml"
      ) as pipeline_file:
          self.assertIsNotNone(pipeline_file)
          pipeline = yaml.safe_load(pipeline_file)
          metadata = [
              c["metadata"]
              for c in pipeline["spec"]["templates"]
              if "dag" not in c
          ]
          for m in metadata:
              self.assertEqual(
                  "tfx-template",
                  m["labels"][telemetry_utils.LABEL_KFP_SDK_ENV],
              )
  
imports: import datetime
  import os
  import subprocess
  import tarfile
  from absl import logging
  from google.cloud import aiplatform
  import kfp
  from tfx.dsl.io import fileio
  from tfx.experimental.templates import test_utils
  from tfx.orchestration import test_utils
  from tfx.orchestration.kubeflow import test_utils
  from tfx.orchestration.kubeflow.v2 import vertex_client_utils
  from tfx.utils import docker_utils
  from tfx.utils import io_utils
  from tfx.utils import retry
  from tfx.utils import telemetry_utils
  from tfx.utils import test_case_utils
  import yaml
label_desc: Use image node_id 13 for calling the BaseKubeflowEndToEndTest obj's underlying member method code with example usage: obj._check_telemetry_label() without return types