Skip to content
Snippets Groups Projects
Commit ea975126 authored by nservant's avatar nservant
Browse files

update split_fastq

parent b1162124
No related branches found
No related tags found
No related merge requests found
...@@ -17,11 +17,15 @@ workflow INPUT_CHECK { ...@@ -17,11 +17,15 @@ workflow INPUT_CHECK {
.splitCsv ( header:true, sep:',' ) .splitCsv ( header:true, sep:',' )
.map { create_fastq_channels(it) } .map { create_fastq_channels(it) }
.splitFastq( by: params.fastq_chunks_size, pe:true, file: true, compress:true) .splitFastq( by: params.fastq_chunks_size, pe:true, file: true, compress:true)
.map { it -> .map { it -> [it[0], [it[1], it[2]]]}
def meta = it[0].clone() .groupTuple(by: [0])
meta.chunk = it[1].baseName - ~/.fastq(.gz)?/ .flatMap { it -> setMetaChunk(it) }
return [meta, [it[1], it[2]]] .collate(2)
} //.map { it ->
// def meta = it[0].clone()
// meta.chunk = it[1].baseName - ~/.fastq(.gz)?/
// return [meta, [it[1], it[2]]]
//}
.set { reads } .set { reads }
}else{ }else{
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment