code: def _create_pipeline():
      """Implements the chicago taxi pipeline with TFX."""
      return pipeline.Pipeline(
          pipeline_name=_pipeline_name,
          pipeline_root=_pipeline_root,
          components=test_utils.create_e2e_components(_data_root),
          enable_cache=True,
          metadata_connection_config=metadata.sqlite_metadata_connection_config(
              _metadata_path
          ),
      )
  
imports: import datetime
  import os
  from tfx.orchestration import metadata
  from tfx.orchestration import pipeline
  from tfx.orchestration.airflow.airflow_dag_runner import AirflowDagRunner
  from tfx.orchestration.airflow.airflow_dag_runner import AirflowPipelineConfig
  from tfx.tools.cli.e2e import test_utils
label_desc: Use image node_id 1 for calling a global function with example usage: _create_pipeline() and returns: pipeline