Skip to content
Snippets Groups Projects
Commit 0dc72531 authored by Cats's avatar Cats
Browse files

fix somatic tasks and add supporting tasks

parent c3f2adf6
No related branches found
No related tags found
1 merge request!43fix somatic tasks and add supporting tasks
...@@ -298,7 +298,7 @@ task MuTect2 { ...@@ -298,7 +298,7 @@ task MuTect2 {
String? preCommand String? preCommand
Array[File]+ inputBams Array[File]+ inputBams
File inputBamIndex Array[File]+ inputBamIndex
File refFasta File refFasta
File refFastaIndex File refFastaIndex
File refDict File refDict
...@@ -331,6 +331,7 @@ task MuTect2 { ...@@ -331,6 +331,7 @@ task MuTect2 {
output { output {
File vcfFile = outputVcf File vcfFile = outputVcf
File vcfIndex = outputVcf + ".tbi"
} }
runtime { runtime {
......
version 1.0 version 1.0
struct Readgroup { struct Readgroup {
String id String id
File R1 File R1
...@@ -15,9 +16,10 @@ struct Library { ...@@ -15,9 +16,10 @@ struct Library {
struct Sample { struct Sample {
String id String id
Array[Library]+ libraries Array[Library]+ libraries
String? control
} }
task sampleConfigFileToStruct { task SampleConfigFileToStruct {
input { input {
File sampleConfigFile File sampleConfigFile
String outputJson = "output.json" String outputJson = "output.json"
...@@ -69,5 +71,5 @@ task sampleConfigFileToStruct { ...@@ -69,5 +71,5 @@ task sampleConfigFileToStruct {
output { output {
Map[String,Array[Sample]] map = read_json(outputJson) Map[String,Array[Sample]] map = read_json(outputJson)
Array[Sample] samples = map["samples"] Array[Sample] samples = map["samples"]
} }
} }
version 1.0 version 1.0
task BgzipAndIndex {
input {
File inputFile
String outputDir
String type = "vcf"
}
String outputGz = outputDir + "/" + basename(inputFile) + ".gz"
command {
bgzip -c ~{inputFile} > ~{outputGz}
tabix ~{outputGz} -p ~{type}
}
output {
File compressed = outputGz
File index = outputGz + ".tbi"
}
}
task Index { task Index {
input { input {
String? preCommand String? preCommand
...@@ -131,6 +151,21 @@ task Fastq { ...@@ -131,6 +151,21 @@ task Fastq {
} }
} }
task Tabix {
input {
String inputFile
String type = "vcf"
}
command {
tabix ~{inputFile} -p ~{type}
}
output {
File index = inputFile + ".tbi"
}
}
task View { task View {
input { input {
String? preCommand String? preCommand
......
version 1.0 version 1.0
task Germline {
input {
String? preCommand
String? installDir
String runDir
Array[File]+ bams
Array[File]+ indexes
File refFasta
File? callRegions
File? callRegionsIndex
Boolean exome = false
Boolean rna = false
Int cores = 1
Int memory = 4
}
String toolCommand = if defined(installDir)
then installDir + "bin/configureStrelkaGermlineWorkflow.py"
else "configureStrelkaGermlineWorkflow.py"
command {
set -e -o pipefail
~{preCommand}
~{toolCommand} \
--bam ~{sep=" --bam " bams} \
--ref ~{refFasta} \
--runDir ~{runDir} \
~{"--callRegions" + callRegions} \
~{true="--exome" false="" exome} \
~{true="--rna" false="" rna}
~{runDir}/runWorkflow.py \
-m local \
-J ~{cores} \
-g ~{memory}
}
output {
File variants = runDir + "/results/variants.vcf.gz"
File variantsIndex = runDir + "/results/variants.vcf.gz.tbi"
}
runtime {
cpu: cores
memory: memory
}
}
task Somatic { task Somatic {
input { input {
String? preCommand String? preCommand
String? installDir String? installDir
String runDir String runDir
File normalBam File normalBam
File normalIndex
File tumorBam File tumorBam
File tumorIndex
File refFasta File refFasta
File? callRegions
File? callRegionsIndex
Boolean exome = false
Boolean rna = false
Int cores = 1 Int cores = 1
Int memory = 4 Int memory = 4
...@@ -24,7 +80,9 @@ task Somatic { ...@@ -24,7 +80,9 @@ task Somatic {
--normalBam ~{normalBam} \ --normalBam ~{normalBam} \
--tumorBam ~{tumorBam} \ --tumorBam ~{tumorBam} \
--ref ~{refFasta} \ --ref ~{refFasta} \
--runDir ~{runDir} --runDir ~{runDir} \
~{"--callRegions" + callRegions} \
~{true="--exome" false="" exome} \
~{runDir}/runWorkflow.py \ ~{runDir}/runWorkflow.py \
-m local \ -m local \
......
...@@ -4,12 +4,14 @@ task VarDict { ...@@ -4,12 +4,14 @@ task VarDict {
input { input {
String? installDir String? installDir
String tumorSampleName
File tumorBam File tumorBam
File normalBam File tumorIndex
String? normalSampleName
File? normalBam
File? normalIndex
File refFasta File refFasta
File bedFile File bedFile
String tumorSampleName
String normalSampleName
String outputVcf String outputVcf
Int chromosomeColumn = 1 Int chromosomeColumn = 1
...@@ -30,19 +32,21 @@ task VarDict { ...@@ -30,19 +32,21 @@ task VarDict {
~{toolCommand} \ ~{toolCommand} \
-G ~{refFasta} \ -G ~{refFasta} \
-N ~{tumorSampleName} \ -N ~{tumorSampleName} \
-b "~{tumorBam}|~{normalBam}" \ -b "~{tumorBam}~{"|" + normalBam}" \
-c ~{chromosomeColumn} \ -c ~{chromosomeColumn} \
-S ~{startColumn} \ -S ~{startColumn} \
-E ~{endColumn} \ -E ~{endColumn} \
-g ~{geneColumn} \ -g ~{geneColumn} \
~{bedFile} | \ ~{bedFile} | \
~{installDir + "/"}testsomatic.R | \ ~{installDir + "/"}~{true="testsomatic.R" false="teststrandbias.R" defined(normalBam)} | \
~{installDir + "/"}var2vcf_paired.pl \ ~{installDir + "/"}~{true="var2vcf_paired.pl"
-N "~{tumorSampleName}|~{normalSampleName}" \ false="var2vcf_valid.pl" defined(normalBam)} \
> ~{outputVcf} -N "~{tumorSampleName}~{"|" + normalSampleName}" \
~{true="" false="-E" defined(normalBam)} | \
bgzip -c > ~{outputVcf}
} }
output { output {
File vcfFile = outputVcf File vcfFile = outputVcf
} }
} }
\ No newline at end of file
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