airflow/models/dag.py
def subdags(self):
        """Returns a list of the subdag objects associated to this DAG"""
        # Check SubDag for class but don't check class directly
        from airflow.operators.subdag import SubDagOperator

        subdag_lst = []
        for task in self.tasks:
            if (
                isinstance(task, SubDagOperator)
                or
                # TODO remove in Airflow 2.0
                type(task).__name__ == 'SubDagOperator'
                or task.task_type == 'SubDagOperator'
            ):
                subdag_lst.append(task.subdag)
                subdag_lst += task.subdag.subdags
        return subdag_lst
Returns a list of the subdag objects associated to this DAG
Returns a list of the subdag objects associated to this DAG
Returns a list of the subdag objects associated to this DAG
def subdags(self):
        from airflow.operators.subdag import SubDagOperator
        subdag_lst = []
        for task in self.tasks:
            if (
                isinstance(task, SubDagOperator)
                or
                type(task).__name__ == 'SubDagOperator'
                or task.task_type == 'SubDagOperator'
            ):
                subdag_lst.append(task.subdag)
                subdag_lst += task.subdag.subdags
        return subdag_lst
def subdags ( self ) : from airflow . operators . subdag import SubDagOperator subdag_lst = [ ] for task in self . tasks : if ( isinstance ( task , SubDagOperator ) or type ( task ) . __name__ == 'SubDagOperator' or task . task_type == 'SubDagOperator' ) : subdag_lst . append ( task . subdag ) subdag_lst += task . subdag . subdags return subdag_lst
Returns a list of the subdag objects associated to this DAG
Returns a list of the subdag objects associated to this DAG
"""Returns a list of the subdag objects associated to this DAG""" # Check SubDag for class but don't check class directly # TODO remove in Airflow 2.0
self