'test that were\'re able to parse some example DAGs and retrieve them'

def test_get_existing_dag(self):

    dagbag = models.DagBag(include_examples=True)
    some_expected_dag_ids = [u'example_bash_operator', u'example_branch_operator']
    for dag_id in some_expected_dag_ids:
        dag = dagbag.get_dag(dag_id)
        self.assertIsNotNone(dag)
        self.assertEqual(dag_id, dag.dag_id)
    self.assertGreaterEqual(dagbag.size(), 7)
