fix(pipeline): also update supervisor.py to use plan --auto-apply

Missed the Python supervisor module — same fix as supervisor.sh and
worker.py.

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
Deeman
2026-03-06 22:33:59 +01:00
parent 27e86db6a1
commit 71e08a5fa6

View File

@@ -247,10 +247,10 @@ def run_shell(cmd: str, timeout_seconds: int = SUBPROCESS_TIMEOUT_SECONDS) -> tu
def run_transform() -> None: def run_transform() -> None:
"""Run SQLMesh — evaluates missing daily intervals.""" """Run SQLMesh — detects new/modified/deleted models and applies changes."""
logger.info("Running SQLMesh transform") logger.info("Running SQLMesh transform")
ok, err = run_shell( ok, err = run_shell(
"uv run sqlmesh -p transform/sqlmesh_padelnomics run prod", "uv run sqlmesh -p transform/sqlmesh_padelnomics plan prod --auto-apply",
) )
if not ok: if not ok:
send_alert(f"[transform] {err}") send_alert(f"[transform] {err}")