class_docstr: Common utilities for vertex engine.
class_docstr_tok: ["Common","utilities","for","vertex","engine","."]
code: def _run_pipeline(self):
      result = self._runCli(
          [
              "run",
              "create",
              "--engine",
              "vertex",
              "--pipeline_name",
              self._pipeline_name,
              "--project",
              self._GCP_PROJECT_ID,
              "--region",
              self._GCP_REGION,
          ]
      )
      run_id = self._parse_run_id(result)
      self._wait_until_completed(run_id)
  
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 6 for calling the BaseVertexEndToEndTest obj's underlying member method code with example usage: obj._run_pipeline() without return types