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,
         ),
         (