class_docstr: Patches KubeflowDagRunner.run() with several customizations for CLI.
class_docstr_tok: ["Patches","KubeflowDagRunner.run","(",")","with","several","customizations","for","CLI","."]
code: def get_runner_class(self) -> Type[tfx_runner.TfxRunner]:
      return kubeflow_dag_runner.KubeflowDagRunner
  
file_path: tfx/tfx/tools/cli/handler/kubeflow_dag_runner_patcher.py
imports: import os
  import tempfile
  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 import kubeflow_dag_runner
  from tfx.tools.cli.handler import dag_runner_patcher
label_desc: Use image node_id 3 for calling the KubeflowDagRunnerPatcher obj's underlying member method code with example usage: obj.get_runner_class() and returns: kubeflow_dag_runner