def find_upstream_nodes()

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

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

    def find_upstream_nodes(self, target_node):
        result = []
        for node in self.nodes.values():
            if target_node.name in node.downstream_names or target_node.name == node.error_downstream_name:
                result.append(node)
        return result