code: def create_pipeline() -> (
      pipeline_pb2.Pipeline
  ):  # pylint: disable=invalid-name
      pipeline = pipeline_lib.Pipeline(
          pipeline_name="my_pipeline",
          pipeline_root="/path/to/root",
          components=create_components(),
      )
      dsl_compiler = compiler.Compiler()
      return dsl_compiler.compile(pipeline)
  
imports: import os
  from typing import Any, Dict, List, Optional, Union
  from tfx import types
  from tfx.dsl.compiler import compiler
  from tfx.dsl.component.experimental.annotations import OutputDict
  from tfx.dsl.component.experimental.annotations import Parameter
  from tfx.dsl.component.experimental.decorators import component
  from tfx.dsl.components.base import base_component
  from tfx.dsl.components.base import base_executor
  from tfx.dsl.components.base import executor_spec
  from tfx.dsl.placeholder import placeholder
  from tfx.orchestration import pipeline
  from tfx.proto.orchestration import pipeline_pb2
  from tfx.types import component_spec
label_desc: Use image node_id 3 for calling a global function with example usage: create_pipeline() and returns: dsl_compiler