From 17da21cc945a7c2f6c47b505c054c65d12f6b068 Mon Sep 17 00:00:00 2001 From: Iaroslav Zeigerman Date: Tue, 25 Mar 2025 13:23:19 -0700 Subject: [PATCH] Fix: Don't expand intervals when recording an empty backfill --- sqlmesh/core/plan/evaluator.py | 4 +++- tests/core/test_integration.py | 6 +++++- 2 files changed, 8 insertions(+), 2 deletions(-) diff --git a/sqlmesh/core/plan/evaluator.py b/sqlmesh/core/plan/evaluator.py index 2adbe9e39..5b01db5ff 100644 --- a/sqlmesh/core/plan/evaluator.py +++ b/sqlmesh/core/plan/evaluator.py @@ -197,7 +197,9 @@ def _backfill( if plan.empty_backfill: intervals_to_add = [] for snapshot in snapshots_by_name.values(): - intervals = [snapshot.inclusive_exclusive(plan.start, plan.end, strict=False)] + intervals = [ + snapshot.inclusive_exclusive(plan.start, plan.end, strict=False, expand=False) + ] is_deployable = deployability_index.is_deployable(snapshot) intervals_to_add.append( SnapshotIntervals( diff --git a/tests/core/test_integration.py b/tests/core/test_integration.py index 0cab49083..d147cc287 100644 --- a/tests/core/test_integration.py +++ b/tests/core/test_integration.py @@ -3874,7 +3874,7 @@ def test_create_environment_no_changes_with_selector(init_and_plan_context: t.Ca @time_machine.travel("2023-01-08 15:00:00 UTC") -def test_empty_bacfkill(init_and_plan_context: t.Callable): +def test_empty_backfill(init_and_plan_context: t.Callable): context, _ = init_and_plan_context("examples/sushi") plan = context.plan_builder("prod", skip_tests=True, empty_backfill=True).build() @@ -3895,6 +3895,10 @@ def test_empty_bacfkill(init_and_plan_context: t.Callable): assert not plan.has_changes assert not plan.missing_intervals + snapshots = plan.snapshots + for snapshot in snapshots.values(): + assert snapshot.intervals[-1][1] <= to_timestamp("2023-01-08") + @time_machine.travel("2023-01-08 15:00:00 UTC") def test_dbt_requirements(sushi_dbt_context: Context):