Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Fix bad check for missing workflow name [VS-520] #7943

Merged
merged 2 commits into from
Jul 14, 2022
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
3 changes: 1 addition & 2 deletions .dockstore.yml
Original file line number Diff line number Diff line change
Expand Up @@ -231,8 +231,7 @@ workflows:
branches:
- master
- ah_var_store
- vs_475_read_cost_observability
- vs_518_throw_on_fiss_api_error
- cost_robustitude
- name: MitochondriaPipeline
subclass: WDL
primaryDescriptorPath: /scripts/mitochondria_m2_wdl/MitochondriaPipeline.wdl
Expand Down
2 changes: 1 addition & 1 deletion scripts/variantstore/wdl/GvsAssignIds.wdl
Original file line number Diff line number Diff line change
Expand Up @@ -214,7 +214,7 @@ task CreateCostObservabilityTable {
fi
>>>
runtime {
docker: "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_13"
docker: "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_14"
}
output {
Boolean done = true
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -264,7 +264,7 @@ task Add_AS_MAX_VQSLOD_ToVcf {
File input_vcf
String output_basename

String docker = "us.gcr.io/broad-dsde-methods/variantstore:rsa_metadata_from_python_20220628"
String docker = "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_14"
Int cpu = 1
Int memory_mb = 3500
Int disk_size_gb = ceil(2*size(input_vcf, "GiB")) + 50
Expand Down
2 changes: 1 addition & 1 deletion scripts/variantstore/wdl/GvsCallsetCost.wdl
Original file line number Diff line number Diff line change
Expand Up @@ -62,7 +62,7 @@ task WorkflowComputeCosts {
>>>

runtime {
docker: "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_13"
docker: "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_14"
}

output {
Expand Down
2 changes: 1 addition & 1 deletion scripts/variantstore/wdl/GvsCreateAltAllele.wdl
Original file line number Diff line number Diff line change
Expand Up @@ -204,7 +204,7 @@ task PopulateAltAlleleTable {
$SERVICE_ACCOUNT_STANZA
>>>
runtime {
docker: "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_13"
docker: "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_14"
memory: "3 GB"
disks: "local-disk 10 HDD"
cpu: 1
Expand Down
2 changes: 1 addition & 1 deletion scripts/variantstore/wdl/GvsCreateVAT.wdl
Original file line number Diff line number Diff line change
Expand Up @@ -155,7 +155,7 @@ task MakeSubpopulationFiles {
# ------------------------------------------------
# Runtime settings:
runtime {
docker: "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_13"
docker: "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_14"
memory: "1 GB"
preemptible: 3
cpu: "1"
Expand Down
4 changes: 2 additions & 2 deletions scripts/variantstore/wdl/GvsCreateVATAnnotations.wdl
Original file line number Diff line number Diff line change
Expand Up @@ -186,7 +186,7 @@ task ExtractAnAcAfFromVCF {
# ------------------------------------------------
# Runtime settings:
runtime {
docker: "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_13"
docker: "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_14"
maxRetries: 3
memory: "16 GB"
preemptible: 3
Expand Down Expand Up @@ -317,7 +317,7 @@ task PrepAnnotationJson {
# ------------------------------------------------
# Runtime settings:
runtime {
docker: "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_13"
docker: "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_14"
memory: "8 GB"
preemptible: 5
cpu: "1"
Expand Down
4 changes: 2 additions & 2 deletions scripts/variantstore/wdl/GvsCreateVATFromAnnotations.wdl
Original file line number Diff line number Diff line change
Expand Up @@ -92,7 +92,7 @@ task GetAnnotations {
# ------------------------------------------------
# Runtime settings:
runtime {
docker: "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_13"
docker: "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_14"
memory: "1 GB"
preemptible: 3
cpu: "1"
Expand Down Expand Up @@ -151,7 +151,7 @@ task PrepAnnotationJson {
# ------------------------------------------------
# Runtime settings:
runtime {
docker: "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_13"
docker: "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_14"
memory: "8 GB"
preemptible: 5
cpu: "1"
Expand Down
2 changes: 1 addition & 1 deletion scripts/variantstore/wdl/GvsImportGenomes.wdl
Original file line number Diff line number Diff line change
Expand Up @@ -426,7 +426,7 @@ task CurateInputLists {
--output_files True
>>>
runtime {
docker: "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_13"
docker: "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_14"
memory: "3 GB"
disks: "local-disk 100 HDD"
bootDiskSizeGb: 15
Expand Down
2 changes: 1 addition & 1 deletion scripts/variantstore/wdl/GvsPrepareRangesCallset.wdl
Original file line number Diff line number Diff line change
Expand Up @@ -116,7 +116,7 @@ task PrepareRangesCallsetTask {
}

runtime {
docker: "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_13"
docker: "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_14"
memory: "3 GB"
disks: "local-disk 100 HDD"
bootDiskSizeGb: 15
Expand Down
2 changes: 1 addition & 1 deletion scripts/variantstore/wdl/GvsUtils.wdl
Original file line number Diff line number Diff line change
Expand Up @@ -367,7 +367,7 @@ task ScaleXYBedValues {
}

runtime {
docker: "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_13"
docker: "us.gcr.io/broad-dsde-methods/variantstore:ah_var_store_2022_07_14"
maxRetries: 3
memory: "7 GB"
preemptible: 3
Expand Down
4 changes: 2 additions & 2 deletions scripts/variantstore/wdl/extract/workflow_compute_costs.py
Original file line number Diff line number Diff line change
Expand Up @@ -47,11 +47,11 @@ def compute_costs(workspace_namespace, workspace_name, excluded_submission_ids,
workflow_ids = [w['workflowId'] for w in workflows]
for workflow_id in workflow_ids:
workflow = get_workflow_metadata(workspace_namespace, workspace_name, submission_id, workflow_id)
workflow_name = workflow['workflowName']
if not workflow_name:
if 'workflowName' not in workflow:
warning(f"Workflow {workflow_id} has no workflow name, skipping cost calculation.")
continue

workflow_name = workflow['workflowName']
if workflow_name.startswith('Gvs'):
if len(workflow_ids) == 1:
# If this run is < 1 day old the cost data may not yet be available.
Expand Down