Sort channels before creating the snapshot

genepi · Jun 20, 2024 · 2204535 · 2204535
1 parent 37ad152
commit 2204535
Show file tree

Hide file tree

Showing 3 changed files with 33 additions and 11 deletions.
diff --git a/tests/lib/processes/map_reads.nf.test b/tests/lib/processes/map_reads.nf.test
@@ -22,7 +22,7 @@ nextflow_process {
 
         then {
             assert process.success
-            // assert snapshot(process.out).match()
+            assert snapshot(process.out.sort).match()
         }
 
     }
@@ -45,7 +45,7 @@ nextflow_process {
 
         then {
             assert process.success
-            // assert snapshot(process.out).match()
+            assert snapshot(process.out.sort).match()
         }
 
     }
@@ -68,7 +68,7 @@ nextflow_process {
 
         then {
             assert process.success
-            // assert snapshot(process.out).match()
+            assert snapshot(process.out.sort).match()
         }
 
     }

diff --git a/tests/lib/processes/map_reads.nf.test.snap b/tests/lib/processes/map_reads.nf.test.snap
@@ -0,0 +1,26 @@
+{
+    "Maps raw reads and should run with success": {
+        "content": null,
+        "meta": {
+            "nf-test": "0.9.0-rc2",
+            "nextflow": "24.05.0"
+        },
+        "timestamp": "2024-06-20T15:14:00.481095"
+    },
+    "Maps consensus reads and should run with success": {
+        "content": null,
+        "meta": {
+            "nf-test": "0.9.0-rc2",
+            "nextflow": "24.05.0"
+        },
+        "timestamp": "2024-06-20T15:36:33.416682"
+    },
+    "Maps final consensus reads and should run with success": {
+        "content": null,
+        "meta": {
+            "nf-test": "0.9.0-rc2",
+            "nextflow": "24.05.0"
+        },
+        "timestamp": "2024-06-20T15:36:44.226869"
+    }
+}
diff --git a/tests/lib/processes/merge_input.nf.test b/tests/lib/processes/merge_input.nf.test
@@ -13,16 +13,14 @@ nextflow_process {
             }
             process {
                 """
-                input[0] = Channel.from("$baseDir/tests/input/merge_fastq/")
+                input[0] = Channel.from("$baseDir/tests/input/merge_fastq/").collect(sort: true)
                 """
             }
         }
 
         then {
-            def file = path(process.out.merged_fastq[0][2])
-            assert file.size() == 34240216
             assert process.success
-            // assert snapshot(process.out).match()
+            assert snapshot(process.out).match()
 
         }
 
@@ -37,16 +35,14 @@ nextflow_process {
             }
             process {
                 """
-                input[0] = Channel.from("$baseDir/tests/input/merge_fastq/")
+                input[0] = Channel.from("$baseDir/tests/input/merge_fastq/").collect(sort: true)
                 """
             }
         }
 
         then {
-            def file = path(process.out.merged_fastq[0][2])
-            assert file.size() == 0
             assert process.success
-            // assert snapshot(process.out).match()
+            assert snapshot(process.out).match()
         }
 
     }