From e6ffeef063f34555e4a8b7dde704190557ce8d25 Mon Sep 17 00:00:00 2001 From: eakmanrq <6326532+eakmanrq@users.noreply.github.com> Date: Fri, 7 Mar 2025 14:03:33 -0800 Subject: [PATCH] chore: remove private push snapshots on state sync --- sqlmesh/core/state_sync/db/facade.py | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/sqlmesh/core/state_sync/db/facade.py b/sqlmesh/core/state_sync/db/facade.py index eabd323cad..cb3dd10685 100644 --- a/sqlmesh/core/state_sync/db/facade.py +++ b/sqlmesh/core/state_sync/db/facade.py @@ -139,7 +139,7 @@ def push_snapshots(self, snapshots: t.Iterable[Snapshot]) -> None: snapshots = snapshots_by_id.values() if snapshots: - self._push_snapshots(snapshots) + self.snapshot_state.push_snapshots(snapshots) @transactional() def promote( @@ -442,9 +442,6 @@ def rollback(self) -> None: def state_type(self) -> str: return self.engine_adapter.dialect - def _push_snapshots(self, snapshots: t.Iterable[Snapshot]) -> None: - self.snapshot_state.push_snapshots(snapshots) - def _get_versions(self) -> Versions: return self.version_state.get_versions()