'Returns a list of the subdag objects associated to this DAG'

@property
def subdags(self):

    from airflow.operators.subdag_operator import SubDagOperator
    l = []
    for task in self.tasks:
        if (isinstance(task, SubDagOperator) or (type(task).__name__ == u'SubDagOperator')):
            l.append(task.subdag)
            l += task.subdag.subdags
    return l
