def convert_relations()

in o2a/converter/oozie_converter.py [0:0]

• 17 lines of code
• 4 McCabe index (conditional complexity)

    def convert_relations(self) -> None:
        logging.info("Converting relations between tasks groups.")
        for task_group in self.workflow.task_groups.values():
            for downstream in task_group.downstream_names:
                relation = Relation(
                    from_task_id=task_group.last_task_id_of_ok_flow,
                    to_task_id=self.workflow.task_groups[downstream].first_task_id,
                )
                self.workflow.task_group_relations.add(relation)
            error_downstream = task_group.error_downstream_name
            if error_downstream:
                relation = Relation(
                    from_task_id=task_group.last_task_id_of_error_flow,
                    to_task_id=self.workflow.task_groups[error_downstream].first_task_id,
                    is_error=True,
                )
                self.workflow.task_group_relations.add(relation)