class_docstr: Common utilities for kubeflow engine.
class_docstr_tok: ["Common","utilities","for","kubeflow","engine","."]
code: def _create_pipeline(self):
      self._runCli(
          [
              "pipeline",
              "create",
              "--engine",
              "kubeflow",
              "--pipeline_path",
              "kubeflow_runner.py",
              "--endpoint",
              self._endpoint,
              "--build-image",
              "--build-base-image",
              self._base_container_image,
          ]
      )
  
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 9 for calling the BaseKubeflowEndToEndTest obj's underlying member method code with example usage: obj._create_pipeline() without return types