Skip to content
Snippets Groups Projects
Commit af259d7d authored by Pappas's avatar Pappas
Browse files

centrifuge input from File to Array[File] and style fixes

parent fc01ad36
No related branches found
No related tags found
1 merge request!16Centrifuge related changes
# Copyright Sequencing Analysis Support Core - Leiden University Medical Center 2018 # Copyright Sequencing Analysis Support Core - Leiden University Medical Center 2018
# #
# Tasks from centrifuge # Tasks from centrifuge
task build { task Build {
File conversionTable File conversionTable
File taxonomyTree File taxonomyTree
File inputFasta File inputFasta
...@@ -22,9 +21,10 @@ task build { ...@@ -22,9 +21,10 @@ task build {
File? nameTable File? nameTable
File? sizeTable File? sizeTable
Int? seed Int? seed
Int? kmerCount
Int? threads Int? threads
Int? memory Int? memory
Int? kmerCount
command { command {
set -e -o pipefail set -e -o pipefail
...@@ -56,25 +56,28 @@ task build { ...@@ -56,25 +56,28 @@ task build {
} }
} }
task classify { task Classify {
String outputDir String outputDir
Boolean? compressOutput = true Boolean? compressOutput = true
String? preCommand String? preCommand
String indexPrefix String indexPrefix
File? unpairedReads Array[File]? unpairedReads
File read1 Array[File]+ read1
File? read2 Array[File]? read2
Boolean? fastaInput Boolean? fastaInput
# Variables for handling output # Variables for handling output
String outputFileName = outputDir + "/centrifuge.out" String outputFilePath = outputDir + "/centrifuge.out"
String reportFileName = outputDir + "/centrifuge_report.tsv" String reportFilePath = outputDir + "/centrifuge_report.tsv"
String finalOutputName = if (compressOutput == true) then outputFileName + ".gz" else outputFileName String finalOutputPath = if (compressOutput == true)
String? metFileName # If this is specified, the report file is empty then outputFilePath + ".gz"
else outputFilePath
String? metFilePath # If this is specified, the report file is empty
Int? assignments Int? assignments
Int? minHitLen Int? minHitLen
Int? minTotalLen Int? minTotalLen
Array[String]? hostTaxIds Array[String]? hostTaxIds
Array[String]? excludeTaxIds Array[String]? excludeTaxIds
Int? threads Int? threads
Int? memory Int? memory
...@@ -86,22 +89,22 @@ task classify { ...@@ -86,22 +89,22 @@ task classify {
${"-p " + threads} \ ${"-p " + threads} \
${"-x " + indexPrefix} \ ${"-x " + indexPrefix} \
${true="-f" false="" fastaInput} \ ${true="-f" false="" fastaInput} \
${true="-k " false="" defined(assignments)} ${assignments} \ ${true="-k" false="" defined(assignments)} ${assignments} \
${true="-1 " false="-U " defined(read2)} ${read1} \ ${true="-1" false="-U" defined(read2)} ${sep=',' read1} \
${"-2 " + read2} \ ${true="-2" false="" defined(read2)} ${sep=',' read2} \
${"-U " + unpairedReads} \ ${true="-U" false="" defined(unpairedReads)} ${sep=',' unpairedReads}\
${"--report-file " + reportFileName} \ ${"--report-file " + reportFilePath} \
${"--min-hitlen " + minHitLen} \ ${"--min-hitlen " + minHitLen} \
${"--min-totallen " + minTotalLen} \ ${"--min-totallen " + minTotalLen} \
${"--met-file " + metFileName} \ ${"--met-file " + metFilePath} \
${true="--host-taxids " false="" defined(hostTaxIds)} ${sep=',' hostTaxIds} \ ${true="--host-taxids " false="" defined(hostTaxIds)} ${sep=',' hostTaxIds} \
${true="--exclude-taxids " false="" defined(excludeTaxIds)} ${sep=',' excludeTaxIds} \ ${true="--exclude-taxids " false="" defined(excludeTaxIds)} ${sep=',' excludeTaxIds} \
${true="| gzip -c >" false="-S" compressOutput} ${finalOutputName} ${true="| gzip -c >" false="-S" compressOutput} ${finalOutputPath}
} }
output { output {
File classifiedReads = finalOutputName File classifiedReads = finalOutputPath
File reportFile = reportFileName File reportFile = reportFilePath
} }
runtime { runtime {
...@@ -110,7 +113,7 @@ task classify { ...@@ -110,7 +113,7 @@ task classify {
} }
} }
task download { task Download {
String libraryPath String libraryPath
Array[String]? domain Array[String]? domain
String? executable = "centrifuge-download" String? executable = "centrifuge-download"
...@@ -153,10 +156,11 @@ task download { ...@@ -153,10 +156,11 @@ task download {
} }
} }
task downloadTaxonomy { task DownloadTaxonomy {
String centrifugeTaxonomyDir String centrifugeTaxonomyDir
String? executable = "centrifuge-download" String? executable = "centrifuge-download"
String? preCommand String? preCommand
command { command {
set -e -o pipefail set -e -o pipefail
${preCommand} ${preCommand}
...@@ -164,23 +168,25 @@ task downloadTaxonomy { ...@@ -164,23 +168,25 @@ task downloadTaxonomy {
-o ${centrifugeTaxonomyDir} \ -o ${centrifugeTaxonomyDir} \
taxonomy taxonomy
} }
output { output {
File taxonomyTree = centrifugeTaxonomyDir + "/nodes.dmp" File taxonomyTree = centrifugeTaxonomyDir + "/nodes.dmp"
File nameTable = centrifugeTaxonomyDir + "/names.dmp" File nameTable = centrifugeTaxonomyDir + "/names.dmp"
} }
} }
task kreport { task Kreport {
String? preCommand String? preCommand
File centrifugeOut File centrifugeOut
Boolean inputIsCompressed Boolean inputIsCompressed
String kreportFileName=sub(centrifugeOut, "\\.out$|\\.out\\.gz$", "\\.kreport") String kreportFilePath=sub(centrifugeOut, "\\.out$|\\.out\\.gz$", "\\.kreport")
String indexPrefix String indexPrefix
Boolean? onlyUnique Boolean? onlyUnique
Boolean? showZeros Boolean? showZeros
Boolean? isCountTable Boolean? isCountTable
Int? minScore Int? minScore
Int? minLength Int? minLength
Int? cores Int? cores
Int? memory Int? memory
...@@ -196,11 +202,11 @@ task kreport { ...@@ -196,11 +202,11 @@ task kreport {
${"--min-length " + minLength} \ ${"--min-length " + minLength} \
${true="<(zcat" false="" inputIsCompressed} ${centrifugeOut}\ ${true="<(zcat" false="" inputIsCompressed} ${centrifugeOut}\
${true=")" false="" inputIsCompressed} \ ${true=")" false="" inputIsCompressed} \
> ${kreportFileName} > ${kreportFilePath}
} }
output { output {
File kreport = kreportFileName File kreport = kreportFilePath
} }
runtime { runtime {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment