@@ -36,7 +36,7 @@ nextflow_process {
3636
3737 when {
3838 params {
39- module_args = '--num-gpus 1 --memory-limit 4 -- low-memory --read-files-command zcat --x3'
39+ module_args = '--num-gpus 1 --low-memory --read-files-command zcat --x3'
4040 // Ref: https://forums.developer.nvidia.com/t/problem-with-gpu/256825/6
4141 // Parabricks’s rnafq2bam requires 24GB of memory.
4242 // Using --low-memory for testing
@@ -105,4 +105,79 @@ nextflow_process {
105105 }
106106 }
107107
108+ test("homo_sapiens_chimeric") {
109+
110+ config "./nextflow.config"
111+
112+ when {
113+ params {
114+ module_args = '--num-gpus 1 --low-memory --read-files-command zcat --out-chim-type Junctions --min-chim-segment 15 --x3'
115+ // Ref: https://forums.developer.nvidia.com/t/problem-with-gpu/256825/6
116+ // Parabricks’s rnafq2bam requires 24GB of memory.
117+ // Using --low-memory for testing
118+ }
119+ process {
120+ """
121+ input[0] = Channel.of([
122+ [ id:'test', single_end:true ], // meta map
123+ [ file(params.modules_testdata_base_path + 'genomics/homo_sapiens/genome/test_starfusion_rnaseq_1.fastq.gz', checkIfExists: true) ]
124+ ])
125+ input[1] = Channel.of([
126+ [ id:'test' ], // meta map
127+ file(params.modules_testdata_base_path + 'genomics/homo_sapiens/genome/genome.fasta', checkIfExists: true)
128+ ])
129+ input[2] = PARABRICKS_STARGENOMEGENERATE.out.index
130+ input[3] = false
131+ input[4] = false
132+ """
133+ }
134+ }
135+
136+ then {
137+ assertAll(
138+ { assert process.success },
139+ { assert snapshot(
140+ bam(process.out.bam[0][1]).getReadsMD5(),
141+ file(process.out.bai[0][1]).name,
142+ file(process.out.junction[0][1]).name,
143+ process.out.findAll { key, val -> key.startsWith('versions') }
144+ ).match() }
145+ )
146+ }
147+ }
148+
149+ test("homo_sapiens_chimeric - stub") {
150+
151+ config "./nextflow.config"
152+ options "-stub"
153+
154+ when {
155+ params {
156+ module_args = '--out-chim-type Junctions'
157+ }
158+ process {
159+ """
160+ input[0] = Channel.of([
161+ [ id:'test', single_end:true ], // meta map
162+ [ file(params.modules_testdata_base_path + 'genomics/homo_sapiens/genome/test_starfusion_rnaseq_1.fastq.gz', checkIfExists: true) ]
163+ ])
164+ input[1] = Channel.of([
165+ [ id:'test' ], // meta map
166+ file(params.modules_testdata_base_path + 'genomics/homo_sapiens/genome/genome.fasta', checkIfExists: true)
167+ ])
168+ input[2] = PARABRICKS_STARGENOMEGENERATE.out.index
169+ input[3] = false
170+ input[4] = false
171+ """
172+ }
173+ }
174+
175+ then {
176+ assertAll(
177+ { assert process.success },
178+ { assert snapshot(process.out).match() }
179+ )
180+ }
181+ }
182+
108183}
0 commit comments