class_docstr: Patches KubeflowV2DagRunner.run() with several customizations for CLI.
code: def get_runner_class(self) -> Type[tfx_runner.TfxRunner]:
      return kubeflow_v2_dag_runner.KubeflowV2DagRunner
  
file_path: tfx/tfx/tools/cli/handler/kubeflow_v2_dag_runner_patcher.py
imports: import os
  import typing
  from typing import Any, Callable, MutableMapping, Optional, Type
  from tfx.orchestration import pipeline
  from tfx.orchestration import tfx_runner
  from tfx.orchestration.kubeflow.v2 import kubeflow_v2_dag_runner
  from tfx.tools.cli.handler import dag_runner_patcher
label_desc: Use image node_id 3 for calling the KubeflowV2DagRunnerPatcher obj's underlying member method code with example usage: obj.get_runner_class() and returns: kubeflow_v2_dag_runner