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()