def _find_accessible_nodes()

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

• 15 lines of code
• 5 McCabe index (conditional complexity)

    def _find_accessible_nodes(workflow: Workflow):
        """
        Finds nodes that are reachable from any Start node.
        """
        start_nodes = workflow.get_nodes_by_type(StartMapper)
        visited_node: Dict[str, OozieNode] = dict()

        def visit_node(node: OozieNode):
            if node.name in visited_node:
                return
            visited_node[node.name] = node

            all_downstream_node_names = [*node.downstream_names]
            if node.error_downstream_name:
                all_downstream_node_names.append(node.error_downstream_name)

            for node_name in all_downstream_node_names:
                visit_node(workflow.nodes[node_name])

        for start_node in start_nodes:
            visit_node(start_node)

        return visited_node.values()