code: def create_dag(suffix):
      dag = DAG(
          dag_id=f"test_multiple_dags__{suffix}",
          default_args=args,
          schedule="0 0 * * *",
          dagrun_timeout=datetime.timedelta(minutes=60),
      )
  
      with dag:
          BashOperator(
              task_id="test_task",
              bash_command="echo",
              dag=dag,
          )
      return dag
  
imports: from __future__ import annotations
  import datetime
  from airflow.models.dag import DAG
  from airflow.operators.bash import BashOperator
label_desc: Use image node_id 1 for calling a global function with example usage: create_dag(suffix) and returns: dag