Skip to content

Commit 03343cd

Browse files
committed
More trino + dagster + sqlmesh fixes
1 parent f119d70 commit 03343cd

File tree

1 file changed

+20
-17
lines changed

1 file changed

+20
-17
lines changed

warehouse/oso_dagster/assets/sqlmesh.py

Lines changed: 20 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -78,27 +78,30 @@ def sqlmesh_project(context: AssetExecutionContext, sqlmesh: SQLMeshResource):
7878
f"http://{trino_service_name}.{trino_deployment_namespace}.svc.cluster.local:8080/"
7979
)
8080

81-
yield from sqlmesh.run(context, environment=environment)
82-
83-
safe_async_run(
84-
ensure_scale_down(
85-
name=trino_coordinator_deployment_name,
86-
namespace=trino_deployment_namespace,
81+
try:
82+
yield from sqlmesh.run(
83+
context, environment=environment, plan_options={"skip_tests": True}
84+
)
85+
finally:
86+
safe_async_run(
87+
ensure_scale_down(
88+
name=trino_coordinator_deployment_name,
89+
namespace=trino_deployment_namespace,
90+
)
8791
)
88-
)
8992

90-
safe_async_run(
91-
ensure_scale_down(
92-
name=trino_worker_deployment_name,
93-
namespace=trino_deployment_namespace,
93+
safe_async_run(
94+
ensure_scale_down(
95+
name=trino_worker_deployment_name,
96+
namespace=trino_deployment_namespace,
97+
)
9498
)
95-
)
9699

97-
safe_async_run(
98-
ensure_scale_down(
99-
name=mcs_deployment_name,
100-
namespace=mcs_deployment_namespace,
100+
safe_async_run(
101+
ensure_scale_down(
102+
name=mcs_deployment_name,
103+
namespace=mcs_deployment_namespace,
104+
)
101105
)
102-
)
103106

104107
return sqlmesh_project

0 commit comments

Comments
 (0)