Evict pod and decrease process forks if pod is restarted after except…

…ion (#2787) Signed-off-by: Lehmann-Fabian <fabian.lehmann@informatik.hu-berlin.de> Co-authored-by: Paolo Di Tommaso <paolo.ditommaso@gmail.com>
nextflow-io · Apr 23, 2022 · 05ea0c8 · 05ea0c8
1 parent 111cc31
commit 05ea0c8
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/modules/nextflow/src/main/groovy/nextflow/processor/TaskPollingMonitor.groovy b/modules/nextflow/src/main/groovy/nextflow/processor/TaskPollingMonitor.groovy
@@ -577,6 +577,9 @@ class TaskPollingMonitor implements TaskMonitor {
     final protected void handleException( TaskHandler handler, Throwable error ) {
         def fault = null
         try {
+            if (evict(handler)) { 
+                handler.decProcessForks()
+            }
             fault = handler.task.processor.resumeOrDie(handler?.task, error)
         }
         finally {