23f7a6de9a581d18a1fb87582f50b6efb72e7683,elfi/executor.py,Executor,get_execution_order,#Any#Any#,84

Before Change

        for output_node in G.graph["outputs"]:
            if dep_graph.has_node(output_node):
                nodes.update([output_node])
                nodes.update(nx.ancestors(dep_graph, output_node))

        return [n for n in order if n in nodes]

After Change

        // Get the cache dict if it exists
        cache = G.graph.get("_executor_cache", {})

        output_nodes = G.graph["outputs"]
        // Filter those output nodes who have an operation to run
        needed = tuple(sorted(node for node in output_nodes if "operation" in G.node[node]))

        if needed not in cache:
            // Resolve the nodes that need to be executed in the graph
            nodes_to_execute = set(needed)

Instances