diff --git a/src/main.nf b/src/main.nf index 5034df44fe25910c997e505e8090222c4b15ee25..4d13e99aee9fdb44898adf00dd992d18474b2ed9 100644 --- a/src/main.nf +++ b/src/main.nf @@ -4,8 +4,9 @@ nextflow.enable.dsl=2 Testing pipeline for marseq scRNASeq analysis */ -include { FASTKMERS } from "./modules/fastkmers" include { SPLIT } from "./modules/split" +include { FASTKMERS } from "./modules/fastkmers" +include { MERGEKMER } from "./modules/mergekmer" Channel.fromPath( file(params.csv) ) @@ -21,4 +22,5 @@ Channel.fromPath( file(params.csv) ) workflow { SPLIT(fastq.r1.mix(fastq.r2)) FASTKMERS(SPLIT.out.fastq.transpose()) + MERGEKMER(FASTKMERS.out.csv.view()) } diff --git a/src/modules/fastkmers.nf b/src/modules/fastkmers.nf index ebbdf45db41435ed556dd6f6ab1bf4bf158679e8..c2b0028324fe79d8fa92ba47e64fac6d29f89b36 100644 --- a/src/modules/fastkmers.nf +++ b/src/modules/fastkmers.nf @@ -1,6 +1,3 @@ -/* - * normalize bam file - */ process FASTKMERS { tag "$meta.id" label 'big_mem_mono_cpus' diff --git a/src/modules/mergekmer.nf b/src/modules/mergekmer.nf new file mode 100644 index 0000000000000000000000000000000000000000..d8c4c7dcdc9884d1bf33b9b9af83f9eea469b06c --- /dev/null +++ b/src/modules/mergekmer.nf @@ -0,0 +1,26 @@ +process MERGEKMER { + tag "$meta.id" + label 'big_mem_mono_cpus' + publishDir "results/${meta.specie}/${meta.sex}/${meta.read}/", mode: 'copy' + + container "lbmc/mergekmer:0.1.0" + + input: + tuple val(meta), path(csv) + + output: + tuple val(meta), path("*.csv"), emit: csv + path "versions.yml" , emit: versions + + script: + def args = task.ext.args ?: '' + """ + mergekmer --csv ${csv} -output ${meta.id}.csv + + + cat <<-END_VERSIONS > versions.yml + "${task.process}": + mergekmer: \$(echo \$(mergekmer --version 2>&1)) + END_VERSIONS + """ +}