Skip to content

Commit

Permalink
reconnect to the overall workflow [ci skip]
Browse files Browse the repository at this point in the history
  • Loading branch information
abhi18av committed Jun 23, 2024
1 parent 68ff034 commit 4f418eb
Showing 1 changed file with 9 additions and 11 deletions.
20 changes: 9 additions & 11 deletions workflows/validate_fastqs_wf.nf
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,6 @@ workflow VALIDATE_FASTQS_WF {



/*
FASTQ_VALIDATOR( fastqs_ch, ready )


Expand All @@ -39,19 +38,18 @@ workflow VALIDATE_FASTQS_WF {

approved_fastqs_ch = UTILS_FASTQ_COHORT_VALIDATION.out.magma_analysis_json
.splitJson()
.filter {it.value.fastqs_approved}
.map {
if (it.value.R2) {
[it.value.magma_sample_name, it.value.magma_bam_rg_string, [it.value.R1, it.value.R2]]
} else {
[it.value.magma_sample_name, it.value.magma_bam_rg_string, [it.value.R1]]
}
}
.filter {it.value.fastqs_approved}
.map {
if (it.value.R2) {
[it.value.magma_sample_name, it.value.magma_bam_rg_string, [it.value.R1, it.value.R2]]
} else {
[it.value.magma_sample_name, it.value.magma_bam_rg_string, [it.value.R1]]
}
}

emit:

passed_fastqs_ch = approved_fastqs_ch
passed_fastqs_ch = approved_fastqs_ch

*/

}

0 comments on commit 4f418eb

Please sign in to comment.