@@ -16,8 +16,10 @@ nextflow_process {
1616 script "../../../bowtie/build/main.nf"
1717 process {
1818 """
19- input[0] = [[ id:'sarscov2' ],
20- file(params.modules_testdata_base_path + 'genomics/sarscov2/genome/genome.fasta', checkIfExists: true) ]
19+ input[0] = [
20+ [ id:'sarscov2' ],
21+ file(params.modules_testdata_base_path + 'genomics/sarscov2/genome/genome.fasta', checkIfExists: true)
22+ ]
2123 """
2224 }
2325 }
@@ -28,9 +30,10 @@ nextflow_process {
2830 when {
2931 process {
3032 """
31- input[0] = [ [id:"test", single_end:true],
33+ input[0] = [
34+ [id:"test", single_end:true],
3235 file(params.modules_testdata_base_path + 'genomics/sarscov2/illumina/fastq/test_1.fastq.gz', checkIfExists: true)
33- ]
36+ ]
3437 input[1] = BOWTIE_BUILD.out.index
3538 input[2] = true
3639 """
@@ -40,11 +43,12 @@ nextflow_process {
4043 then {
4144 assertAll(
4245 { assert process.success },
43- { assert snapshot(process. out. versions,
44- process. out. bam. collect { bam(it[1 ]). getReadsMD5() },
45- process. out. fastq,
46- process. out. log
47- ). match() }
46+ { assert snapshot(
47+ process.out.bam.collect { bam(it[1]).getReadsMD5() },
48+ process.out.fastq,
49+ process.out.log,
50+ process.out.findAll { key, val -> key.startsWith('versions') }
51+ ).match() }
4852 )
4953 }
5054
@@ -57,9 +61,10 @@ nextflow_process {
5761 when {
5862 process {
5963 """
60- input[0] = [ [id:"test", single_end:true],
64+ input[0] = [
65+ [id:"test", single_end:true],
6166 file(params.modules_testdata_base_path + 'genomics/sarscov2/illumina/fastq/test_1.fastq.gz', checkIfExists: true)
62- ]
67+ ]
6368 input[1] = BOWTIE_BUILD.out.index
6469 input[2] = true
6570 """
@@ -69,7 +74,7 @@ nextflow_process {
6974 then {
7075 assertAll(
7176 { assert process.success },
72- { assert snapshot(process. out). match() }
77+ { assert snapshot(sanitizeOutput( process.out) ).match() }
7378 )
7479 }
7580
@@ -80,10 +85,11 @@ nextflow_process {
8085 when {
8186 process {
8287 """
83- input[0] = [ [id:"test", single_end:false],
88+ input[0] = [
89+ [id:"test", single_end:false],
8490 [file(params.modules_testdata_base_path + 'genomics/sarscov2/illumina/fastq/test_1.fastq.gz', checkIfExists: true),
8591 file(params.modules_testdata_base_path + 'genomics/sarscov2/illumina/fastq/test_2.fastq.gz', checkIfExists: true)]
86- ]
92+ ]
8793 input[1] = BOWTIE_BUILD.out.index
8894 input[2] = false
8995 """
@@ -93,10 +99,11 @@ nextflow_process {
9399 then {
94100 assertAll(
95101 { assert process.success },
96- { assert snapshot(process. out. versions,
97- process. out. bam. collect { bam(it[1 ]). getReads(2 ) },
98- process. out. log
99- ). match() }
102+ { assert snapshot(
103+ process.out.bam.collect { bam(it[1]).getReads(2) }, // Unstable BAM output, so only check the first 2 reads
104+ process.out.log,
105+ process.out.findAll { key, val -> key.startsWith('versions') },
106+ ).match() }
100107 )
101108 }
102109
@@ -108,9 +115,10 @@ nextflow_process {
108115 when {
109116 process {
110117 """
111- input[0] = [ [id:"test", single_end:false],
118+ input[0] = [
119+ [id:"test", single_end:false],
112120 file(params.modules_testdata_base_path + 'genomics/sarscov2/illumina/fastq/test_1.fastq.gz', checkIfExists: true)
113- ]
121+ ]
114122 input[1] = BOWTIE_BUILD.out.index
115123 input[2] = false
116124 """
@@ -120,7 +128,7 @@ nextflow_process {
120128 then {
121129 assertAll(
122130 { assert process.success },
123- { assert snapshot(process. out). match() }
131+ { assert snapshot(sanitizeOutput( process.out) ).match() }
124132 )
125133 }
126134
0 commit comments