def test_dagrun_fail(self):
        self.evaluate_dagrun(
            dag_id='test_dagrun_states_fail',
            expected_task_states={
                'test_dagrun_fail': State.FAILED,
                'test_dagrun_succeed': State.UPSTREAM_FAILED,
            },
            dagrun_state=State.FAILED)
DagRuns with one failed and one incomplete root task -> FAILED
dataset/ETHPy150Open airbnb/airflow/tests/jobs.py/SchedulerJobTest.test_dagrun_fail