File tree Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Expand file tree Collapse file tree 1 file changed +6
-3
lines changed Original file line number Diff line number Diff line change @@ -429,7 +429,11 @@ def process(self, forceCompute=False):
429429 self .upgradeStatusTo (Status .SUCCESS )
430430
431431 def stopProcess (self ):
432- self .upgradeStatusTo (Status .STOPPED )
432+ if not self .isExtern ():
433+ if self ._status .status == Status .RUNNING :
434+ self .upgradeStatusTo (Status .STOPPED )
435+ elif self ._status .status == Status .SUBMITTED :
436+ self .upgradeStatusTo (Status .NONE )
433437 self .node .nodeDesc .stopProcess (self )
434438
435439 def isExtern (self ):
@@ -942,8 +946,7 @@ def endSequence(self):
942946 def stopComputation (self ):
943947 """ Stop the computation of this node. """
944948 for chunk in self ._chunks .values ():
945- if not chunk .isExtern ():
946- chunk .stopProcess ()
949+ chunk .stopProcess ()
947950
948951 def getGlobalStatus (self ):
949952 """
You can’t perform that action at this time.
0 commit comments