CNVkit_Sequenza/tasks/CNVkit.wdl

task cnvkit{
    String sample_id
    File ref_dir
    String? fasta
    File ref_flat
    File bed_file
    String center_at
    File tumor_bam
    File tumor_bam_index
    File? normal_bam
    File? normal_bam_index
    String docker
    String cluster_config
    String disk_size
    String sample=basename(tumor_bam,".bam")

    command <<<

       set -o pipefail
       set -e
       nt=$(nproc)
        
       echo ${sample}

       if [ ${normal_bam} ]; then   
               /root/miniconda2/bin/cnvkit.py batch ${tumor_bam} \
                  --normal ${normal_bam} \
                  --method wgs \
                  --fasta ${ref_dir} \
                  --annotate ${ref_flat} -p $nt \
                  --drop-low-coverage \
                  --output-dir ${sample}.reference.cnn
       else
               /root/miniconda2/bin/cnvkit.py batch ${tumor_bam} \
                  --method wgs \
                  --fasta ${ref_dir} \
                  --annotate ${ref_flat} -p $nt \
                  --drop-low-coverage \
                  --output-dir ${sample}.reference.cnn 
       fi
                  
       ls ./
       
        
       /root/miniconda2/bin/cnvkit.py batch  ${tumor_bam} \
                  -r ${sample}.reference.cnn/reference.cnn \
                  --output-dir ${sample}.cns \
                  -p $nt
                  
       ls ./
       /root/miniconda2/bin/cnvkit.py call ${sample}.cns/${sample}.cns --center-at ${center_at} \
                  -o ${sample}.call.cns
                  
                

        ls ./

        tar cvf ${sample}.tar ${sample}*

    >>>

    runtime{
        docker:docker
        cluster:cluster_config
        systemDisk:"cloud_ssd 40"
        dataDisk:"cloud_ssd " + disk_size + " /cromwell_root/"
        timeout:259200
    }

    output{
        File out_file = "${sample}.tar"
        #File cnv_bed = "${sample}.ratio_cnv.call.filter.bed"
    }

}