Skip to content

Commit a1b21e3

Browse files
authored
Fix: Require the cache for upstream deps in the scheduler (#5571)
1 parent 23f66f9 commit a1b21e3

File tree

1 file changed

+1
-2
lines changed

1 file changed

+1
-2
lines changed

sqlmesh/core/scheduler.py

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -730,9 +730,8 @@ def _find_upstream_dependencies(
730730
parent_sid: SnapshotId,
731731
intervals_per_snapshot: t.Dict[str, Intervals],
732732
snapshots_to_create: t.Set[SnapshotId],
733-
cache: t.Optional[t.Dict[SnapshotId, t.Set[SchedulingUnit]]] = None,
733+
cache: t.Dict[SnapshotId, t.Set[SchedulingUnit]],
734734
) -> t.Set[SchedulingUnit]:
735-
cache = cache or {}
736735
if parent_sid not in self.snapshots:
737736
return set()
738737
if parent_sid in cache:

0 commit comments

Comments
 (0)