code: def _run_pipeline_using_kfp_client(self, pipeline_name: str):
      pipeline_id = self._get_kfp_pipeline_id(pipeline_name)
      experiment_id = self._get_kfp_experiment_id(pipeline_name)
      absl.logging.info(
          'Creating a run directly using kfp API for "%s"(pipeline_id=%s,'
          " experiment_id=%s)",
          pipeline_name,
          pipeline_id,
          experiment_id,
      )
      return self._client.run_pipeline(
          experiment_id=experiment_id,
          job_name=pipeline_name,
          pipeline_id=pipeline_id,
      )
  
imports: import codecs
  import locale
  import os
  import subprocess
  import sys
  from typing import Optional
  import absl
  from google.cloud import storage
  import kfp
  import kfp_server_api
  import tensorflow
  from tfx.dsl.io import fileio
  from tfx.tools.cli import labels
  from tfx.tools.cli import pip_utils
  from tfx.tools.cli.e2e import test_utils
  from tfx.utils import retry
  from tfx.utils import test_case_utils
label_desc: Use image node_id 12 for calling the CliKubeflowEndToEndTest obj's underlying member method code with example usage: obj._run_pipeline_using_kfp_client(pipeline_name) and returns: self