From 2e42245ad5c432e00ab3f3241909a8fa24662bed Mon Sep 17 00:00:00 2001 From: Deeman Date: Thu, 5 Mar 2026 21:49:51 +0100 Subject: [PATCH] fix(worker): use sqlmesh run prod instead of plan prod --auto-apply MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit `plan --auto-apply` only detects SQL model changes and won't re-run for new data. `run prod` evaluates missing cron intervals and picks up newly extracted data — matching the fix already applied to the supervisor. Co-Authored-By: Claude Sonnet 4.6 --- web/src/padelnomics/worker.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/web/src/padelnomics/worker.py b/web/src/padelnomics/worker.py index 0a91771..ceebc76 100644 --- a/web/src/padelnomics/worker.py +++ b/web/src/padelnomics/worker.py @@ -737,9 +737,9 @@ async def handle_run_extraction(payload: dict) -> None: @task("run_transform") async def handle_run_transform(payload: dict) -> None: - """Run SQLMesh transform (prod plan --auto-apply) in the background. + """Run SQLMesh transform (prod run) in the background. - Shells out to `uv run sqlmesh -p transform/sqlmesh_padelnomics plan prod --auto-apply`. + Shells out to `uv run sqlmesh -p transform/sqlmesh_padelnomics run prod`. 2-hour absolute timeout — same as extraction. """ import subprocess @@ -748,7 +748,7 @@ async def handle_run_transform(payload: dict) -> None: repo_root = Path(__file__).resolve().parents[4] result = await asyncio.to_thread( subprocess.run, - ["uv", "run", "sqlmesh", "-p", "transform/sqlmesh_padelnomics", "plan", "prod", "--auto-apply"], + ["uv", "run", "sqlmesh", "-p", "transform/sqlmesh_padelnomics", "run", "prod"], capture_output=True, text=True, timeout=7200, @@ -803,7 +803,7 @@ async def handle_run_pipeline(payload: dict) -> None: ), ( "transform", - ["uv", "run", "sqlmesh", "-p", "transform/sqlmesh_padelnomics", "plan", "prod", "--auto-apply"], + ["uv", "run", "sqlmesh", "-p", "transform/sqlmesh_padelnomics", "run", "prod"], 7200, ), (