self.clean_db()
    def teardown_method(self) -> None:
        self.clean_db()
    def create_dag_run(
        self,
        dag: DAG,
        *,
        task_states: Mapping[str, TaskInstanceState] | None = None,
        execution_date: datetime.datetime | None = None,
        is_backfill: bool = False,
        state: DagRunState = DagRunState.RUNNING,
        session: Session,
    ):
        now = timezone.utcnow()
        if execution_date is None:
            execution_date = now
        execution_date = pendulum.instance(execution_date)
        if is_backfill:
            run_type = DagRunType.BACKFILL_JOB
            data_interval = dag.infer_automated_data_interval(execution_date)
        else:
            run_type = DagRunType.MANUAL
            data_interval = dag.timetable.infer_manual_data_interval(run_after=execution_date)
        dag_run = dag.create_dagrun(