Updated to filter out empties

sanger-tol · Oct 19, 2023 · 245465a · 245465a
1 parent 8055b7b
commit 245465a
Showing 1 changed file with 19 additions and 1 deletion.
diff --git a/subworkflows/local/extract_nt_blast.nf b/subworkflows/local/extract_nt_blast.nf
@@ -43,10 +43,28 @@ workflow EXTRACT_NT_BLAST {
     REFORMAT_FULL_OUTFMT6 ( BLAST_CHUNK_TO_FULL.out.full )
     ch_versions             = ch_versions.mix(REFORMAT_FULL_OUTFMT6.out.versions)
 
+    //
+    // LOGIC:
+    //
+    REFORMAT_FULL_OUTFMT6.out.full
+        .map { meta, file ->
+            tuple(  [   id: meta.id,
+                        sz: file.size() ],
+                    file
+            )
+        }
+        .branch {
+            valid:      it[0].sz >= 1
+            invalid:    it[0].sz <= 0
+        }
+        .set { gatekeeper }
+
     //
     // MODULE:
     //
-    BLAST_GET_TOP_HITS ( REFORMAT_FULL_OUTFMT6.out.full )
+    BLAST_GET_TOP_HITS (
+        gatekeeper.valid
+    )
     ch_versions             = ch_versions.mix(BLAST_GET_TOP_HITS.out.versions)
 
     //