Skip to content

Commit 2d9c32b

Browse files
address comments
1 parent b4bcb26 commit 2d9c32b

File tree

2 files changed

+1
-4
lines changed

2 files changed

+1
-4
lines changed

sqlmesh/core/plan/evaluator.py

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -238,7 +238,6 @@ def visit_backfill_stage(self, stage: stages.BackfillStage, plan: EvaluatablePla
238238
restatements_by_snapshot_id = {
239239
stage.all_snapshots[name].snapshot_id: interval
240240
for name, interval in plan.restatements.items()
241-
if name in stage.all_snapshots
242241
}
243242
errors, _ = scheduler.run_merged_intervals(
244243
merged_intervals=stage.snapshot_to_intervals,

sqlmesh/core/scheduler.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -452,9 +452,7 @@ def evaluate_node(node: SchedulingUnit) -> None:
452452
else:
453453
# Determine if this snapshot and interval is a restatement (for SCD type 2)
454454
is_restatement = (
455-
restatements is not None
456-
and snapshot.snapshot_id in restatements
457-
and start >= restatements[snapshot.snapshot_id][0]
455+
restatements is not None and snapshot.snapshot_id in restatements
458456
)
459457
audit_results = self.evaluate(
460458
snapshot=snapshot,

0 commit comments

Comments
 (0)