Skip to content

Commit 25ab149

Browse files
committed
Make use of threads
1 parent d30f78f commit 25ab149

4 files changed

Lines changed: 83 additions & 8 deletions

File tree

modules/nf-core/delly/call/main.nf

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -37,6 +37,7 @@ process DELLY_CALL {
3737
delly \\
3838
call \\
3939
${args} \\
40+
--threads ${task.cpus} \\
4041
${bcf_output} \\
4142
--genome ${fasta} \\
4243
${genotype} \\
Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
process {
2+
withName: "DELLY_CALL" {
3+
cpus = 2
4+
}
5+
}

modules/nf-core/delly/call/tests/main.nf.test

Lines changed: 35 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -45,6 +45,41 @@ nextflow_process {
4545

4646
}
4747

48+
test("homo_sapiens - bam, bai, [], [], [], fasta, fai - cpus") {
49+
50+
config "./cpus.config"
51+
52+
when {
53+
process {
54+
"""
55+
input[0] = [
56+
[ id:'test'], // meta map
57+
file(params.modules_testdata_base_path + "genomics/homo_sapiens/illumina/bam/test2.paired_end.recalibrated.sorted.bam", checkIfExists:true),
58+
file(params.modules_testdata_base_path + "genomics/homo_sapiens/illumina/bam/test2.paired_end.recalibrated.sorted.bam.bai", checkIfExists:true),
59+
[],
60+
[],
61+
[]
62+
]
63+
input[1] = [
64+
[ id:'fasta' ],
65+
file(params.modules_testdata_base_path + "genomics/homo_sapiens/genome/chr21/sequence/genome.fasta", checkIfExists:true)
66+
]
67+
input[2] = [
68+
[ id:'fai' ],
69+
file(params.modules_testdata_base_path + "genomics/homo_sapiens/genome/chr21/sequence/genome.fasta.fai", checkIfExists:true)
70+
]
71+
"""
72+
}
73+
}
74+
75+
then {
76+
assertAll(
77+
{ assert process.success },
78+
{ assert snapshot(sanitizeOutput(process.out)).match() }
79+
)
80+
}
81+
}
82+
4883
test("homo_sapiens - cram, crai, [], [], [], fasta, fai") {
4984

5085
when {

modules/nf-core/delly/call/tests/main.nf.test.snap

Lines changed: 42 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@
4141
{
4242
"id": "test"
4343
},
44-
"test.bcf:md5,de0ac784efa4da9ecd236d4e9b9e99df"
44+
"test.bcf:md5,d4da44c1455810fe699cc63c12b25ff4"
4545
]
4646
],
4747
"csi": [
@@ -61,7 +61,41 @@
6161
]
6262
}
6363
],
64-
"timestamp": "2026-03-27T22:51:33.931579498",
64+
"timestamp": "2026-03-28T00:22:24.774120386",
65+
"meta": {
66+
"nf-test": "0.9.4",
67+
"nextflow": "25.10.4"
68+
}
69+
},
70+
"homo_sapiens - bam, bai, [], [], [], fasta, fai - cpus": {
71+
"content": [
72+
{
73+
"bcf": [
74+
[
75+
{
76+
"id": "test"
77+
},
78+
"test.bcf:md5,d4da44c1455810fe699cc63c12b25ff4"
79+
]
80+
],
81+
"csi": [
82+
[
83+
{
84+
"id": "test"
85+
},
86+
"test.bcf.csi:md5,c198abfc14584c5ac69c004057927e0b"
87+
]
88+
],
89+
"versions_delly": [
90+
[
91+
"DELLY_CALL",
92+
"delly",
93+
"1.7.3"
94+
]
95+
]
96+
}
97+
],
98+
"timestamp": "2026-03-28T00:21:15.58823983",
6599
"meta": {
66100
"nf-test": "0.9.4",
67101
"nextflow": "25.10.4"
@@ -75,7 +109,7 @@
75109
{
76110
"id": "test"
77111
},
78-
"test.bcf:md5,de0ac784efa4da9ecd236d4e9b9e99df"
112+
"test.bcf:md5,d4da44c1455810fe699cc63c12b25ff4"
79113
]
80114
],
81115
"csi": [
@@ -95,7 +129,7 @@
95129
]
96130
}
97131
],
98-
"timestamp": "2026-03-27T22:50:57.395295355",
132+
"timestamp": "2026-03-28T00:21:38.783461969",
99133
"meta": {
100134
"nf-test": "0.9.4",
101135
"nextflow": "25.10.4"
@@ -109,7 +143,7 @@
109143
{
110144
"id": "test"
111145
},
112-
"test.bcf:md5,de0ac784efa4da9ecd236d4e9b9e99df"
146+
"test.bcf:md5,d4da44c1455810fe699cc63c12b25ff4"
113147
]
114148
],
115149
"csi": [
@@ -129,7 +163,7 @@
129163
]
130164
}
131165
],
132-
"timestamp": "2026-03-27T22:51:14.902129068",
166+
"timestamp": "2026-03-28T00:22:01.408245362",
133167
"meta": {
134168
"nf-test": "0.9.4",
135169
"nextflow": "25.10.4"
@@ -143,7 +177,7 @@
143177
{
144178
"id": "test"
145179
},
146-
"test.vcf.gz:md5,e030fce4d07043b1b1101238394f0b58"
180+
"test.vcf.gz:md5,0a81ce46f60c9216891e6470ef6f9890"
147181
]
148182
],
149183
"csi": [
@@ -163,7 +197,7 @@
163197
]
164198
}
165199
],
166-
"timestamp": "2026-03-27T22:50:35.147896323",
200+
"timestamp": "2026-03-28T00:20:44.631319255",
167201
"meta": {
168202
"nf-test": "0.9.4",
169203
"nextflow": "25.10.4"

0 commit comments

Comments
 (0)