code: def _create_pipeline(
      pipeline_name,
      pipeline_root,
      metadata_path,
      name,
  ):
      hello_world = _HelloWorldComponent(name=name)
  
      return pipeline.Pipeline(
          pipeline_name=pipeline_name,
          pipeline_root=pipeline_root,
          components=[hello_world],
          enable_cache=True,
          metadata_connection_config=metadata.sqlite_metadata_connection_config(
              metadata_path
          ),
          additional_pipeline_args={},
      )
  
file_path: tfx/tfx/orchestration/launcher/docker_component_launcher_e2e_test.py
imports: import os
  import tensorflow
  from tfx.dsl.components.base import base_component
  from tfx.dsl.components.base import executor_spec
  from tfx.orchestration import metadata
  from tfx.orchestration import pipeline
  from tfx.orchestration.beam import beam_dag_runner
  from tfx.types import component_spec
label_desc: Use image node_id 1 for calling a global function with example usage: _create_pipeline(pipeline_name, pipeline_root, metadata_path, name) and returns: pipeline