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")