SV_MIE/workflow.wdl

import "./tasks/vcf2bed.wdl" as vcf2bed
import "./tasks/mergeBed.wdl" as mergeBed
import "./tasks/bedAnnotation.wdl" as bedAnnotation
import "./tasks/colSum.wdl" as colSum

workflow {{ project_name }} {
	File inputSamplesFile
	Array[Array[File]] inputSamples = read_tsv(inputSamplesFile)
	File breakpoint_directory
	String sample_name
	String cluster_config
	String disk_size

	scatter (sample in inputSamples){
		call vcf2bed.vcf2bed as vcf2bed {
			input:
			vcf=sample[0],
			vote_file=sample[1],
			chromo=sample[2],
			sample_name=sample_name,
			cluster_config=cluster_config,
			disk_size=disk_size	
		}
	}
	call mergeBed.mergeBed as mergeBed {
		input:
		chromo_filtered_bed=vcf2bed.chromo_filtered_bed,
		chromo_voted_bed=vcf2bed.chromo_voted_bed,
		sample_name=sample_name,
		cluster_config=cluster_config,
		disk_size=disk_size
	}
	call bedAnnotation.bedAnnotation as bedAnnotation {
		input:
		filtered_bed=mergeBed.filtered_bed,
		voted_bed=mergeBed.voted_bed,
		breakpoint_directory=breakpoint_directory,
		sample_name=sample_name,
		cluster_config=cluster_config,
		disk_size=disk_size
	}
	call colSum.colSum as colSum {
		input:
		filtered_bnd=bedAnnotation.filtered_bnd,
		filtered_ins=bedAnnotation.filtered_ins,
		filtered_inv=bedAnnotation.filtered_inv,
		filtered_del=bedAnnotation.filtered_del,
		filtered_dup=bedAnnotation.filtered_dup,
		voted_bnd=bedAnnotation.voted_bnd,
		voted_ins=bedAnnotation.voted_ins,
		voted_inv=bedAnnotation.voted_inv,
		voted_del=bedAnnotation.voted_del,
		voted_dup=bedAnnotation.voted_dup,
		sample_name=sample_name,
		cluster_config=cluster_config,
		disk_size=disk_size
	}
}