Prevent the use existing work dir (#5682) [ci fast]

Signed-off-by: Paolo Di Tommaso <[email protected]>
nextflow-io · Jan 19, 2025 · e14fc99 · e14fc99
1 parent 5abb5ad
commit e14fc99
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/modules/nextflow/src/main/groovy/nextflow/processor/TaskProcessor.groovy b/modules/nextflow/src/main/groovy/nextflow/processor/TaskProcessor.groovy
@@ -830,7 +830,11 @@ class TaskProcessor {
             try {
                 if( resumeDir != workDir )
                     exists = workDir.exists()
-                if( !exists && !workDir.mkdirs() )
+                if( exists ) {
+                    tries++
+                    continue
+                }
+                else if( !workDir.mkdirs() )
                     throw new IOException("Unable to create directory=$workDir -- check file system permissions")
             }
             finally {