Skip to content

Commit 6c0a080

Browse files
dpark01claude
andcommitted
Increase disk sizing multiplier from 3x to 6x
Update dynamic disk size calculation to use 6x multiplier for input BAM files instead of 3x. This accounts for minimap2 creating large uncompressed SAM files during alignment before converting to BAM. Testing with 3x multiplier (submission 24dfd2f6-6a10-441e-8c1c-9c059e98befa) showed continued failures for 75GB inputs, indicating the multiplier was insufficient for alignment workloads. 🤖 Generated with [Claude Code](https://claude.com/claude-code) Co-Authored-By: Claude Sonnet 4.5 <noreply@anthropic.com>
1 parent 9227591 commit 6c0a080

2 files changed

Lines changed: 3 additions & 3 deletions

File tree

pipes/WDL/tasks/tasks_reports.wdl

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -418,7 +418,7 @@ task align_and_count {
418418

419419
String reads_basename=basename(reads_bam, ".bam")
420420
String ref_basename=basename(ref_db, ".fasta")
421-
Int disk_size = ceil((3 * size(reads_bam, "GB") + 2 * size(ref_db, "GB") + 100) / 375.0) * 375
421+
Int disk_size = ceil((6 * size(reads_bam, "GB") + 2 * size(ref_db, "GB") + 100) / 375.0) * 375
422422

423423
parameter_meta {
424424
reads_bam: {

pipes/WDL/tasks/tasks_taxon_filter.wdl

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ task deplete_taxa {
3838
Float blast_db_size = if defined(blastDbs) then size(select_first([blastDbs, []]), "GB") else 0
3939
Float bwa_db_size = if defined(bwaDbs) then size(select_first([bwaDbs, []]), "GB") else 0
4040
Float total_db_size = bmtagger_db_size + blast_db_size + bwa_db_size
41-
Int disk_size = ceil((3 * size(raw_reads_unmapped_bam, "GB") + 2 * total_db_size + 100) / 375.0) * 375
41+
Int disk_size = ceil((6 * size(raw_reads_unmapped_bam, "GB") + 2 * total_db_size + 100) / 375.0) * 375
4242

4343
command <<<
4444
set -ex -o pipefail
@@ -122,7 +122,7 @@ task filter_to_taxon {
122122

123123
# do this in two steps in case the input doesn't actually have "cleaned" in the name
124124
String bam_basename = basename(basename(reads_unmapped_bam, ".bam"), ".cleaned")
125-
Int disk_size = ceil((3 * size(reads_unmapped_bam, "GB") + 2 * size(lastal_db_fasta, "GB") + 100) / 375.0) * 375
125+
Int disk_size = ceil((6 * size(reads_unmapped_bam, "GB") + 2 * size(lastal_db_fasta, "GB") + 100) / 375.0) * 375
126126

127127
command <<<
128128
set -ex -o pipefail

0 commit comments

Comments
 (0)