'This checks the defensive against non existent tasks in a dag run'

def test_without_dag_run(self):

    self.branch_op.run(start_date=DEFAULT_DATE, end_date=DEFAULT_DATE)
    session = Session()
    tis = session.query(TI).filter((TI.dag_id == self.dag.dag_id), (TI.execution_date == DEFAULT_DATE))
    session.close()
    for ti in tis:
        if (ti.task_id == u'make_choice'):
            self.assertEquals(ti.state, State.SUCCESS)
        elif (ti.task_id == u'branch_1'):
            self.assertEquals(ti.state, State.NONE)
        elif (ti.task_id == u'branch_2'):
            self.assertEquals(ti.state, State.SKIPPED)
        else:
            raise
