From 6153cc9b6bb3ee70183386a47bf07272107e34db Mon Sep 17 00:00:00 2001 From: Steve Clarke <84364906+s7clarke10@users.noreply.github.com> Date: Tue, 8 Oct 2024 15:05:42 +1300 Subject: [PATCH] Passing in a non-escaped table to the lsn lookup function --- tap_mssql/sync_strategies/log_based.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tap_mssql/sync_strategies/log_based.py b/tap_mssql/sync_strategies/log_based.py index e553e28..5a692fb 100644 --- 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())