Skip to content

Commit bbe44a3

Browse files
authored
Fix: Use a correct deoployability index when running the scheduler against non-prod environments (#2343)
1 parent c5b52b2 commit bbe44a3

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

sqlmesh/core/scheduler.py

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -5,6 +5,7 @@
55
import typing as t
66
from datetime import datetime
77

8+
from sqlmesh.core import constants as c
89
from sqlmesh.core.console import Console, get_console
910
from sqlmesh.core.environment import EnvironmentNamingInfo
1011
from sqlmesh.core.model import SeedModel
@@ -243,7 +244,11 @@ def run(
243244
else:
244245
environment_naming_info = environment
245246

246-
deployability_index = deployability_index or DeployabilityIndex.all_deployable()
247+
deployability_index = deployability_index or (
248+
DeployabilityIndex.create(self.snapshots.values())
249+
if environment_naming_info.name != c.PROD
250+
else DeployabilityIndex.all_deployable()
251+
)
247252
execution_time = execution_time or now()
248253
batches = self.batches(
249254
start,

0 commit comments

Comments
 (0)