Skip to content

Commit

Permalink
More sqlmesh run tweaks (#2657)
Browse files Browse the repository at this point in the history
* allow job retries to be configurable

* set flux to this branch

* temp uninstall

* reinstall

* ensure that we use scopes to resolve table deps

* go spot or go home

* more tests

* Improve progress reporting and error logging

* restore main
  • Loading branch information
ravenac95 authored Dec 17, 2024
1 parent 2aa341a commit 76ae3d6
Show file tree
Hide file tree
Showing 8 changed files with 376 additions and 146 deletions.
2 changes: 1 addition & 1 deletion ops/tf-modules/warehouse-cluster/main.tf
Original file line number Diff line number Diff line change
Expand Up @@ -164,7 +164,7 @@ locals {
max_count = 20
local_ssd_count = 0
local_ssd_ephemeral_storage_count = 2
spot = false
spot = true
disk_size_gb = 100
disk_type = "pd-standard"
image_type = "COS_CONTAINERD"
Expand Down
6 changes: 6 additions & 0 deletions warehouse/metrics_tools/compute/client.py
Original file line number Diff line number Diff line change
Expand Up @@ -190,6 +190,12 @@ def _handler(response: JobStatusResponse):

if final_status.status == QueryJobStatus.FAILED:
self.logger.error(f"job[{job_id}] failed with status {final_status.status}")
if final_status.exceptions:
self.logger.error(f"job[{job_id}] failed with exceptions")

for exc in final_status.exceptions:
self.logger.error(f"job[{job_id}] failed with exceptoin {exc}")

raise Exception(f"job[{job_id}] failed with status {final_status.status}")

self.logger.info(f"job[{job_id}] completed with status {final_status.status}")
Expand Down
Loading

0 comments on commit 76ae3d6

Please sign in to comment.