code: def create_test_pipeline(suffix, trigger_rule):
      """
      Instantiate a number of operators for the given DAG.
  
      :param str suffix: Suffix to append to the operator task_ids
      :param str trigger_rule: TriggerRule for the join task
      :param DAG dag_: The DAG to run the operators on
      """
      skip_operator = EmptySkipOperator(
          task_id=f"skip_operator_{suffix}"
      )
      always_true = EmptyOperator(task_id=f"always_true_{suffix}")
      join = EmptyOperator(
          task_id=trigger_rule, trigger_rule=trigger_rule
      )
      final = EmptyOperator(task_id=f"final_{suffix}")
  
      skip_operator >> join
      always_true >> join
      join >> final
  
file_path: airflow/airflow/example_dags/example_skip_dag.py
imports: from __future__ import annotations
  from typing import TYPE_CHECKING
  import pendulum
  from airflow.exceptions import AirflowSkipException
  from airflow.models.baseoperator import BaseOperator
  from airflow.models.dag import DAG
  from airflow.operators.empty import EmptyOperator
  from airflow.utils.trigger_rule import TriggerRule
label_desc: Use image node_id 1 for calling a global function with example usage: create_test_pipeline(suffix, trigger_rule) without return types