'DagRuns with one unfinished and one failed root task -> RUNNING'

def test_dagrun_root_fail_unfinished(self):

    scheduler = SchedulerJob(**self.default_scheduler_args)
    dag_id = u'test_dagrun_states_root_fail_unfinished'
    dag = self.dagbag.get_dag(dag_id)
    dag.clear()
    dr = scheduler.create_dag_run(dag)
    try:
        dag.run(start_date=dr.execution_date, end_date=dr.execution_date)
    except AirflowException:
        pass
    session = settings.Session()
    ti = dr.get_task_instance(u'test_dagrun_unfinished', session=session)
    ti.state = State.NONE
    session.commit()
    dr_state = dr.update_state()
    self.assertEqual(dr_state, State.RUNNING)
