code: def main():
      # First, create the tfx pipeline instance.
      pipeline = _create_pipeline()
      # Use kubernetes dag runner to run the pipeline.
      kubernetes_dag_runner.KubernetesDagRunner().run(pipeline=pipeline)
  
imports: import absl
  from tfx.orchestration import pipeline
  from tfx.orchestration.experimental.kubernetes import kubernetes_dag_runner
  from tfx.orchestration.test_pipelines.download_grep_print_pipeline import create_pipeline_component_instances
label_desc: Use image node_id 2 for calling a global function with example usage: main() without return types