Skip to content

Commit

Permalink
Passing in a non-escaped table to the lsn lookup function
Browse files Browse the repository at this point in the history
  • Loading branch information
s7clarke10 authored Oct 8, 2024
1 parent d1c4540 commit 6153cc9
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion tap_mssql/sync_strategies/log_based.py
Original file line number Diff line number Diff line change
Expand Up @@ -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())
Expand Down

0 comments on commit 6153cc9

Please sign in to comment.