code: def create_test_pipeline():
      return _create_pipeline(
          pipeline_name=_pipeline_name,
          pipeline_root=_pipeline_root,
          data_root_1=_data_root_1,
          data_root_2=_data_root_2,
      )
  
file_path: tfx/tfx/dsl/compiler/testdata/channel_union_pipeline.py
imports: import os
  from tfx.components import CsvExampleGen
  from tfx.components import StatisticsGen
  from tfx.dsl.component.experimental import annotations
  from tfx.dsl.component.experimental.decorators import component
  from tfx.dsl.components.common import resolver
  from tfx.dsl.input_resolution.strategies import latest_artifact_strategy
  from tfx.orchestration import pipeline
  from tfx.types import channel
  from tfx.types import standard_artifacts
label_desc: Use image node_id 3 for calling a global function with example usage: create_test_pipeline() and returns: _create_pipeline