Test _sdc_table_version

meltano · Nov 29, 2024 · 8117fd0 · 8117fd0
1 parent f22e730
commit 8117fd0
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/tests/samples/test_target_sqlite.py b/tests/samples/test_target_sqlite.py
@@ -296,6 +296,7 @@ def test_sqlite_add_record_metadata(sqlite_target_add_record_metadata: SQLTarget
         json.dumps(msg)
         for msg in [
             schema_msg,
+            {"type": "ACTIVATE_VERSION", "stream": test_tbl, "version": 12345},
             {
                 "type": "RECORD",
                 "stream": test_tbl,
@@ -324,6 +325,9 @@ def test_sqlite_add_record_metadata(sqlite_target_add_record_metadata: SQLTarget
     assert "_sdc_sync_started_at" in table.columns
     assert type(table.columns["_sdc_sync_started_at"].type) is sa.INTEGER
 
+    assert "_sdc_table_version" in table.columns
+    assert type(table.columns["_sdc_table_version"].type) is sa.INTEGER
+
 
 def test_sqlite_column_morph(sqlite_sample_target: SQLTarget):
     """End-to-end-to-end test for SQLite tap and target.