code: def set_dag_run_state_to_queued(
      *,
      dag: DAG,
      execution_date: datetime | None = None,
      run_id: str | None = None,
      commit: bool = False,
      session: SASession = NEW_SESSION,
  ) -> list[TaskInstance]:
      """
      Set the dag run's state to queued.
  
      Set for a specific execution date and its task instances to queued.
      """
      return __set_dag_run_state_to_running_or_queued(
          new_state=DagRunState.QUEUED,
          dag=dag,
          execution_date=execution_date,
          run_id=run_id,
          commit=commit,
          session=session,
      )
  
imports: from __future__ import annotations
  from typing import TYPE_CHECKING, Collection, Iterable, Iterator, NamedTuple
  from sqlalchemy import or_, select
  from sqlalchemy.orm import lazyload
  from airflow.models.dagrun import DagRun
  from airflow.models.taskinstance import TaskInstance
  from airflow.operators.subdag import SubDagOperator
  from airflow.utils import timezone
  from airflow.utils.helpers import exactly_one
  from airflow.utils.session import NEW_SESSION, provide_session
  from airflow.utils.state import DagRunState, State, TaskInstanceState
  from airflow.utils.types import DagRunType
label_desc: Use image node_id 16 for calling a global function with example usage: set_dag_run_state_to_queued() and returns: __set_dag_run_state_to_running_or_queued