code: def create_producer_pipeline():
      example_gen = CsvExampleGen(
          input_base=os.path.join("tfx_root", "data_path")
      )
  
      return pipeline.Pipeline(
          pipeline_name="producer-pipeline",
          components=[example_gen],
          outputs={"examples": example_gen.outputs["examples"]},
      )
  
file_path: tfx/tfx/dsl/compiler/testdata/consumer_pipeline.py
imports: import os
  from tfx.components import CsvExampleGen
  from tfx.components import StatisticsGen
  from tfx.dsl.components.common import resolver
  from tfx.dsl.input_resolution.strategies import latest_artifact_strategy
  from tfx.orchestration import pipeline
label_desc: Use image node_id 1 for calling a global function with example usage: create_producer_pipeline() and returns: pipeline