Fix watchPath hang shutdown execution

Signed-off-by: Paolo Di Tommaso <[email protected]>
nextflow-io · Dec 16, 2022 · bac0ced · bac0ced
1 parent d1bb2fe
commit bac0ced
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/modules/nextflow/src/main/groovy/nextflow/Channel.groovy b/modules/nextflow/src/main/groovy/nextflow/Channel.groovy
@@ -314,6 +314,7 @@ class Channel  {
                         ? new DirWatcher(syntax,folder,pattern,skipHidden,events,fs)
                         : new DirWatcherV2(syntax,folder,pattern,skipHidden,events,fs)
         watcher.onComplete { result.bind(STOP) }
+        Global.onCleanup(it -> watcher.terminate())
 
         if( NF.isDsl2() )  {
             session.addIgniter {