':param dag_id: DAG ID
:type dag_id: unicode
:return: if the given DAG ID exists in the bag, return the BaseDag
corresponding to that ID. Otherwise, throw an Exception
:rtype: SimpleDag'

def get_dag(self, dag_id):

    if (dag_id not in self.dag_id_to_simple_dag):
        raise AirflowException(u'Unknown    DAG    ID    {}'.format(dag_id))
    return self.dag_id_to_simple_dag[dag_id]
