[ui] add partial graph submission up to a certain node

This commit is contained in:
Yann Lanthony 2018-02-07 14:35:50 +01:00
parent 907c9cbcba
commit 25992286d0
4 changed files with 21 additions and 7 deletions

View file

@ -1812,8 +1812,7 @@ def execute(graph, toNodes=None, forceCompute=False, forceStatus=False):
node.endSequence()
def submitGraph(graph, submitter, toNode=None):
toNodes = graph.findNodes([toNode]) if toNode else None
def submitGraph(graph, submitter, toNodes=None):
nodesToProcess, edgesToProcess = graph.dfsToProcess(startNodes=toNodes)
flowEdges = graph.flowEdges(startNodes=toNodes)
edgesToProcess = set(edgesToProcess).intersection(flowEdges)
@ -1843,5 +1842,6 @@ def submit(graphFile, submitter, toNode=None):
Submit the given graph via the given submitter.
"""
graph = loadGraph(graphFile)
submitGraph(graph, submitter, toNode)
toNodes = graph.findNodes([toNode]) if toNode else None
submitGraph(graph, submitter, toNodes)