quartet_dna_quality_control_wgs_big_pipeline/workflow.wdl

import "./tasks/rename_fastq.wdl" as rename_fastq
import "./tasks/rename_vcf.wdl" as rename_vcf
import "./tasks/mapping.wdl" as mapping
import "./tasks/Dedup.wdl" as Dedup
import "./tasks/qualimap.wdl" as qualimap
import "./tasks/deduped_Metrics.wdl" as deduped_Metrics
import "./tasks/sentieon.wdl" as sentieon
import "./tasks/Realigner.wdl" as Realigner
import "./tasks/BQSR.wdl" as BQSR
import "./tasks/Haplotyper.wdl" as Haplotyper
import "./tasks/benchmark.wdl" as benchmark
import "./tasks/multiqc.wdl" as multiqc
import "./tasks/multiqc_hap.wdl" as multiqc_hap
import "./tasks/merge_sentieon_metrics.wdl" as merge_sentieon_metrics
import "./tasks/extract_tables.wdl" as extract_tables
import "./tasks/extract_tables_vcf.wdl" as extract_tables_vcf
import "./tasks/mendelian.wdl" as mendelian
import "./tasks/merge_mendelian.wdl" as merge_mendelian
import "./tasks/quartet_mendelian.wdl" as quartet_mendelian
import "./tasks/fastqc.wdl" as fastqc
import "./tasks/fastqscreen.wdl" as fastqscreen
import "./tasks/merge_family.wdl" as merge_family
import "./tasks/filter_vcf.wdl" as filter_vcf


workflow {{ project_name }} {

	File? fastq_1_D5
	File? fastq_1_D6
	File? fastq_1_F7
	File? fastq_1_M8

	File? fastq_2_D5
	File? fastq_2_D6
	File? fastq_2_F7
	File? fastq_2_M8

	File? vcf_D5
	File? vcf_D6
	File? vcf_F7
	File? vcf_M8

	String REPLACE_SENTIEON_DOCKER
	String DEEPVARIANT_DOCKER
	String FASTQCdocker
	String FASTQSCREENdocker
	String QUALIMAPdocker
	String BENCHMARKdocker
	String MENDELIANdocker
	String DIYdocker
	String MULTIQCdocker
	String BEDTOOLSdocker

	String fasta
	File ref_dir
	File dbmills_dir
	String db_mills
	File dbsnp_dir
	String dbsnp
	String pl

	File screen_ref_dir
	File fastq_screen_conf
	File benchmarking_dir

	String project

	String disk_size
	String BIGcluster_config
	String SMALLcluster_config

	# Fastq is not null, which means starting from fastq
	if (fastq_1_D5 != "" && fastq_2_D5 != ""
		&& fastq_1_D6 != "" && fastq_2_D6 != ""
		&& fastq_1_F7 != "" && fastq_2_F7 != ""
		&& fastq_1_M8 != "" && fastq_2_M8 != "") {

		call mapping.mapping as mapping_D5 {
			input: 
			pl=pl,
			fasta=fasta,
			ref_dir=ref_dir,
			fastq_1=fastq_1_D5,
			fastq_2=fastq_2_D5,
			group=project,
			sample='LCL5',
			project=project,
			docker=REPLACE_SENTIEON_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call fastqc.fastqc as fastqc_D5 {
			input:
			read1=fastq_1_D5,
			read2=fastq_2_D5,
			project=project,
			sample="LCL5",
			docker=FASTQCdocker,
			cluster_config=BIGcluster_config,
			disk_size=disk_size
		}

		call fastqscreen.fastq_screen as fastqscreen_D5 {
			input:
			read1=fastq_1_D5,
			read2=fastq_2_D5,
			project=project,
			sample="LCL5",
			screen_ref_dir=screen_ref_dir,
			fastq_screen_conf=fastq_screen_conf,
			docker=FASTQSCREENdocker,
			cluster_config=BIGcluster_config,
			disk_size=disk_size
		}

		call Dedup.Dedup as Dedup_D5 {
			input:
			sorted_bam=mapping_D5.sorted_bam,
			sorted_bam_index=mapping_D5.sorted_bam_index,
			docker=REPLACE_SENTIEON_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call qualimap.qualimap as qualimap_D5 {
			input:
			bam=Dedup_D5.Dedup_bam,
			bai=Dedup_D5.Dedup_bam_index,
			docker=QUALIMAPdocker,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}		

		call deduped_Metrics.deduped_Metrics as deduped_Metrics_D5 {
			input:
			fasta=fasta,
			ref_dir=ref_dir,
			Dedup_bam=Dedup_D5.Dedup_bam,
			Dedup_bam_index=Dedup_D5.Dedup_bam_index,
			docker=REPLACE_SENTIEON_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call sentieon.sentieon as sentieon_D5 {
			input:
			quality_yield=deduped_Metrics_D5.deduped_QualityYield,
			wgs_metrics_algo=deduped_Metrics_D5.deduped_wgsmetrics,
			aln_metrics=deduped_Metrics_D5.dedeuped_aln_metrics,
			is_metrics=deduped_Metrics_D5.deduped_is_metrics,
			cluster_config=SMALLcluster_config,
			disk_size=disk_size		
		}

		## Bam realignment doesn't support in GATK 4
		call Realigner.Realigner as Realigner_D5 {
			input:
			fasta=fasta,
			ref_dir=ref_dir,
			Dedup_bam=Dedup_D5.Dedup_bam,
			Dedup_bam_index=Dedup_D5.Dedup_bam_index,
			db_mills=db_mills,
			dbmills_dir=dbmills_dir,
			docker=REPLACE_SENTIEON_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call BQSR.BQSR as BQSR_D5 {
			input:
			fasta=fasta,
			ref_dir=ref_dir,
			realigned_bam=Realigner_D5.realigner_bam,
			realigned_bam_index=Realigner_D5.realigner_bam_index,
			db_mills=db_mills,
			dbmills_dir=dbmills_dir,
			dbsnp=dbsnp,
			dbsnp_dir=dbsnp_dir,
			docker=REPLACE_SENTIEON_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call Haplotyper.Haplotyper as Haplotyper_D5 {
			input:
			fasta=fasta,
			ref_dir=ref_dir,
			recaled_bam=BQSR_D5.recaled_bam,
			recaled_bam_index=BQSR_D5.recaled_bam_index,
			docker=DEEPVARIANT_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call filter_vcf.filter_vcf as filter_vcf_D5 {
			input:
			vcf=Haplotyper_D5.vcf,
			docker=BEDTOOLSdocker,
			cluster_config=SMALLcluster_config,
			disk_size=disk_size			
		}

		call benchmark.benchmark as benchmark_D5 {
			input:
			filtered_vcf=filter_vcf_D5.filtered_vcf,
			benchmarking_dir=benchmarking_dir,
			ref_dir=ref_dir,
			fasta=fasta,
			docker=BENCHMARKdocker,
			cluster_config=BIGcluster_config,
			disk_size=disk_size
		}		

		call mapping.mapping as mapping_D6 {
			input: 
			pl=pl,
			fasta=fasta,
			ref_dir=ref_dir,
			fastq_1=fastq_1_D6,
			fastq_2=fastq_2_D6,
			group=project,
			sample='LCL6',
			project=project,
			docker=REPLACE_SENTIEON_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call fastqc.fastqc as fastqc_D6 {
			input:
			read1=fastq_1_D6,
			read2=fastq_2_D6,
			project=project,
			sample="LCL6",
			docker=FASTQCdocker,
			cluster_config=BIGcluster_config,
			disk_size=disk_size
		}

		call fastqscreen.fastq_screen as fastqscreen_D6 {
			input:
			read1=fastq_1_D6,
			read2=fastq_2_D6,
			project=project,
			sample="LCL6",
			screen_ref_dir=screen_ref_dir,
			fastq_screen_conf=fastq_screen_conf,
			docker=FASTQSCREENdocker,
			cluster_config=BIGcluster_config,
			disk_size=disk_size
		}

		call Dedup.Dedup as Dedup_D6 {
			input:
			sorted_bam=mapping_D6.sorted_bam,
			sorted_bam_index=mapping_D6.sorted_bam_index,
			docker=REPLACE_SENTIEON_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call qualimap.qualimap as qualimap_D6 {
			input:
			bam=Dedup_D6.Dedup_bam,
			bai=Dedup_D6.Dedup_bam_index,
			docker=QUALIMAPdocker,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}		

		call deduped_Metrics.deduped_Metrics as deduped_Metrics_D6 {
			input:
			fasta=fasta,
			ref_dir=ref_dir,
			Dedup_bam=Dedup_D6.Dedup_bam,
			Dedup_bam_index=Dedup_D6.Dedup_bam_index,
			docker=REPLACE_SENTIEON_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call sentieon.sentieon as sentieon_D6 {
			input:
			quality_yield=deduped_Metrics_D6.deduped_QualityYield,
			wgs_metrics_algo=deduped_Metrics_D6.deduped_wgsmetrics,
			aln_metrics=deduped_Metrics_D6.dedeuped_aln_metrics,
			is_metrics=deduped_Metrics_D6.deduped_is_metrics,
			cluster_config=SMALLcluster_config,
			disk_size=disk_size		
		}

		call Realigner.Realigner as Realigner_D6 {
			input:
			fasta=fasta,
			ref_dir=ref_dir,
			Dedup_bam=Dedup_D6.Dedup_bam,
			Dedup_bam_index=Dedup_D6.Dedup_bam_index,
			db_mills=db_mills,
			dbmills_dir=dbmills_dir,
			docker=REPLACE_SENTIEON_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call BQSR.BQSR as BQSR_D6 {
			input:
			fasta=fasta,
			ref_dir=ref_dir,
			realigned_bam=Realigner_D6.realigner_bam,
			realigned_bam_index=Realigner_D6.realigner_bam_index,
			db_mills=db_mills,
			dbmills_dir=dbmills_dir,
			dbsnp=dbsnp,
			dbsnp_dir=dbsnp_dir,
			docker=REPLACE_SENTIEON_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call Haplotyper.Haplotyper as Haplotyper_D6 {
			input:
			fasta=fasta,
			ref_dir=ref_dir,
			recaled_bam=BQSR_D6.recaled_bam,
			recaled_bam_index=BQSR_D6.recaled_bam_index,
			docker=DEEPVARIANT_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call filter_vcf.filter_vcf as filter_vcf_D6 {
			input:
			vcf=Haplotyper_D6.vcf,
			docker=BEDTOOLSdocker,
			cluster_config=SMALLcluster_config,
			disk_size=disk_size			
		}

		call benchmark.benchmark as benchmark_D6 {
			input:
			filtered_vcf=filter_vcf_D6.filtered_vcf,
			benchmarking_dir=benchmarking_dir,
			ref_dir=ref_dir,
			fasta=fasta,
			docker=BENCHMARKdocker,
			cluster_config=BIGcluster_config,
			disk_size=disk_size
		}
	
		call mapping.mapping as mapping_F7 {
			input: 
			pl=pl,
			fasta=fasta,
			ref_dir=ref_dir,
			fastq_1=fastq_1_F7,
			fastq_2=fastq_2_F7,
			group=project,
			sample='LCL7',
			project=project,
			docker=REPLACE_SENTIEON_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call fastqc.fastqc as fastqc_F7 {
			input:
			read1=fastq_1_F7,
			read2=fastq_2_F7,
			project=project,
			sample="LCL7",
			docker=FASTQCdocker,
			cluster_config=BIGcluster_config,
			disk_size=disk_size
		}

		call fastqscreen.fastq_screen as fastqscreen_F7 {
			input:
			read1=fastq_1_F7,
			read2=fastq_2_F7,
			project=project,
			sample="LCL7",
			screen_ref_dir=screen_ref_dir,
			fastq_screen_conf=fastq_screen_conf,
			docker=FASTQSCREENdocker,
			cluster_config=BIGcluster_config,
			disk_size=disk_size
		}

		call Dedup.Dedup as Dedup_F7 {
			input:
			sorted_bam=mapping_F7.sorted_bam,
			sorted_bam_index=mapping_F7.sorted_bam_index,
			docker=REPLACE_SENTIEON_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call qualimap.qualimap as qualimap_F7 {
			input:
			bam=Dedup_F7.Dedup_bam,
			bai=Dedup_F7.Dedup_bam_index,
			docker=QUALIMAPdocker,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}		

		call deduped_Metrics.deduped_Metrics as deduped_Metrics_F7 {
			input:
			fasta=fasta,
			ref_dir=ref_dir,
			Dedup_bam=Dedup_F7.Dedup_bam,
			Dedup_bam_index=Dedup_F7.Dedup_bam_index,
			docker=REPLACE_SENTIEON_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call sentieon.sentieon as sentieon_F7 {
			input:
			quality_yield=deduped_Metrics_F7.deduped_QualityYield,
			wgs_metrics_algo=deduped_Metrics_F7.deduped_wgsmetrics,
			aln_metrics=deduped_Metrics_F7.dedeuped_aln_metrics,
			is_metrics=deduped_Metrics_F7.deduped_is_metrics,
			cluster_config=SMALLcluster_config,
			disk_size=disk_size		
		}

		call Realigner.Realigner as Realigner_F7 {
			input:
			fasta=fasta,
			ref_dir=ref_dir,
			Dedup_bam=Dedup_F7.Dedup_bam,
			Dedup_bam_index=Dedup_F7.Dedup_bam_index,
			db_mills=db_mills,
			dbmills_dir=dbmills_dir,
			docker=REPLACE_SENTIEON_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call BQSR.BQSR as BQSR_F7 {
			input:
			fasta=fasta,
			ref_dir=ref_dir,
			realigned_bam=Realigner_F7.realigner_bam,
			realigned_bam_index=Realigner_F7.realigner_bam_index,
			db_mills=db_mills,
			dbmills_dir=dbmills_dir,
			dbsnp=dbsnp,
			dbsnp_dir=dbsnp_dir,
			docker=REPLACE_SENTIEON_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call Haplotyper.Haplotyper as Haplotyper_F7 {
			input:
			fasta=fasta,
			ref_dir=ref_dir,
			recaled_bam=BQSR_F7.recaled_bam,
			recaled_bam_index=BQSR_F7.recaled_bam_index,
			docker=DEEPVARIANT_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call filter_vcf.filter_vcf as filter_vcf_F7 {
			input:
			vcf=Haplotyper_F7.vcf,
			docker=BEDTOOLSdocker,
			cluster_config=SMALLcluster_config,
			disk_size=disk_size			
		}

		call benchmark.benchmark as benchmark_F7 {
			input:
			filtered_vcf=filter_vcf_F7.filtered_vcf,
			benchmarking_dir=benchmarking_dir,
			ref_dir=ref_dir,
			fasta=fasta,
			docker=BENCHMARKdocker,
			cluster_config=BIGcluster_config,
			disk_size=disk_size
		}
	
		call mapping.mapping as mapping_M8 {
			input: 
			pl=pl,
			fasta=fasta,
			ref_dir=ref_dir,
			fastq_1=fastq_1_M8,
			fastq_2=fastq_2_M8,
			group=project,
			project=project,
			sample='LCL8',
			docker=REPLACE_SENTIEON_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call fastqc.fastqc as fastqc_M8 {
			input:
			read1=fastq_1_M8,
			read2=fastq_2_M8,
			project=project,
			sample="LCL8",
			docker=FASTQCdocker,
			cluster_config=BIGcluster_config,
			disk_size=disk_size
		}

		call fastqscreen.fastq_screen as fastqscreen_M8 {
			input:
			read1=fastq_1_M8,
			read2=fastq_2_M8,
			project=project,
			sample="LCL8",
			screen_ref_dir=screen_ref_dir,
			fastq_screen_conf=fastq_screen_conf,
			docker=FASTQSCREENdocker,
			cluster_config=BIGcluster_config,
			disk_size=disk_size
		}

		call Dedup.Dedup as Dedup_M8 {
			input:
			sorted_bam=mapping_M8.sorted_bam,
			sorted_bam_index=mapping_M8.sorted_bam_index,
			docker=REPLACE_SENTIEON_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call qualimap.qualimap as qualimap_M8 {
			input:
			bam=Dedup_M8.Dedup_bam,
			bai=Dedup_M8.Dedup_bam_index,
			docker=QUALIMAPdocker,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}		

		call deduped_Metrics.deduped_Metrics as deduped_Metrics_M8 {
			input:
			fasta=fasta,
			ref_dir=ref_dir,
			Dedup_bam=Dedup_M8.Dedup_bam,
			Dedup_bam_index=Dedup_M8.Dedup_bam_index,
			docker=REPLACE_SENTIEON_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call sentieon.sentieon as sentieon_M8 {
			input:
			quality_yield=deduped_Metrics_M8.deduped_QualityYield,
			wgs_metrics_algo=deduped_Metrics_M8.deduped_wgsmetrics,
			aln_metrics=deduped_Metrics_M8.dedeuped_aln_metrics,
			is_metrics=deduped_Metrics_M8.deduped_is_metrics,
			cluster_config=SMALLcluster_config,
			disk_size=disk_size		
		}

		call Realigner.Realigner as Realigner_M8 {
			input:
			fasta=fasta,
			ref_dir=ref_dir,
			Dedup_bam=Dedup_M8.Dedup_bam,
			Dedup_bam_index=Dedup_M8.Dedup_bam_index,
			db_mills=db_mills,
			dbmills_dir=dbmills_dir,
			docker=REPLACE_SENTIEON_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call BQSR.BQSR as BQSR_M8 {
			input:
			fasta=fasta,
			ref_dir=ref_dir,
			realigned_bam=Realigner_M8.realigner_bam,
			realigned_bam_index=Realigner_M8.realigner_bam_index,
			db_mills=db_mills,
			dbmills_dir=dbmills_dir,
			dbsnp=dbsnp,
			dbsnp_dir=dbsnp_dir,
			docker=REPLACE_SENTIEON_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call Haplotyper.Haplotyper as Haplotyper_M8 {
			input:
			fasta=fasta,
			ref_dir=ref_dir,
			recaled_bam=BQSR_M8.recaled_bam,
			recaled_bam_index=BQSR_M8.recaled_bam_index,
			docker=DEEPVARIANT_DOCKER,
			disk_size=disk_size,
			cluster_config=BIGcluster_config
		}

		call filter_vcf.filter_vcf as filter_vcf_M8 {
			input:
			vcf=Haplotyper_M8.vcf,
			docker=BEDTOOLSdocker,
			cluster_config=SMALLcluster_config,
			disk_size=disk_size			
		}

		call benchmark.benchmark as benchmark_M8 {
			input:
			filtered_vcf=filter_vcf_M8.filtered_vcf,
			benchmarking_dir=benchmarking_dir,
			ref_dir=ref_dir,
			fasta=fasta,
			docker=BENCHMARKdocker,
			cluster_config=BIGcluster_config,
			disk_size=disk_size
		}
	

	    Array[File] fastqc_read1_zip = [fastqc_D5.read1_zip, fastqc_D6.read1_zip, fastqc_F7.read1_zip, fastqc_M8.read1_zip]

	    Array[File] fastqc_read2_zip = [fastqc_D5.read2_zip, fastqc_D6.read2_zip, fastqc_F7.read2_zip, fastqc_M8.read2_zip]

	    Array[File] fastqscreen_txt1 = [fastqscreen_D5.txt1, fastqscreen_D6.txt1, fastqscreen_F7.txt1, fastqscreen_M8.txt1]

	    Array[File] fastqscreen_txt2 = [fastqscreen_D5.txt2, fastqscreen_D6.txt2, fastqscreen_F7.txt2, fastqscreen_M8.txt2]

	    Array[File] benchmark_summary = [benchmark_D5.summary, benchmark_D6.summary, benchmark_F7.summary, benchmark_M8.summary]

		call multiqc.multiqc as multiqc_big {
			input:
			read1_zip=fastqc_read1_zip,
			read2_zip=fastqc_read2_zip,
			txt1=fastqscreen_txt1,
			txt2=fastqscreen_txt2,
			summary=benchmark_summary,
			docker=MULTIQCdocker,
			cluster_config=SMALLcluster_config,
			disk_size=disk_size
		}


		Array[File] sentieon_quality_yield_header = [sentieon_D5.quality_yield_header, sentieon_D6.quality_yield_header, sentieon_F7.quality_yield_header, sentieon_M8.quality_yield_header]

		Array[File] sentieon_wgs_metrics_algo_header = [sentieon_D5.wgs_metrics_algo_header, sentieon_D6.wgs_metrics_algo_header, sentieon_F7.wgs_metrics_algo_header, sentieon_M8.wgs_metrics_algo_header]

		Array[File] sentieon_aln_metrics_header = [sentieon_D5.aln_metrics_header, sentieon_D6.aln_metrics_header, sentieon_F7.aln_metrics_header, sentieon_M8.aln_metrics_header]

		Array[File] sentieon_is_metrics_header = [sentieon_D5.is_metrics_header, sentieon_D6.is_metrics_header, sentieon_F7.is_metrics_header, sentieon_M8.is_metrics_header]

		Array[File] sentieon_quality_yield_data = [sentieon_D5.quality_yield_data, sentieon_D6.quality_yield_data, sentieon_F7.quality_yield_data, sentieon_M8.quality_yield_data]

		Array[File] sentieon_wgs_metrics_algo_data = [sentieon_D5.wgs_metrics_algo_data, sentieon_D6.wgs_metrics_algo_data, sentieon_F7.wgs_metrics_algo_data, sentieon_M8.wgs_metrics_algo_data]

		Array[File] sentieon_aln_metrics_data = [sentieon_D5.aln_metrics_data, sentieon_D6.aln_metrics_data, sentieon_F7.aln_metrics_data, sentieon_M8.aln_metrics_data]

		Array[File] sentieon_is_metrics_data = [sentieon_D5.is_metrics_data, sentieon_D6.is_metrics_data, sentieon_F7.is_metrics_data, sentieon_M8.is_metrics_data]

		call merge_sentieon_metrics.merge_sentieon_metrics as merge_sentieon_metrics {
			input:
			quality_yield_header=sentieon_quality_yield_header,
			wgs_metrics_algo_header=sentieon_wgs_metrics_algo_header,
			aln_metrics_header=sentieon_aln_metrics_header,
			is_metrics_header=sentieon_is_metrics_header,
			quality_yield_data=sentieon_quality_yield_data,
			wgs_metrics_algo_data=sentieon_wgs_metrics_algo_data,
			aln_metrics_data=sentieon_aln_metrics_data,
			is_metrics_data=sentieon_is_metrics_data,
			project=project,
			docker=MULTIQCdocker,
			cluster_config=SMALLcluster_config,
			disk_size=disk_size	
		}

		call extract_tables.extract_tables as extract_tables {
			input:
			quality_yield_summary=merge_sentieon_metrics.quality_yield_summary,
			wgs_metrics_summary=merge_sentieon_metrics.wgs_metrics_summary,
			aln_metrics_summary=merge_sentieon_metrics.aln_metrics_summary,
			is_metrics_summary=merge_sentieon_metrics.is_metrics_summary,
			fastqc=multiqc_big.fastqc,
			fastqscreen=multiqc_big.fastqscreen,
			hap=multiqc_big.hap,
			project=project,
			docker=DIYdocker,
			cluster_config=SMALLcluster_config,
			disk_size=disk_size
		}

		call merge_family.merge_family as merge_family {
			input:
			D5_vcf=benchmark_D5.rtg_vcf,
			D6_vcf=benchmark_D6.rtg_vcf,
			F7_vcf=benchmark_F7.rtg_vcf,
			M8_vcf=benchmark_M8.rtg_vcf,
			D5_vcf_tbi=benchmark_D5.rtg_vcf_index,
			D6_vcf_tbi=benchmark_D6.rtg_vcf_index,
			F7_vcf_tbi=benchmark_F7.rtg_vcf_index,
			M8_vcf_tbi=benchmark_M8.rtg_vcf_index,
			project=project,
			docker=BENCHMARKdocker,
			cluster_config=SMALLcluster_config,
			disk_size=disk_size,
		}

		call mendelian.mendelian as mendelian {
			input:
			family_vcf=merge_family.family_vcf,
			ref_dir=ref_dir,
			fasta=fasta,
			docker=MENDELIANdocker,
			cluster_config=BIGcluster_config,
			disk_size=disk_size		
		}

		call merge_mendelian.merge_mendelian as merge_mendelian {
			input:
			D5_trio_vcf=mendelian.D5_trio_vcf,
			D6_trio_vcf=mendelian.D6_trio_vcf,
			family_vcf=merge_family.family_vcf,
			docker=DIYdocker,
			cluster_config=SMALLcluster_config,
			disk_size=disk_size
		}
	} 
	
	# Fastq is null, check if starts with vcf
	if (vcf_D5 != "" && vcf_D6 != "" && vcf_F7 != "" && vcf_M8 != "" ) {
		call rename_vcf.rename_vcf as rename_vcf{
			input:
			vcf_D5=vcf_D5,
			vcf_D6=vcf_D6,
			vcf_F7=vcf_F7,
			vcf_M8=vcf_M8,
			project=project,
			docker=DIYdocker,
			cluster_config=SMALLcluster_config,
			disk_size=disk_size
		}
		call filter_vcf.filter_vcf as filter_vcf_D5_vcf {
			input:
			vcf=rename_vcf.vcf_D5_renamed,
			docker=BEDTOOLSdocker,
			cluster_config=SMALLcluster_config,
			disk_size=disk_size			
		}

		call benchmark.benchmark as benchmark_D5_vcf {
			input:
			filtered_vcf=filter_vcf_D5_vcf.filtered_vcf,
			benchmarking_dir=benchmarking_dir,
			ref_dir=ref_dir,
			fasta=fasta,
			docker=BENCHMARKdocker,
			cluster_config=BIGcluster_config,
			disk_size=disk_size
		}

		call filter_vcf.filter_vcf as filter_vcf_D6_vcf {
			input:
			vcf=rename_vcf.vcf_D6_renamed,
			docker=BEDTOOLSdocker,
			cluster_config=SMALLcluster_config,
			disk_size=disk_size			
		}

		call benchmark.benchmark as benchmark_D6_vcf {
			input:
			filtered_vcf=filter_vcf_D6_vcf.filtered_vcf,
			benchmarking_dir=benchmarking_dir,
			ref_dir=ref_dir,
			fasta=fasta,
			docker=BENCHMARKdocker,
			cluster_config=BIGcluster_config,
			disk_size=disk_size
		}

		call filter_vcf.filter_vcf as filter_vcf_F7_vcf {
			input:
			vcf=rename_vcf.vcf_F7_renamed,
			docker=BEDTOOLSdocker,
			cluster_config=SMALLcluster_config,
			disk_size=disk_size			
		}

		call benchmark.benchmark as benchmark_F7_vcf {
			input:
			filtered_vcf=filter_vcf_F7_vcf.filtered_vcf,
			benchmarking_dir=benchmarking_dir,
			ref_dir=ref_dir,
			fasta=fasta,
			docker=BENCHMARKdocker,
			cluster_config=BIGcluster_config,
			disk_size=disk_size
		}

		call filter_vcf.filter_vcf as filter_vcf_M8_vcf {
			input:
			vcf=rename_vcf.vcf_M8_renamed,
			docker=BEDTOOLSdocker,
			cluster_config=SMALLcluster_config,
			disk_size=disk_size			
		}

		call benchmark.benchmark as benchmark_M8_vcf {
			input:
			filtered_vcf=filter_vcf_M8_vcf.filtered_vcf,
			benchmarking_dir=benchmarking_dir,
			ref_dir=ref_dir,
			fasta=fasta,
			docker=BENCHMARKdocker,
			cluster_config=BIGcluster_config,
			disk_size=disk_size
		}

		Array[File] benchmark_summary_hap = [benchmark_D5_vcf.summary, benchmark_D6_vcf.summary, benchmark_F7_vcf.summary, benchmark_M8_vcf.summary]

		call multiqc_hap.multiqc_hap as multiqc_hap {
			input:
			summary=benchmark_summary_hap,
			docker=MULTIQCdocker,
			cluster_config=SMALLcluster_config,
			disk_size=disk_size
		}

		call extract_tables_vcf.extract_tables_vcf as extract_tables_vcf {
			input:
			hap=multiqc_hap.hap,
			project=project,
			docker=DIYdocker,
			cluster_config=SMALLcluster_config,
			disk_size=disk_size
		}

		call merge_family.merge_family as merge_family_vcf {
			input:
			D5_vcf=benchmark_D5_vcf.rtg_vcf,
			D6_vcf=benchmark_D6_vcf.rtg_vcf,
			F7_vcf=benchmark_F7_vcf.rtg_vcf,
			M8_vcf=benchmark_M8_vcf.rtg_vcf,
			D5_vcf_tbi=benchmark_D5_vcf.rtg_vcf_index,
			D6_vcf_tbi=benchmark_D6_vcf.rtg_vcf_index,
			F7_vcf_tbi=benchmark_F7_vcf.rtg_vcf_index,
			M8_vcf_tbi=benchmark_M8_vcf.rtg_vcf_index,
			project=project,
			docker=BENCHMARKdocker,
			cluster_config=SMALLcluster_config,
			disk_size=disk_size,
		}

		call mendelian.mendelian as mendelian_vcf {
			input:
			family_vcf=merge_family_vcf.family_vcf,
			ref_dir=ref_dir,
			fasta=fasta,
			docker=MENDELIANdocker,
			cluster_config=BIGcluster_config,
			disk_size=disk_size		
		}

		call merge_mendelian.merge_mendelian as merge_mendelian_vcf {
			input:
			D5_trio_vcf=mendelian_vcf.D5_trio_vcf,
			D6_trio_vcf=mendelian_vcf.D6_trio_vcf,
			family_vcf=merge_family_vcf.family_vcf,
			docker=DIYdocker,
			cluster_config=SMALLcluster_config,
			disk_size=disk_size
		}
	}
	
}