kkonganti@11: process MASURCA_POLISH { kkonganti@11: tag "$meta.id" kkonganti@11: label 'process_micro' kkonganti@11: kkonganti@11: module (params.enable_module ? "${params.swmodulepath}${params.fs}masurca${params.fs}4.1.0" : null) kkonganti@11: conda (params.enable_conda ? "bioconda::masurca=4.1.0 conda-forge::libgcc-ng" : null) kkonganti@11: container "${ workflow.containerEngine == 'singularity' && !task.ext.singularity_pull_docker_container ? kkonganti@11: 'https://depot.galaxyproject.org/singularity/masurca:4.1.0--pl5321hb5bd705_1' : kkonganti@11: 'quay.io/biocontainers/masurca:4.1.0--pl5321hb5bd705_1' }" kkonganti@11: kkonganti@11: input: kkonganti@11: tuple val(meta), path(contigs), path(reads) kkonganti@11: kkonganti@11: output: kkonganti@11: tuple val(meta), path("${prefix}_contigs.fa"), emit: polished kkonganti@11: path "versions.yml" , emit: versions kkonganti@11: kkonganti@11: when: kkonganti@11: task.ext.when == null || task.ext.when kkonganti@11: kkonganti@11: script: kkonganti@11: def args = task.ext.args ?: '' kkonganti@11: def memory = (task.memory ? task.memory.toGiga() : 16) kkonganti@11: def mem_per_thread = memory.toGiga().toInteger().div(task.cpus.toInteger()).round(0) kkonganti@11: def all_reads = "${reads.join(' ')}" kkonganti@11: prefix = (task.ext.prefix ?: meta.id) kkonganti@11: """ kkonganti@11: polca.sh \\ kkonganti@11: -a $contigs \\ kkonganti@11: -r '${all_reads}' \\ kkonganti@11: -t $task.cpus \\ kkonganti@11: -m $mem_per_thread \\ kkonganti@11: $args \\ kkonganti@11: kkonganti@11: mv 'contigs.fa' "${prefix}.contigs.fa" kkonganti@11: kkonganti@11: cat <<-END_VERSIONS > versions.yml kkonganti@11: "${task.process}": kkonganti@11: masurca: \$(echo \$(masurca --version 2>&1) | sed 's/^.*version //') kkonganti@11: END_VERSIONS kkonganti@11: """ kkonganti@11: }