self,
        ti_state_begin: TaskInstanceState | None,
        ti_state_end: TaskInstanceState | None,
    ):
        dag_id = "test_clear_dag"
        self._clean_up(dag_id)
        task_id = "t1"
        dag = DAG(dag_id, start_date=DEFAULT_DATE, max_active_runs=1)
        t_1 = EmptyOperator(task_id=task_id, dag=dag)
        session = settings.Session()  
        dagrun_1 = dag.create_dagrun(
            run_type=DagRunType.BACKFILL_JOB,
            state=DagRunState.RUNNING,
            start_date=DEFAULT_DATE,
            execution_date=DEFAULT_DATE,
        )