Named lock for published files

phac-nml · Jan 21, 2024 · 623d54e · 623d54e
1 parent 5fc5466
commit 623d54e
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/plugins/nf-iridanext/src/main/nextflow/iridanext/IridaNextObserver.groovy b/plugins/nf-iridanext/src/main/nextflow/iridanext/IridaNextObserver.groovy
@@ -53,6 +53,7 @@ import nextflow.iridanext.MetadataParserJSON
 @CompileStatic
 class IridaNextObserver implements TraceObserver {
     private static final tasksLock = new Object[0]
+    private static final publishedFilesLock = new Object[0]
 
     private Map<Path,Path> publishedFiles = [:]
     private List<TaskRun> tasks = []
@@ -221,7 +222,7 @@ class IridaNextObserver implements TraceObserver {
     }
 
     @Override
-    @Synchronized
+    @Synchronized("publishedFilesLock")
     void onFilePublish(Path destination, Path source) {
         if (publishedFiles.containsKey(source)) {
             throw new Exception("Error: file with source=${source} was already published")