code: def test_create_pipeline(self):
      pipeline = create_pipeline()
      self.assertIsNotNone(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 1 for calling the PipelineTest obj's underlying member method code with example usage: obj.test_create_pipeline() without return types