code: def create_sub_pipeline(
      examples: channel.Channel,
  ) -> pipeline_lib.Pipeline:
      """A test sub pipeline."""
      # pylint: disable=no-value-for-parameter
      p_in = pipeline_lib.PipelineInputs(inputs={"examples": examples})
      stats_gen = _statistics_gen(
          examples=p_in.inputs["examples"]
      ).with_id("my_statistics_gen")
      schema_gen = _schema_gen(
          statistics=stats_gen.outputs["statistics"]
      ).with_id("my_schema_gen")
  
      return pipeline_lib.Pipeline(
          pipeline_name="my_sub_pipeline",
          components=[stats_gen, schema_gen],
          inputs=p_in,
          outputs={"schema": schema_gen.outputs["schema"]},
      )
  
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 5 for calling a global function with example usage: create_sub_pipeline(examples) and returns: pipeline_lib