From 1852fe84ead82b3e1d26bd8d9c7a510bcf75c7d4 Mon Sep 17 00:00:00 2001
From: Laurent Modolo <laurent.modolo@ens-lyon.fr>
Date: Fri, 7 May 2021 16:24:57 +0200
Subject: [PATCH] flexi_splitter: split computation per plate
---
src/nf_modules/flexi_splitter/main.nf | 10 ++++++++--
1 file changed, 8 insertions(+), 2 deletions(-)
diff --git a/src/nf_modules/flexi_splitter/main.nf b/src/nf_modules/flexi_splitter/main.nf
index 50e41ac3..753ef1be 100644
--- a/src/nf_modules/flexi_splitter/main.nf
+++ b/src/nf_modules/flexi_splitter/main.nf
@@ -12,9 +12,15 @@ workflow split {
main:
split_fastq(reads, config)
group_fastq(split_fastq.out.fastq_folder)
+ group_fastq.out.fastq
+ .map{ it -> it[1] }
+ .flatten()
+ .collate(2)
+ .map{ it -> [it[0].simpleName - ~/_{0,1}R[12]/, it]}
+ .set{ splited_fastq }
emit:
- fastq = group_fastq.out.fastq
+ fastq = splited_fastq
}
process split_fastq {
@@ -54,7 +60,7 @@ process split_fastq {
process group_fastq {
container = "${container_url}"
label "big_mem_mono_cpus"
- tag "$file_prefix"
+ tag "$file_id"
if (params.split_out != "") {
publishDir "results/${params.split_out}", mode: 'copy'
}
--
GitLab