Skip to content
This repository was archived by the owner on Mar 13, 2020. It is now read-only.

Commit e2cb927

Browse files
committed
Revert "oops.. forgot i changed the model"
This reverts commit 32d88e0.
1 parent 32d88e0 commit e2cb927

File tree

1 file changed

+11
-5
lines changed

1 file changed

+11
-5
lines changed

tests/unit_tests/test_MsSqlDataSource.py

Lines changed: 11 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -65,12 +65,14 @@ def test_get_table_info_change_tracking_info(self):
6565
for table in TestMsSqlDataSource.table_configs:
6666
print("TESTING ON TABLE: " + table["source_table"]["name"])
6767
print("FIRST TEST: INITIALISE TABLE")
68-
results = TestMsSqlDataSource.data_source.get_table_info(table["source_table"], last_sync_version)
68+
results = TestMsSqlDataSource.data_source.get_table_info(
69+
table["source_table"], last_sync_version).change_tracking_info
6970
self.assertEqual(results.force_full_load, True)
7071

7172
print("SECOND TEST: NO CHANGES")
7273
last_sync_version = results.sync_version
73-
results = TestMsSqlDataSource.data_source.get_table_info(table["source_table"], last_sync_version)
74+
results = TestMsSqlDataSource.data_source.get_table_info(
75+
table["source_table"], last_sync_version).change_tracking_info
7476
self.assertEqual(results.force_full_load, False)
7577

7678
print("OPERATION TESTS")
@@ -80,18 +82,22 @@ def test_get_table_info_change_tracking_info(self):
8082
TestMsSqlDataSource.data_source.database_engine.execute(
8183
text(operation_string).execution_options(autocommit=True))
8284

83-
results = TestMsSqlDataSource.data_source.get_table_info(table["source_table"], last_sync_version)
85+
results = TestMsSqlDataSource.data_source.get_table_info(
86+
table["source_table"], last_sync_version).change_tracking_info
8487
self.assertEqual(results.force_full_load, False, msg="Failed on: " + operation_string)
8588
last_sync_version = results.sync_version
8689

8790
print("EXTRA TEST: NO CHANGES")
8891
last_sync_version = results.sync_version
89-
results = TestMsSqlDataSource.data_source.get_table_info(table["source_table"], last_sync_version)
92+
results = TestMsSqlDataSource.data_source.get_table_info(
93+
table["source_table"], last_sync_version).change_tracking_info
9094
self.assertEqual(results.force_full_load, False)
9195

9296
print("EXTRA TEST: LOST TRACK")
9397
last_sync_version = -1
94-
results = TestMsSqlDataSource.data_source.get_table_info(table["source_table"], last_sync_version)
98+
results = TestMsSqlDataSource.data_source\
99+
.get_table_info(table["source_table"], last_sync_version)\
100+
.change_tracking_info
95101
self.assertEqual(results.force_full_load, True)
96102

97103
def test_can_handle_connection_string(self):

0 commit comments

Comments
 (0)