mirror of
https://github.com/MillironX/taxprofiler.git
synced 2024-11-22 18:49:55 +00:00
Changes after code review
This commit is contained in:
parent
a15c45b00c
commit
16a3556bfc
1 changed files with 3 additions and 2 deletions
|
@ -139,15 +139,16 @@ workflow TAXPROFILER {
|
||||||
meta_new.remove('run_accession')
|
meta_new.remove('run_accession')
|
||||||
[ meta_new, reads ]
|
[ meta_new, reads ]
|
||||||
}
|
}
|
||||||
.groupTuple(by: 0)
|
.groupTuple()
|
||||||
.map {
|
.map {
|
||||||
meta, reads ->
|
meta, reads ->
|
||||||
[ meta, reads.flatten() ]
|
[ meta, reads.flatten() ]
|
||||||
}
|
}
|
||||||
.branch {
|
.branch {
|
||||||
|
meta, reads ->
|
||||||
// we can't concatenate files if there is not a second run, we branch
|
// we can't concatenate files if there is not a second run, we branch
|
||||||
// here to separate them out, and mix back in after for efficiency
|
// here to separate them out, and mix back in after for efficiency
|
||||||
cat: ( it[0]['single_end'] && it[1].size() > 1 ) || ( !it[0]['single_end'] && it[1].size() > 2 )
|
cat: ( meta.single_end && reads.size() > 1 ) || ( !meta.single_end && reads.size() > 2 )
|
||||||
skip: true
|
skip: true
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue