Extending tests for sentieon joint germline AND avoiding duplicated variants in VQSR vcfs

subworkflows/local/bam_variant_calling_germline_all/main.nf

@@ -190,22 +190,16 @@ workflow BAM_VARIANT_CALLING_GERMLINE_ALL {
             dbsnp,
             dbsnp_tbi,
             dbsnp_vqsr,
-            known_sites_indels,
-            known_sites_indels_tbi,
-            known_indels_vqsr,
-            known_sites_snps,
-            known_sites_snps_tbi,
-            known_snps_vqsr,
             intervals,
-            intervals_bed_combined_haplotypec,
-            (skip_tools && skip_tools.split(',').contains('haplotyper_filter')),
             joint_germline,
             sentieon_haplotyper_emit_mode)
 
         versions = versions.mix(BAM_VARIANT_CALLING_SENTIEON_HAPLOTYPER.out.versions)
 
-        vcf_sentieon_haplotyper = BAM_VARIANT_CALLING_SENTIEON_HAPLOTYPER.out.vcf
-        gvcf_sentieon_haplotyper = BAM_VARIANT_CALLING_SENTIEON_HAPLOTYPER.out.gvcf
+        vcf_sentieon_haplotyper      = BAM_VARIANT_CALLING_SENTIEON_HAPLOTYPER.out.vcf
+        vcf_tbi_sentieon_haplotyper  = BAM_VARIANT_CALLING_SENTIEON_HAPLOTYPER.out.vcf_tbi
+        gvcf_sentieon_haplotyper     = BAM_VARIANT_CALLING_SENTIEON_HAPLOTYPER.out.gvcf
+        gvcf_tbi_sentieon_haplotyper = BAM_VARIANT_CALLING_SENTIEON_HAPLOTYPER.out.gvcf_tbi
 
         if (joint_germline) {
             BAM_JOINT_CALLING_GERMLINE_SENTIEON(
@@ -223,11 +217,29 @@ workflow BAM_VARIANT_CALLING_GERMLINE_ALL {
                 known_sites_snps_tbi,
                 known_snps_vqsr)
 
+            // TO-DO: Should this VCF from the sentieon haploTYPER really be put into a variable called vcf_haploTYPECALLER
+            // The vcf_haplotypecaller is just being sent to annotation in sarek.nf
             vcf_haplotypecaller = BAM_JOINT_CALLING_GERMLINE_SENTIEON.out.genotype_vcf
             versions = versions.mix(BAM_JOINT_CALLING_GERMLINE_SENTIEON.out.versions)
+        } else {
 
-        }
+            // If single sample track, check if filtering should be done
+            if (!skip_haplotyper_filter) {
+
+                VCF_VARIANT_FILTERING_GATK(
+                    vcf_sentieon_haplotyper.join(vcf_tbi_sentieon_haplotyper, failOnDuplicate: true, failOnMismatch: true),
+                    fasta,
+                    fasta_fai,
+                    dict.map{ meta, dict -> [ dict ] },
+                    intervals_bed_combined_haplotypec,
+                    known_sites_indels.concat(known_sites_snps).flatten().unique().collect(),
+                    known_sites_indels_tbi.concat(known_sites_snps_tbi).flatten().unique().collect())
+
+                vcf_haplotypecaller = VCF_VARIANT_FILTERING_GATK.out.filtered_vcf
 
+                versions = versions.mix(VCF_VARIANT_FILTERING_GATK.out.versions)
+            }
+        }
     }
 
     // STRELKA

subworkflows/local/bam_variant_calling_sentieon_haplotyper/main.nf

@@ -7,7 +7,6 @@
 include { GATK4_MERGEVCFS            as MERGE_SENTIEON_HAPLOTYPER_GVCFS } from '../../../modules/nf-core/gatk4/mergevcfs/main'
 include { GATK4_MERGEVCFS            as MERGE_SENTIEON_HAPLOTYPER_VCFS  } from '../../../modules/nf-core/gatk4/mergevcfs/main'
 include { SENTIEON_HAPLOTYPER                                           } from '../../../modules/nf-core/sentieon/haplotyper/main'
-include { VCF_VARIANT_FILTERING_GATK                                    } from '../vcf_variant_filtering_gatk/main'
 
 workflow BAM_VARIANT_CALLING_SENTIEON_HAPLOTYPER {
     take:
@@ -18,23 +17,15 @@ workflow BAM_VARIANT_CALLING_SENTIEON_HAPLOTYPER {
     dbsnp                          // channel: [optional]
     dbsnp_tbi                      // channel: [optional]
     dbsnp_vqsr                     // channel: [optional]
-    known_sites_indels             // channel: [optional]
-    known_sites_indels_tbi         // channel: [optional]
-    known_indels_vqsr              // channel: [optional]
-    known_sites_snps               // channel: [optional]
-    known_sites_snps_tbi           // channel: [optional]
-    known_snps_vqsr                // channel: [optional]
     intervals                      // channel: [mandatory] [ intervals, num_intervals ] or [ [], 0 ] if no intervals
-    intervals_bed_combined         // channel: [mandatory] intervals/target regions in one file unzipped, no_intervals.bed if no_intervals
-    skip_haplotyper_filter         // boolean: [mandatory] [default: false] skip haplotyper filter
     joint_germline                 // boolean: [mandatory] [default: false] joint calling of germline variants
     sentieon_haplotyper_emit_mode
 
     main:
     versions = Channel.empty()
 
-    gvcf = Channel.empty()
-    vcf = Channel.empty()
+    gvcf               = Channel.empty()
+    vcf                = Channel.empty()
     genotype_intervals = Channel.empty()
 
     // Combine cram and intervals for spread and gather strategy
@@ -73,25 +64,37 @@ workflow BAM_VARIANT_CALLING_SENTIEON_HAPLOTYPER {
     }
 
     // Figure out if using intervals or no_intervals
-    SENTIEON_HAPLOTYPER.out.vcf.branch{
-        intervals:    it[0].num_intervals > 1
-        no_intervals: it[0].num_intervals <= 1
-    }.set{haplotyper_vcf_branch}
-
-    SENTIEON_HAPLOTYPER.out.vcf_tbi.branch{
-        intervals:    it[0].num_intervals > 1
-        no_intervals: it[0].num_intervals <= 1
-    }.set{haplotyper_vcf_tbi_branch}
-
-    SENTIEON_HAPLOTYPER.out.gvcf.branch{
-        intervals:    it[0].num_intervals > 1
-        no_intervals: it[0].num_intervals <= 1
-    }.set{haplotyper_gvcf_branch}
-
-    SENTIEON_HAPLOTYPER.out.gvcf_tbi.branch{
-        intervals:    it[0].num_intervals > 1
-        no_intervals: it[0].num_intervals <= 1
-    }.set{haplotyper_gvcf_tbi_branch}
+    haplotyper_vcf_branch = SENTIEON_HAPLOTYPER.out.vcf.map{
+            meta, vcf -> [ meta - meta.subMap('interval_name'), vcf]
+        }
+        .branch{
+            intervals:    it[0].num_intervals > 1
+            no_intervals: it[0].num_intervals <= 1
+        }
+
+    haplotyper_vcf_tbi_branch = SENTIEON_HAPLOTYPER.out.vcf_tbi.map{
+            meta, vcf_tbi -> [ meta - meta.subMap('interval_name'), vcf_tbi]
+        }
+        .branch{
+            intervals:    it[0].num_intervals > 1
+            no_intervals: it[0].num_intervals <= 1
+        }
+
+    haplotyper_gvcf_branch = SENTIEON_HAPLOTYPER.out.gvcf.map{
+            meta, gvcf -> [ meta - meta.subMap('interval_name'), gvcf]
+        }
+        .branch{
+            intervals:    it[0].num_intervals > 1
+            no_intervals: it[0].num_intervals <= 1
+        }
+
+    haplotyper_gvcf_tbi_branch = SENTIEON_HAPLOTYPER.out.gvcf_tbi.map{
+            meta, gvcf_tbi -> [ meta - meta.subMap('interval_name'), gvcf_tbi]
+        }
+        .branch{
+            intervals:    it[0].num_intervals > 1
+            no_intervals: it[0].num_intervals <= 1
+        }
 
     vcfs_for_merging = haplotyper_vcf_branch.intervals.map{
         meta, vcf -> [ groupKey(meta, meta.num_intervals), vcf ]}
@@ -113,25 +116,9 @@ workflow BAM_VARIANT_CALLING_SENTIEON_HAPLOTYPER {
         MERGE_SENTIEON_HAPLOTYPER_VCFS.out.tbi,
         haplotyper_vcf_tbi_branch.no_intervals)
 
-    if (!skip_haplotyper_filter) {
-        VCF_VARIANT_FILTERING_GATK(
-            haplotyper_vcf.join(
-                haplotyper_tbi,
-                failOnDuplicate: true,
-                failOnMismatch: true),
-            fasta,
-            fasta_fai,
-            dict.map{ meta, dict -> [ dict ] },
-            intervals_bed_combined,
-            known_sites_indels.concat(known_sites_snps).flatten().unique().collect(),
-            known_sites_indels_tbi.concat(known_sites_snps_tbi).flatten().unique().collect())
-
-        vcf = VCF_VARIANT_FILTERING_GATK.out.filtered_vcf.map{meta, vcf -> [meta + [variantcaller:"sentieon_haplotyper"], vcf]}
-        versions = versions.mix(VCF_VARIANT_FILTERING_GATK.out.versions)
-    } else vcf = haplotyper_vcf
-
     // Remove no longer necessary field: num_intervals
-    vcf = vcf.map{ meta, vcf -> [ meta - meta.subMap('num_intervals'), vcf ] }
+    vcf = haplotyper_vcf.map{ meta, vcf -> [ meta - meta.subMap('num_intervals'), vcf ] }
+    vcf_tbi = haplotyper_tbi.map{ meta, tbi -> [ meta - meta.subMap('num_intervals'), tbi ] }
 
     // GVFs
     // Only when using intervals
@@ -148,14 +135,20 @@ workflow BAM_VARIANT_CALLING_SENTIEON_HAPLOTYPER {
         MERGE_SENTIEON_HAPLOTYPER_GVCFS.out.vcf,
         haplotyper_gvcf_branch.no_intervals)
 
+    gvcf_tbi = Channel.empty().mix(
+        MERGE_SENTIEON_HAPLOTYPER_GVCFS.out.tbi,
+        haplotyper_gvcf_tbi_branch.no_intervals)
+
     versions = versions.mix(SENTIEON_HAPLOTYPER.out.versions)
     versions = versions.mix(MERGE_SENTIEON_HAPLOTYPER_VCFS.out.versions)
     versions = versions.mix(MERGE_SENTIEON_HAPLOTYPER_GVCFS.out.versions)
 
     emit:
     versions
     vcf
+    vcf_tbi
     gvcf
+    gvcf_tbi
     genotype_intervals // For joint genotyping
 
 }

tests/test_sentieon_joint_germline.yml

@@ -55,3 +55,37 @@
     - path: results/variant_calling/sentieon_haplotyper/testT/testT.haplotyper.g.vcf.gz.tbi
     - path: results/haplotyper
       should_exist: false
+
+- name: Run joint germline variant calling with sentieon haplotyper with stub for VQSR
+  command: nextflow run main.nf -profile test_cache,tools_germline --input ./tests/csv/3.0/mapped_joint_bam.csv --tools sentieon_haplotyper --step variant_calling --joint_germline --outdir results --sentieon_haplotyper_emit_mode gvcf -stub-run
+  tags:
+    - germline
+    - sentieon_joint_germline
+    - variant_calling
+    - vqsr
+  files:
+    - path: results/csv/variantcalled.csv
+      md5sum: b9d926c0bbb9c31d7659051ce98196d2
+    - path: results/multiqc
+    - path: results/preprocessing/recalibrated/test/test.recal.cram
+      should_exist: false
+    - path: results/preprocessing/recalibrated/test/test.recal.cram.crai
+      should_exist: false
+    - path: results/reports/bcftools/sentieon_haplotyper/joint_variant_calling/joint_germline_recalibrated.bcftools_stats.txt
+    - path: results/reports/vcftools/sentieon_haplotyper/joint_variant_calling/joint_germline_recalibrated.FILTER.summary
+    - path: results/reports/vcftools/sentieon_haplotyper/joint_variant_calling/joint_germline_recalibrated.TsTv.count
+    - path: results/reports/vcftools/sentieon_haplotyper/joint_variant_calling/joint_germline_recalibrated.TsTv.qual
+    - path: results/reports/bcftools/sentieon_haplotyper/recalibrated_joint_variant_calling/joint_germline_recalibrated.bcftools_stats.txt
+    - path: results/reports/vcftools/sentieon_haplotyper/recalibrated_joint_variant_calling/joint_germline_recalibrated.FILTER.summary
+    - path: results/reports/vcftools/sentieon_haplotyper/recalibrated_joint_variant_calling/joint_germline_recalibrated.TsTv.count
+    - path: results/reports/vcftools/sentieon_haplotyper/recalibrated_joint_variant_calling/joint_germline_recalibrated.TsTv.qual
+    - path: results/variant_calling/sentieon_haplotyper/joint_variant_calling/joint_germline.vcf.gz
+    - path: results/variant_calling/sentieon_haplotyper/joint_variant_calling/joint_germline.vcf.gz.tbi
+    - path: results/variant_calling/sentieon_haplotyper/joint_variant_calling/joint_germline_recalibrated.vcf.gz
+    - path: results/variant_calling/sentieon_haplotyper/joint_variant_calling/joint_germline_recalibrated.vcf.gz.tbi
+    - path: results/variant_calling/sentieon_haplotyper/testN/testN.haplotyper.g.vcf.gz
+    - path: results/variant_calling/sentieon_haplotyper/testN/testN.haplotyper.g.vcf.gz.tbi
+    - path: results/variant_calling/sentieon_haplotyper/testT/testT.haplotyper.g.vcf.gz
+    - path: results/variant_calling/sentieon_haplotyper/testT/testT.haplotyper.g.vcf.gz.tbi
+    - path: results/haplotyper
+      should_exist: false