code: def _iter_existing_dag_run_infos(
      dag: DAG, run_ids: list[str], session: SASession
  ) -> Iterator[_DagRunInfo]:
      for dag_run in DagRun.find(
          dag_id=dag.dag_id, run_id=run_ids, session=session
      ):
          dag_run.dag = dag
          dag_run.verify_integrity(session=session)
          yield _DagRunInfo(
              dag_run.logical_date, dag.get_run_data_interval(dag_run)
          )
  
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 7 for calling a global function with example usage: _iter_existing_dag_run_infos(dag, run_ids, session) without return types