3pp-mirror/Meshroom
1
0
Fork 0
mirror of https://github.com/alicevision/Meshroom.git synced 2025-05-23 22:16:30 +02:00
Code Issues Projects Releases Packages Wiki Activity

[ui] update graph computing status when NodeChunks change

Browse source 
Ensure graph computing status is properly updated after deleting a node that was running
This commit is contained in:
Yann Lanthony 2019-07-25 14:40:05 +02:00
parent aff5a98a4b
commit d229743c3d
No known key found for this signature in database
GPG key ID: 519FAE6DF7A70642
1 changed files with 5 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

8
meshroom/ui/graph.py
View file

@ -283,12 +283,14 @@ class UIGraph(QObject):
if self._sortedDFSChunks.objectList() == chunks: if self._sortedDFSChunks.objectList() == chunks:
return return
for chunk in self._sortedDFSChunks: for chunk in self._sortedDFSChunks:
chunk.statusChanged.disconnect(self.onChunkStatusChanged) chunk.statusChanged.disconnect(self.updateGraphComputingStatus)
self._sortedDFSChunks.setObjectList(chunks) self._sortedDFSChunks.setObjectList(chunks)
for chunk in self._sortedDFSChunks: for chunk in self._sortedDFSChunks:
chunk.statusChanged.connect(self.onChunkStatusChanged) chunk.statusChanged.connect(self.updateGraphComputingStatus)
# provide ChunkMonitor with the update list of chunks # provide ChunkMonitor with the update list of chunks
self.updateChunkMonitor(self._sortedDFSChunks) self.updateChunkMonitor(self._sortedDFSChunks)
# update graph computing status based on the new list of NodeChunks
self.updateGraphComputingStatus()
def updateChunkMonitor(self, chunks): def updateChunkMonitor(self, chunks):
""" Update the list of chunks for status files monitoring. """ """ Update the list of chunks for status files monitoring. """
@ -374,7 +376,7 @@ class UIGraph(QObject):
node = [node] if node else None node = [node] if node else None
submitGraph(self._graph, os.environ.get('MESHROOM_DEFAULT_SUBMITTER', ''), node) submitGraph(self._graph, os.environ.get('MESHROOM_DEFAULT_SUBMITTER', ''), node)
def onChunkStatusChanged(self): def updateGraphComputingStatus(self):
# update graph computing status # update graph computing status
running = any([ch.status.status == Status.RUNNING for ch in self._sortedDFSChunks]) running = any([ch.status.status == Status.RUNNING for ch in self._sortedDFSChunks])
submitted = any([ch.status.status == Status.SUBMITTED for ch in self._sortedDFSChunks]) submitted = any([ch.status.status == Status.SUBMITTED for ch in self._sortedDFSChunks])