Linting: Remove trailing whitespaces

Author: cbentejac

meshroom/core/taskManager.py

@@ -39,7 +39,6 @@ def isRunning(self):
         return self._state == State.RUNNING
 
     def waitForChunkCreation(self, node):
-        
         if hasattr(node, "_chunksCreated") and node._chunksCreated:
             return True
 
@@ -104,7 +103,7 @@ def run(self):
 
                 if self._manager.isChunkCancelled(chunk):
                     continue
-                
+
                 _nodeName, _node, _nbNodes = node.nodeType, nId+1, len(self._manager._nodesToProcess)
 
                 if multiChunks:
@@ -140,7 +139,7 @@ def run(self):
         else:
             self._manager._nodesToProcess = []
             self._state = State.DEAD
-    
+
     # Signals and properties
     createChunksSignal = Signal(BaseObject)
 
@@ -177,7 +176,7 @@ def createChunks(self, node: Node):
             self.chunksCreated.emit(node)
         except Exception as e:
             logging.error(f"Failed to create chunks for {node.name}: {e}")
-            self.chunksCreated.emit(node)  # Still emit to unblock waiting thread 
+            self.chunksCreated.emit(node)  # Still emit to unblock waiting thread
 
     def isChunkCancelled(self, chunk):
         for i, ch in enumerate(self._cancelledChunks):
@@ -186,7 +185,7 @@ def isChunkCancelled(self, chunk):
                 return True
         return False
 
-    def requestBlockRestart(self):  
+    def requestBlockRestart(self):
         """
         Block computing.
         Note: should only be used to completely stop computing.
@@ -208,7 +207,7 @@ def blockRestart(self):
         self._nodesToProcess = []
         self._cancelledChunks = []
         self._thread._state = State.DEAD
-    
+
     @Slot()
     def pauseProcess(self):
         if self._thread.isRunning():
@@ -269,7 +268,7 @@ def compute(self, graph: Graph = None, toNodes: list[Node] = None, forceCompute:
         :param forceCompute: force the computation despite nodes status.
         :param forceStatus: force the computation even if some nodes are submitted externally.
         """
-        
+
         self._graph = graph
 
         self.updateNodes()
@@ -493,7 +492,7 @@ def submit(self, graph, submitter=None, toNodes=None, submitLabel="{projectName}
             raise RuntimeError(f"[SUBMITTING] Unknown Submitter:\n"
                                f"Unknown Submitter called '{submitter}'. "
                                f"Available submitters are: '{str(meshroom.core.submitters.keys())}'.")
-        
+
         # TODO : If possible with the submitter (ATTACH_JOB)
 
         # Update task manager's lists
@@ -525,7 +524,7 @@ def submit(self, graph, submitter=None, toNodes=None, submitLabel="{projectName}
             jobManager.resetNodeJob(node)
 
         graph.updateMonitoredFiles()
-            
+
         flowEdges = graph.flowEdges(startNodes=toNodes)
         edgesToProcess = set(edgesToProcess).intersection(flowEdges)
 

meshroom/ui/graph.py

@@ -591,20 +591,20 @@ def cancelNodeComputation(self, node):
             for n in node.getOutputNodes(recursive=True, dependenciesOnly=True):
                 n.clearSubmittedChunks()
                 self._taskManager.removeNode(n, displayList=True, processList=True)
-    
+
     def isChunkComputingLocally(self, chunk):
         # update graph computing status
         computingLocally = chunk._status.execMode == ExecMode.LOCAL and \
                            (sessionUid in (chunk.node._nodeStatus.submitterSessionUid, chunk._status.computeSessionUid)) and \
                            (chunk._status.status in (Status.RUNNING, Status.SUBMITTED))
         return computingLocally
-    
+
     def isChunkComputingExternally(self, chunk):
         # Note: We do not check computeSessionUid for the submitted status,
         #       as the source instance of the submit has no importance.
         return (chunk._status.execMode == ExecMode.EXTERN) and \
                 chunk._status.status in (Status.RUNNING, Status.SUBMITTED)
-    
+
     @Slot(NodeChunk)
     def stopTask(self, chunk: NodeChunk):
         """ Stop the selected task """
@@ -674,7 +674,7 @@ def restartTask(self, chunk: NodeChunk):
             else:
                 self.parent().showMessage(f"Relaunched chunk {chunkIteration} of {node.label}")
         else:
-            # For this we would need to use a pool (with either chunks or nodes) 
+            # For this we would need to use a pool (with either chunks or nodes)
             # instead of the list of nodes that are processed serially
             self.parent().showMessage(f"Chunks cannot be launched individually locally", "warning")
             if self.canComputeNode(node):
@@ -850,9 +850,9 @@ def updateGraphComputingStatus(self):
                 continue
             if node._nodeStatus.status in (Status.RUNNING, Status.SUBMITTED):
                 # TODO : save session ID in node
-                if (node._nodeStatus.execMode == ExecMode.LOCAL):
+                if node._nodeStatus.execMode == ExecMode.LOCAL:
                     computingLocally = True
-                elif (node._nodeStatus.execMode == ExecMode.EXTERN):
+                elif node._nodeStatus.execMode == ExecMode.EXTERN:
                     submitted = True
 
         if self._computingLocally != computingLocally or self._submitted != submitted: