code: def main(_):
      absl.logging.set_verbosity(absl.logging.INFO)
      dsl_pipeline = _create_pipeline(
          pipeline_name=_pipeline_name,
          pipeline_root=_pipeline_root,
          data_root=_data_root,
      )
  
      runner_config = kubeflow_v2_dag_runner.KubeflowV2DagRunnerConfig()
  
      runner = kubeflow_v2_dag_runner.KubeflowV2DagRunner(
          config=runner_config
      )
  
      runner.run(pipeline=dsl_pipeline)
  
file_path: tfx/tfx/tools/cli/testdata/test_pipeline_kubeflow_v2_1.py
imports: import os
  import absl
  from absl import app
  from tfx.components.example_gen.csv_example_gen.component import CsvExampleGen
  from tfx.components.schema_gen.component import SchemaGen
  from tfx.components.statistics_gen.component import StatisticsGen
  from tfx.orchestration import pipeline
  from tfx.orchestration.kubeflow.v2 import kubeflow_v2_dag_runner
label_desc: Use image node_id 2 for calling a global function with example usage: main(_) without return types