From 9751124fc76b038593a35a749b088a39db7313db Mon Sep 17 00:00:00 2001 From: "Reuven V. Gonzales" Date: Thu, 19 Dec 2024 02:51:53 +0000 Subject: [PATCH] MCS: Increase size of disk --- ops/tf-modules/warehouse-cluster/main.tf | 2 +- warehouse/metrics_tools/compute/service.py | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/ops/tf-modules/warehouse-cluster/main.tf b/ops/tf-modules/warehouse-cluster/main.tf index 7073f655..01b367ed 100644 --- a/ops/tf-modules/warehouse-cluster/main.tf +++ b/ops/tf-modules/warehouse-cluster/main.tf @@ -163,7 +163,7 @@ locals { min_count = 0 max_count = 50 local_ssd_count = 0 - local_ssd_ephemeral_storage_count = 2 + local_ssd_ephemeral_storage_count = 3 spot = true disk_size_gb = 100 disk_type = "pd-standard" diff --git a/warehouse/metrics_tools/compute/service.py b/warehouse/metrics_tools/compute/service.py index f3871911..e3579c62 100644 --- a/warehouse/metrics_tools/compute/service.py +++ b/warehouse/metrics_tools/compute/service.py @@ -174,7 +174,7 @@ async def _handle_query_job_submit_request( total = len(tasks) if total != input.batch_count(): - self.logger.warning("job[{job_id}] batch count mismatch") + self.logger.warning(f"job[{job_id}] batch count mismatch") exceptions = [] cancellations = [] @@ -201,7 +201,7 @@ async def _handle_query_job_submit_request( raise JobFailed(job_id, len(exceptions), exceptions, cancellations) # Import the final result into the database - self.logger.info("job[{job_id}]: importing final result into the database") + self.logger.info(f"job[{job_id}]: importing final result into the database") await self.import_adapter.import_reference(calculation_export, final_export) self.logger.debug(f"job[{job_id}]: notifying job completed")