def process_workflow_after_parse_workflow_xml()

in o2a/transformers/remove_kill_transformer.py [0:0]

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

    def process_workflow_after_parse_workflow_xml(self, workflow: Workflow):
        kill_nodes = workflow.get_nodes_by_type(KillMapper)
        for kill_node in kill_nodes:
            upstream_nodes = workflow.find_upstream_nodes(kill_node)
            if not any(kill_node.name in node.downstream_names for node in upstream_nodes):
                workflow.remove_node(kill_node)