From 2a2fa261ccc1169cd38f330b7c7ed68449aaf80d Mon Sep 17 00:00:00 2001
From: gbggrant <ggrant@broadinstitute.org>
Date: Wed, 28 Aug 2024 15:49:54 -0400
Subject: [PATCH] Copy metrics to `output_gcs_dir` if defined.

---
 scripts/variantstore/wdl/GvsExtractCallset.wdl | 12 ++++++++++++
 1 file changed, 12 insertions(+)

diff --git a/scripts/variantstore/wdl/GvsExtractCallset.wdl b/scripts/variantstore/wdl/GvsExtractCallset.wdl
index 33edea5de22..8c4503b249d 100644
--- a/scripts/variantstore/wdl/GvsExtractCallset.wdl
+++ b/scripts/variantstore/wdl/GvsExtractCallset.wdl
@@ -2,6 +2,8 @@ version 1.0
 
 import "GvsUtils.wdl" as Utils
 
+# It's a comment.
+
 workflow GvsExtractCallset {
   input {
     Boolean go = true
@@ -283,6 +285,7 @@ workflow GvsExtractCallset {
         input_details = select_all(CollectMetricsSharded.detail_metrics_file),
         input_summaries = select_all(CollectMetricsSharded.summary_metrics_file),
         output_prefix = call_set_identifier,
+        output_gcs_dir = output_gcs_dir,
         gatk_docker = effective_gatk_docker
     }
   }
@@ -724,6 +727,7 @@ task GatherVariantCallingMetrics {
     Array[File] input_details
     Array[File] input_summaries
     String output_prefix
+    String? output_gcs_dir
 
     Int memory_mb = 3000
     Int disk_size_gb = 200
@@ -749,6 +753,9 @@ task GatherVariantCallingMetrics {
     PS4='\D{+%F %T} \w $ '
     set -o errexit -o nounset -o pipefail -o xtrace
 
+    # Drop trailing slash if one exists
+    OUTPUT_GCS_DIR=$(echo ~{output_gcs_dir} | sed 's/\/$//')
+
     bash ~{monitoring_script} > monitoring.log &
 
     input_details_fofn=~{write_lines(input_details)}
@@ -790,6 +797,11 @@ task GatherVariantCallingMetrics {
       AccumulateVariantCallingMetrics \
       $INPUT \
       --OUTPUT ~{output_prefix}
+
+    if [ -n "$OUTPUT_GCS_DIR" ]; then
+      gsutil cp ~{output_prefix}.variant_calling_summary_metrics ${OUTPUT_GCS_DIR}/
+      gsutil cp ~{output_prefix}.variant_calling_detail_metrics ${OUTPUT_GCS_DIR}/
+    fi
   >>>
 
   runtime {