diff --git a/wdl-ci.config.json b/wdl-ci.config.json
index d38a2661..f5620547 100644
--- a/wdl-ci.config.json
+++ b/wdl-ci.config.json
@@ -419,7 +419,7 @@
       "tasks": {
         "pbsv_call": {
           "key": "pbsv_call",
-          "digest": "77yon47d6t327ocrw6bed3dccyq5t3va",
+          "digest": "o5xv2etbm2j4s32d5xs626xj6sp2ykmj",
           "tests": [
             {
               "inputs": {
@@ -457,7 +457,7 @@
       "tasks": {
         "concat_vcf": {
           "key": "concat_vcf",
-          "digest": "ntfiawmetxbdacle2l7mpu5tkz2jmtz2",
+          "digest": "xkyvutmrg3gz6zgabdmwcjvcbwrbwwp7",
           "tests": [
             {
               "inputs": {
diff --git a/workflows/cohort_analysis/cohort_analysis.wdl b/workflows/cohort_analysis/cohort_analysis.wdl
index 4ebeba6f..8a9970b5 100644
--- a/workflows/cohort_analysis/cohort_analysis.wdl
+++ b/workflows/cohort_analysis/cohort_analysis.wdl
@@ -32,7 +32,9 @@ workflow cohort_analysis {
 		File gvcf_index = gvcf_object.data_index
 	}
 
-	scatter (region_set in pbsv_splits) {
+	scatter (shard_index in range(length(pbsv_splits))) {
+        Array[String] region_set = pbsv_splits[shard_index]
+
 		call PbsvCall.pbsv_call {
 			input:
 				sample_id = cohort_id + ".joint",
@@ -41,6 +43,7 @@ workflow cohort_analysis {
 				reference = reference.fasta.data,
 				reference_index = reference.fasta.data_index,
 				reference_name = reference.name,
+				shard_index = shard_index,
 				regions = region_set,
 				mem_gb = pbsv_call_mem_gb,
 				runtime_attributes = default_runtime_attributes
diff --git a/workflows/sample_analysis/sample_analysis.wdl b/workflows/sample_analysis/sample_analysis.wdl
index 990e3b91..1f4f1a8d 100644
--- a/workflows/sample_analysis/sample_analysis.wdl
+++ b/workflows/sample_analysis/sample_analysis.wdl
@@ -68,7 +68,9 @@ workflow sample_analysis {
 			runtime_attributes = default_runtime_attributes
 	}
 
-	scatter (region_set in pbsv_splits) {
+	scatter (shard_index in range(length(pbsv_splits))) {
+        Array[String] region_set = pbsv_splits[shard_index]
+
 		call PbsvCall.pbsv_call {
 			input:
 				sample_id = sample.sample_id,
@@ -76,6 +78,7 @@ workflow sample_analysis {
 				reference = reference.fasta.data,
 				reference_index = reference.fasta.data_index,
 				reference_name = reference.name,
+				shard_index = shard_index,
 				regions = region_set,
 				runtime_attributes = default_runtime_attributes
 		}
diff --git a/workflows/wdl-common b/workflows/wdl-common
index 8a2f30e9..d08984b2 160000
--- a/workflows/wdl-common
+++ b/workflows/wdl-common
@@ -1 +1 @@
-Subproject commit 8a2f30e9ad3b392b9502b829abb091fff205898b
+Subproject commit d08984b223fbc3fdab511cdfe0e6ca7987a41603