code: def create_pipeline() -> pipeline_pb2.Pipeline:
      """Builds a test pipeline."""
      # pylint: disable=no-value-for-parameter
      example_gen = _example_gen().with_id("my_example_gen")
      sub_pipeline = create_sub_pipeline(
          example_gen.outputs["examples"]
      )
      transform = _transform(
          examples=example_gen.outputs["examples"],
          schema=sub_pipeline.outputs["schema"],
      ).with_id("my_transform")
  
      my_pipeline = pipeline_lib.Pipeline(
          pipeline_name="my_pipeline",
          pipeline_root="/path/to/root",
          components=[example_gen, sub_pipeline, transform],
      )
      dsl_compiler = compiler.Compiler()
      return dsl_compiler.compile(my_pipeline)
  
file_path: tfx/tfx/orchestration/experimental/core/testing/test_subpipeline.py
imports: from tfx.dsl.compiler import compiler
  from tfx.dsl.component.experimental.annotations import InputArtifact
  from tfx.dsl.component.experimental.annotations import OutputArtifact
  from tfx.dsl.component.experimental.decorators import component
  from tfx.orchestration import pipeline
  from tfx.proto.orchestration import pipeline_pb2
  from tfx.types import channel
  from tfx.types import standard_artifacts
label_desc: Use image node_id 6 for calling a global function with example usage: create_pipeline() and returns: dsl_compiler