Fix null reference error

Signed-off-by: Ben Sherman <bentshermann@gmail.com>
bentsherman · Oct 7, 2024 · 9a095a3 · 9a095a3
1 parent 4702ca3
commit 9a095a3
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/plugins/nf-boost/src/main/nextflow/boost/cleanup/CleanupObserver.groovy b/plugins/nf-boost/src/main/nextflow/boost/cleanup/CleanupObserver.groovy
@@ -146,12 +146,12 @@ class CleanupObserver implements TraceObserver {
                     // skip if node is terminal
                     if( !w )
                         continue
-                    // add operator nodes to the queue to keep searching
-                    if( w.process == null )
-                        queue.addAll( successors[w] )
                     // add process nodes to the list of consumers
-                    else
+                    if( w.process != null )
                         consumers[i] << w.process.name
+                    // add operator nodes to the queue to keep searching
+                    else if( w in successors )
+                        queue.addAll( successors[w] )
                 }
 
                 // check if output may forward input files