File tree Expand file tree Collapse file tree 2 files changed +10
-1
lines changed Expand file tree Collapse file tree 2 files changed +10
-1
lines changed Original file line number Diff line number Diff line change @@ -431,7 +431,11 @@ def _get_physical_layer_update_stage(
431
431
return PhysicalLayerUpdateStage (
432
432
snapshots = self ._get_snapshots_to_create (plan , snapshots ),
433
433
all_snapshots = snapshots ,
434
- snapshots_with_missing_intervals = {s .snapshot_id for s in snapshots_to_intervals },
434
+ snapshots_with_missing_intervals = {
435
+ s .snapshot_id
436
+ for s in snapshots_to_intervals
437
+ if plan .is_selected_for_backfill (s .name )
438
+ },
435
439
deployability_index = deployability_index ,
436
440
)
437
441
Original file line number Diff line number Diff line change @@ -141,6 +141,10 @@ def test_build_plan_stages_basic(
141
141
snapshot_a .snapshot_id ,
142
142
snapshot_b .snapshot_id ,
143
143
}
144
+ assert {s .snapshot_id for s in physical_stage .snapshots_with_missing_intervals } == {
145
+ snapshot_a .snapshot_id ,
146
+ snapshot_b .snapshot_id ,
147
+ }
144
148
assert physical_stage .deployability_index == DeployabilityIndex .all_deployable ()
145
149
146
150
# Verify BackfillStage
@@ -357,6 +361,7 @@ def test_build_plan_stages_select_models(
357
361
assert len (physical_stage .snapshots ) == 1
358
362
assert {s .snapshot_id for s in physical_stage .snapshots } == {snapshot_a .snapshot_id }
359
363
assert physical_stage .deployability_index == DeployabilityIndex .all_deployable ()
364
+ assert physical_stage .snapshots_with_missing_intervals == {snapshot_a .snapshot_id }
360
365
361
366
# Verify BackfillStage
362
367
backfill_stage = stages [2 ]
You can’t perform that action at this time.
0 commit comments