Skip to content

Commit d40b40e

Browse files
authored
Fix state sync rollback test case (#894)
1 parent 6efb8df commit d40b40e

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

tests/core/test_state_sync.py

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -783,16 +783,16 @@ def test_rollback(state_sync: EngineAdapterStateSync, mocker: MockerFixture) ->
783783
):
784784
state_sync.rollback()
785785

786-
mock = mocker.patch("sqlmesh.core.state_sync.EngineAdapterStateSync._restore_table")
786+
restore_table_spy = mocker.spy(state_sync, "_restore_table")
787787
state_sync._backup_state()
788788

789789
state_sync.rollback()
790-
mock.assert_any_call("sqlmesh._snapshots", "sqlmesh._snapshots_backup")
791-
mock.assert_any_call("sqlmesh._environments", "sqlmesh._environments_backup")
792-
mock.assert_any_call("sqlmesh._versions", "sqlmesh._versions_backup")
793-
assert not state_sync.engine_adapter.table_exists("select * from sqlmesh._snapshots_backup")
794-
assert not state_sync.engine_adapter.table_exists("select * from sqlmesh._environments_backup")
795-
assert not state_sync.engine_adapter.table_exists("select * from sqlmesh._versions_backup")
790+
restore_table_spy.assert_any_call("sqlmesh._snapshots", "sqlmesh._snapshots_backup")
791+
restore_table_spy.assert_any_call("sqlmesh._environments", "sqlmesh._environments_backup")
792+
restore_table_spy.assert_any_call("sqlmesh._versions", "sqlmesh._versions_backup")
793+
assert not state_sync.engine_adapter.table_exists("sqlmesh._snapshots_backup")
794+
assert not state_sync.engine_adapter.table_exists("sqlmesh._environments_backup")
795+
assert not state_sync.engine_adapter.table_exists("sqlmesh._versions_backup")
796796

797797

798798
def test_migrate_rows(state_sync: EngineAdapterStateSync, mocker: MockerFixture) -> None:

0 commit comments

Comments
 (0)