code: def create_pipeline() -> pipeline_pb2.Pipeline:
      """Creates a pipeline with an importer node for testing."""
      inode = importer.Importer(
          source_uri="my_url",
          reimport=True,
          custom_properties={
              "int_custom_property": 123,
              "str_custom_property": "abc",
          },
          artifact_type=standard_artifacts.Schema,
      ).with_id("my_importer")
      pipeline = pipeline_lib.Pipeline(
          pipeline_name="my_pipeline",
          pipeline_root="/path/to/root",
          components=[inode],
          execution_mode=pipeline_lib.ExecutionMode.SYNC,
      )
      dsl_compiler = compiler.Compiler()
      return dsl_compiler.compile(pipeline)
  
imports: from tfx.dsl.compiler import compiler
  from tfx.dsl.components.common import importer
  from tfx.orchestration import pipeline
  from tfx.proto.orchestration import pipeline_pb2
  from tfx.types import standard_artifacts
label_desc: Use image node_id 1 for calling a global function with example usage: create_pipeline() and returns: dsl_compiler