code: def run_pipeline_on_beam():
      """Runs the pipelineon Beam."""
      pipeline = create_pipeline()
      BeamDagRunner().run(pipeline)
  
file_path: tfx/tfx/examples/custom_components/container_components/download_grep_print_pipeline_on_beam_test.py
imports: import os
  import absl
  import tensorflow
  from tfx.examples.custom_components.container_components import download_grep_print_pipeline
  from tfx.orchestration import metadata
  from tfx.orchestration import pipeline
  from tfx.orchestration.beam.beam_dag_runner import BeamDagRunner
label_desc: Use image node_id 2 for calling a global function with example usage: run_pipeline_on_beam() without return types