We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 0fdd978 commit 1312781Copy full SHA for 1312781
sqlmesh/core/plan/stages.py
@@ -361,11 +361,14 @@ def build(self, plan: EvaluatablePlan) -> t.List[PlanStage]:
361
# Otherwise, unpause right after updatig the environment record.
362
stages.append(UnpauseStage(promoted_snapshots=promoted_snapshots))
363
364
+ full_demoted_snapshots = self.state_reader.get_snapshots(
365
+ s.snapshot_id for s in demoted_snapshots if s.snapshot_id not in snapshots
366
+ )
367
virtual_layer_update_stage = self._get_virtual_layer_update_stage(
368
promoted_snapshots,
369
demoted_snapshots,
370
demoted_environment_naming_info,
- snapshots,
371
+ snapshots | full_demoted_snapshots,
372
deployability_index,
373
)
374
if virtual_layer_update_stage:
0 commit comments