Passing in a non-escaped table to the lsn lookup function

s7clarke10 · web-flow · commit 6153cc9b6bb3 · 2024-10-08T15:05:42.000+13:00
diff --git a/tap_mssql/sync_strategies/log_based.py b/tap_mssql/sync_strategies/log_based.py
@@ -311,7 +311,7 @@ def sync_table(mssql_conn, config, catalog_entry, state, columns, stream_version
                     ).format(escaped_schema_name, escape_table_name)
                 )
 
-            lsn_range = get_lsn_available_range(mssql_conn, escaped_cdc_table)
+            lsn_range = get_lsn_available_range(mssql_conn, table_name)
 
             if lsn_range[0] is not None:  # Test to see if there are any change records to process
                 lsn_from = str(lsn_range[0].hex())

Original file line number	Diff line number	Diff line change
`@@ -311,7 +311,7 @@ def sync_table(mssql_conn, config, catalog_entry, state, columns, stream_version`
`311`	`311`	`).format(escaped_schema_name, escape_table_name)`
`312`	`312`	`)`
`313`	`313`
`314`		`- lsn_range = get_lsn_available_range(mssql_conn, escaped_cdc_table)`
	`314`	`+ lsn_range = get_lsn_available_range(mssql_conn, table_name)`
`315`	`315`
`316`	`316`	`if lsn_range[0] is not None: # Test to see if there are any change records to process`
`317`	`317`	`lsn_from = str(lsn_range[0].hex())`