@@ -619,7 +619,7 @@ def stopTask(self, chunk: NodeChunk):
619619 job .stopChunkTask (node , chunkIteration )
620620 except Exception as e :
621621 self .parent ().showMessage (f"Failed to stop chunk { chunkIteration } of { node .label } " , "error" )
622- logging .warning (f"Error on stopTask :\n { e } " )
622+ logging .warning (f"Error on stopTask:\n { e } " )
623623 else :
624624 chunk .updateStatusFromCache ()
625625 chunk .upgradeStatusTo (Status .STOPPED )
@@ -645,7 +645,7 @@ def stopNode(self, node: Node):
645645 job .stopChunkTask (node , - 1 )
646646 except Exception as e :
647647 self .parent ().showMessage (f"Failed to stop node { node .label } " , "error" )
648- logging .warning (f"Error on stopTask :\n { e } " )
648+ logging .warning (f"Error on stopTask:\n { e } " )
649649 else :
650650 node .updateNodeStatusFromCache ()
651651 node .upgradeStatusTo (Status .STOPPED )
@@ -654,7 +654,6 @@ def stopNode(self, node: Node):
654654 else :
655655 self .cancelNodeComputation (node )
656656 node .stopComputation ()
657- # self._taskManager.removeNode(node, processList=True)
658657
659658 @Slot (NodeChunk )
660659 def restartTask (self , chunk : NodeChunk ):
@@ -671,7 +670,7 @@ def restartTask(self, chunk: NodeChunk):
671670 chunk .updateStatusFromCache ()
672671 chunk .upgradeStatusTo (Status .ERROR )
673672 self .parent ().showMessage (f"Failed to relaunch chunk { chunkIteration } of { node .label } " , "error" )
674- logging .warning (f"Error on restartTask :\n { e } " )
673+ logging .warning (f"Error on restartTask:\n { e } " )
675674 else :
676675 self .parent ().showMessage (f"Relaunched chunk { chunkIteration } of { node .label } " )
677676 else :
@@ -695,7 +694,7 @@ def skipTask(self, chunk: NodeChunk):
695694 job .skipChunkTask (node , chunkIteration )
696695 except Exception as e :
697696 self .parent ().showMessage (f"Failed to skip chunk { chunkIteration } of { node .label } " , "error" )
698- logging .warning (f"Error on skipTask :\n { e } " )
697+ logging .warning (f"Error on skipTask:\n { e } " )
699698 else :
700699 chunk .upgradeStatusTo (Status .SUCCESS )
701700 self .parent ().showMessage (f"Skipped chunk { chunkIteration } of { node .label } " )
@@ -715,12 +714,12 @@ def pauseJob(self, node: Node):
715714 try :
716715 job .pauseJob ()
717716 except Exception as e :
718- logging .warning (f"Error on pauseJob :\n { e } " )
717+ logging .warning (f"Error on pauseJob:\n { e } " )
719718 self .parent ().showMessage (f"Failed to pause the job for node { node } " , "error" )
720719 else :
721720 self .parent ().showMessage (f"Paused node { node .label } on farm" )
722721 elif not node .isExtern ():
723- self .parent ().showMessage (f"PauseJob is only available in local computation mode !" , "warning" )
722+ self .parent ().showMessage (f"PauseJob is only available in external computation mode!" , "warning" )
724723 else :
725724 self .parent ().showMessage (f"Cannot retrieve the job" , "error" )
726725
@@ -734,8 +733,8 @@ def resumeJob(self, node: Node):
734733 try :
735734 job .resumeJob ()
736735 except Exception as e :
737- self .parent ().showMessage (f"Failed to rsume node { node .label } on farm" )
738- logging .warning (f"Error on resumeJob :\n { e } " )
736+ self .parent ().showMessage (f"Failed to resume node { node .label } on farm" )
737+ logging .warning (f"Error on resumeJob:\n { e } " )
739738 else :
740739 self .parent ().showMessage (f"Resumed the job for node { node } " )
741740 else :
@@ -754,7 +753,7 @@ def interruptJob(self, node: Node):
754753 job .interruptJob ()
755754 except Exception as e :
756755 self .parent ().showMessage (f"Failed to interrupt node { node .label } on farm" , "error" )
757- logging .warning (f"Error on interruptJob :\n { e } " )
756+ logging .warning (f"Error on interruptJob:\n { e } " )
758757 else :
759758 for chunk in self ._sortedDFSChunks :
760759 if jobManager .getNodeJob (chunk .node ) == job :
@@ -794,9 +793,9 @@ def restartJobErrorTasks(self, node: Node):
794793 job .resumeJob ()
795794 except Exception as e :
796795 self .parent ().showMessage (f"Failed to restart error tasks for node { node .label } on farm" , "error" )
797- logging .warning (f"Error on restartJobErrorTasks :\n { e } " )
796+ logging .warning (f"Error on restartJobErrorTasks:\n { e } " )
798797 else :
799- self .parent ().showMessage (f"Restared error tasks for the node { node } " )
798+ self .parent ().showMessage (f"Restarted error tasks for the node { node } " )
800799 else :
801800 # In this case user can just relaunch the node computation
802801 # Could be implemented if we had a paused state on the task manager
0 commit comments