code: def _create_pipeline(
      pipeline_name: str,
      pipeline_root: str,
      data_root: str,
      metadata_path: str,
  ) -> pipeline.Pipeline:
      """Implements the chicago taxi pipeline with TFX."""
  
      # Brings data into the pipeline or otherwise joins/converts training data.
      example_gen = CsvExampleGen(input_base=data_root)
  
      return pipeline.Pipeline(
          pipeline_name=pipeline_name,
          pipeline_root=pipeline_root,
          components=[example_gen],
          enable_cache=True,
          metadata_connection_config=metadata.sqlite_metadata_connection_config(
              metadata_path
          ),
          additional_pipeline_args={},
      )
  
imports: import os
  from absl import logging
  from tfx.components.example_gen.csv_example_gen.component import CsvExampleGen
  from tfx.orchestration import metadata
  from tfx.orchestration import pipeline
  from tfx.orchestration.local import local_dag_runner
label_desc: Use image node_id 1 for calling a global function with example usage: _create_pipeline(pipeline_name, pipeline_root, data_root, metadata_path) and returns: pipeline