code: def create_chore_pipeline() -> pipeline_pb2.Pipeline:
      """Creates a pipeline full of chores.
  
        ┌─────────────┐┌──────────────┐
        │example_gen_1││example_gen_2 │
        └┬────────────┘└┬───────┬─────┘
        ┌▽──────┐┌──────▽───┐┌▽──────┐
        │chore_a ││chore_d    ││chore_e │
        └┬───────┘└┬─────────┬┘└┬───────┘
        ┌▽──────┐┌▽──────┐┌▽──▽───┐
        │chore_b ││chore_f││chore_g   │
        └┬───────┘└┬───────┘└─────────┘
        ┌▽────────▽┐
        │chore_c     │
        └────────────┘
      Returns:
        A pipeline for the above DAG
      """
  
      # pylint: disable=no-value-for-parameter
      example_gen_1 = _example_gen().with_id("my_example_gen_1")
      example_gen_2 = _example_gen().with_id("my_example_gen_2")
  
      chore_a = _chore().with_id("chore_a")
      chore_a.add_upstream_node(example_gen_1)
      chore_b = _chore().with_id("chore_b")
      chore_b.add_upstream_node(chore_a)
      chore_c = _chore().with_id("chore_c")
      chore_c.add_upstream_node(chore_b)
  
      chore_d = _chore().with_id("chore_d")
      chore_d.add_upstream_node(example_gen_2)
      chore_e = _chore().with_id("chore_e")
      chore_e.add_upstream_node(example_gen_2)
      chore_f = _chore().with_id("chore_f")
      chore_f.add_upstream_node(chore_d)
      chore_g = _chore().with_id("chore_g")
      chore_g.add_upstream_node(chore_d)
      chore_g.add_upstream_node(chore_e)
      chore_f.add_downstream_node(chore_c)
  
      pipeline = pipeline_lib.Pipeline(
          pipeline_name="my_pipeline",
          pipeline_root="/path/to/root",
          components=[
              example_gen_1,
              example_gen_2,
              chore_a,
              chore_b,
              chore_d,
              chore_e,
              chore_f,
              chore_g,
              chore_c,
          ],
          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 11 for calling a global function with example usage: create_chore_pipeline() and returns: dsl_compiler