code: def _resolve_dagrun_model():
      from airflow.models.dagrun import DagRun
  
      return DagRun
  
imports: from __future__ import annotations
  from functools import cached_property
  from time import sleep
  from typing import TYPE_CHECKING, Callable, NoReturn
  from sqlalchemy import Column, Index, Integer, String, case, select
  from sqlalchemy.exc import OperationalError
  from sqlalchemy.orm import backref, foreign, relationship
  from sqlalchemy.orm.session import make_transient
  from airflow.api_internal.internal_api_call import internal_api_call
  from airflow.configuration import conf
  from airflow.exceptions import AirflowException
  from airflow.executors.executor_loader import ExecutorLoader
  from airflow.listeners.listener import get_listener_manager
  from airflow.models.base import ID_LEN, Base
  from airflow.serialization.pydantic.job import JobPydantic
  from airflow.stats import Stats
  from airflow.utils import timezone
  from airflow.utils.helpers import convert_camel_to_snake
  from airflow.utils.log.logging_mixin import LoggingMixin
  from airflow.utils.net import get_hostname
  from airflow.utils.platform import getuser
  from airflow.utils.session import NEW_SESSION, provide_session
  from airflow.utils.sqlalchemy import UtcDateTime
  from airflow.utils.state import JobState
label_desc: Use image node_id 1 for calling a global function with example usage: _resolve_dagrun_model() and returns: DagRun