Skip to content

Commit

Permalink
[core] taskManager: downgrade status per chunk
Browse files Browse the repository at this point in the history
Avoid to get trailing "submitted" chunks on the current node when we stop the computation.
  • Loading branch information
fabiencastan committed Jan 6, 2021
1 parent c502ee1 commit a13a7da
Showing 1 changed file with 4 additions and 3 deletions.
7 changes: 4 additions & 3 deletions meshroom/core/taskManager.py
Original file line number Diff line number Diff line change
Expand Up @@ -116,9 +116,10 @@ def requestBlockRestart(self):
def blockRestart(self):
""" Avoid the automatic restart of computing. """
for node in self._nodesToProcess:
if node.getGlobalStatus() in (Status.SUBMITTED, Status.ERROR):
node.upgradeStatusTo(Status.NONE)
self.removeNode(node, displayList=True)
for chunk in node.chunks:
if chunk.status.status in (Status.SUBMITTED, Status.ERROR):
chunk.upgradeStatusTo(Status.NONE)
self.removeNode(node, displayList=True)

self._blockRestart = False
self._nodesToProcess = []
Expand Down

0 comments on commit a13a7da

Please sign in to comment.