Skip to content

Commit 6ed8333

Browse files
committed
fix: clean signal registry before loading signals for the given project
1 parent 009f4b1 commit 6ed8333

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

sqlmesh/core/loader.py

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -710,6 +710,9 @@ def _load_materializations(self) -> None:
710710
def _load_signals(self) -> UniqueKeyDict[str, signal]:
711711
"""Loads signals for the built-in scheduler."""
712712

713+
base_signals = signal.get_registry()
714+
signal.set_registry(UniqueKeyDict("signals"))
715+
713716
signals_max_mtime: t.Optional[float] = None
714717

715718
for path in self._glob_paths(
@@ -729,7 +732,10 @@ def _load_signals(self) -> UniqueKeyDict[str, signal]:
729732

730733
self._signals_max_mtime = signals_max_mtime
731734

732-
return signal.get_registry()
735+
signals = signal.get_registry()
736+
signal.set_registry(base_signals)
737+
738+
return signals
733739

734740
def _load_audits(
735741
self, macros: MacroRegistry, jinja_macros: JinjaMacroRegistry

0 commit comments

Comments
 (0)