def calculate_dag_dependencies_controlm()

in dagify/converter/uf.py [0:0]

• 14 lines of code
• 9 McCabe index (conditional complexity)

    def calculate_dag_dependencies_controlm(self):
        for task in self.get_tasks():
            out_conds = task.get_out_conditions()
            out_conds_positive = []
            for out_cond in out_conds:
                if out_cond.get_attribute("SIGN") == "+":
                    out_conds_positive.append(out_cond)
            if len(out_conds_positive) > 0:

                for poutcon in out_conds_positive:
                    for obj in self.get_tasks():
                        for in_conds in obj.get_in_conditions():
                            if in_conds.get_attribute("NAME") == poutcon.get_attribute("NAME"):
                                task.add_dependent_task(obj.get_dag_name(), obj.get_attribute("JOBNAME_ORIGINAL"))
        return