From 61907ec7a2edcfe1c29ad635bdb8116da9fbc005 Mon Sep 17 00:00:00 2001 From: Steve Clarke <84364906+s7clarke10@users.noreply.github.com> Date: Wed, 9 Oct 2024 14:43:20 +1300 Subject: [PATCH] Passing the correct formatted cdc table name --- 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 5a692fb..2f159a3 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, table_name) + lsn_range = get_lsn_available_range(mssql_conn, cdc_table) 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())