If computeMgr.startworkers raises exception, then computeMgr should s…

…till be shutdown
ubarsc · Oct 19, 2024 · d543e3c · d543e3c
1 parent 2a84212
commit d543e3c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/rios/applier.py b/rios/applier.py
@@ -1149,6 +1149,7 @@ def apply_multipleCompute(userFunction, infiles, outfiles, otherArgs,
             tmpfileMgr=tmpfileMgr, haveSharedTemp=concurrency.haveSharedTemp,
             exceptionQue=exceptionQue)
     except Exception as e:
+        computeMgr.shutdown()
         if readWorkerMgr is not None:
             readWorkerMgr.shutdown()
         raise e