@@ -82,7 +82,7 @@ process prepareBam {
82
82
set val(name),
83
83
val(" ${ bam.baseName} " ),
84
84
val(type), file(" ${ bam.baseName} .prepared.bam" ),
85
- file(" ${ bam.baseName} .prepared.bai" ) into prepared_bams, prepared_bams_for_metrics, prepared_bams_for_hs_metrics
85
+ file(" ${ bam.baseName} .prepared.bai" ) into prepared_bams
86
86
87
87
"""
88
88
mkdir tmp
@@ -128,7 +128,8 @@ if (!params.skip_deduplication) {
128
128
129
129
output:
130
130
set val(name), val(bam_name), val(type),
131
- file(" ${ bam.baseName} .dedup.bam" ), file(" ${ bam.baseName} .dedup.bam.bai" ) into deduplicated_bams
131
+ file(" ${ bam.baseName} .dedup.bam" ), file(" ${ bam.baseName} .dedup.bam.bai" ) into deduplicated_bams,
132
+ deduplicated_bams_for_metrics, deduplicated_bams_for_hs_metrics
132
133
file(" ${ bam.baseName} .dedup_metrics" ) optional true into deduplication_metrics
133
134
134
135
script:
@@ -146,7 +147,7 @@ if (!params.skip_deduplication) {
146
147
}
147
148
}
148
149
else {
149
- deduplicated_bams = prepared_bams
150
+ prepared_bams . into{ deduplicated_bams; deduplicated_bams_for_metrics; deduplicated_bams_for_hs_metrics}
150
151
}
151
152
152
153
if (! params. skip_metrics) {
@@ -160,7 +161,7 @@ if (! params.skip_metrics) {
160
161
publishDir " ${ publish_dir} /${ name} /metrics" , mode: " copy"
161
162
162
163
input:
163
- set name, bam_name, type, file(bam), file(bai) from prepared_bams_for_hs_metrics
164
+ set name, bam_name, type, file(bam), file(bai) from deduplicated_bams_for_hs_metrics
164
165
165
166
output:
166
167
file(" *_metrics" ) optional true into txt_hs_metrics
@@ -200,7 +201,7 @@ if (! params.skip_metrics) {
200
201
publishDir " ${ publish_dir} /${ name} /metrics" , mode: " copy"
201
202
202
203
input:
203
- set name, bam_name, type, file(bam), file(bai) from prepared_bams_for_metrics
204
+ set name, bam_name, type, file(bam), file(bai) from deduplicated_bams_for_metrics
204
205
205
206
output:
206
207
file(" *_metrics" ) optional true into txt_metrics
0 commit comments