code: def create_pipeline_with_subpipeline() -> pipeline_pb2.Pipeline:
      """Creates a pipeline with a subpipeline."""
      # pylint: disable=no-value-for-parameter
      example_gen = _example_gen().with_id("my_example_gen")
  
      p_in = pipeline_lib.PipelineInputs(
          {"examples": example_gen.outputs["examples"]}
      )
      stats_gen = _statistics_gen(examples=p_in["examples"]).with_id(
          "my_statistics_gen"
      )
      schema_gen = _schema_gen(
          statistics=stats_gen.outputs["statistics"]
      ).with_id("my_schema_gen")
      p_out = {"schema": schema_gen.outputs["schema"]}
  
      componsable_pipeline = pipeline_lib.Pipeline(
          pipeline_name="sub-pipeline",
          pipeline_root="/path/to/root/sub",
          components=[stats_gen, schema_gen],
          enable_cache=True,
          inputs=p_in,
          outputs=p_out,
      )
  
      transform = _transform(
          examples=example_gen.outputs["examples"],
          schema=componsable_pipeline.outputs["schema"],
      ).with_id("my_transform")
  
      pipeline = pipeline_lib.Pipeline(
          pipeline_name="my_pipeline",
          pipeline_root="/path/to/root",
          components=[
              example_gen,
              componsable_pipeline,
              transform,
          ],
          enable_cache=True,
      )
      dsl_compiler = compiler.Compiler()
      return dsl_compiler.compile(pipeline)
  
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.dsl.control_flow.for_each import ForEach
  from tfx.dsl.experimental.conditionals import conditional
  from tfx.dsl.experimental.node_execution_options import utils
  from tfx.orchestration import pipeline
  from tfx.proto.orchestration import pipeline_pb2
  from tfx.types import standard_artifacts
label_desc: Use image node_id 13 for calling a global function with example usage: create_pipeline_with_subpipeline() and returns: dsl_compiler