diff --git a/src/SNP_calling.nf b/src/SNP_calling.nf index 84027a8d56450222387e2ec45b94d7a6bee926cc..9fd40b14654feefc0e7845bf35c710e8e1051e18 100644 --- a/src/SNP_calling.nf +++ b/src/SNP_calling.nf @@ -107,13 +107,29 @@ fi """ } +fastq_files_trim.into{ + fastq_files_trim_norm; + fastq_files_trim_tumor +} + +collect_fastq_files_trim_norm = fastq_files_trim_norm + .filter{ normal_sample.contains(it[0]) } + .map { it -> ["normal_sample", it[0], it[1]]} + +collect_fastq_files_trim_tumor = fastq_files_trim_tumor + .filter{ tumor_sample.contains(it[0]) } + .map { it -> ["tumor_sample", it[0], it[1]]} + +collect_fastq_files_trim = Channel.create() + .mix(collect_fastq_files_trim_norm, collect_fastq_files_trim_tumor) + process mapping_fastq { tag "$pair_id" cpus 12 publishDir "results/mapping/bam/", mode: 'copy' input: - set pair_id, file(reads) from fastq_files_trim + set sample_name, pair_id, file(reads) from collect_fastq_files_trim file index from index_files.collect() output: