Skip to content
This repository was archived by the owner on Sep 23, 2024. It is now read-only.

Commit aaa6878

Browse files
authored
Fix incremental select (#149)
1 parent 9cf0839 commit aaa6878

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

tap_postgres/sync_strategies/incremental.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ def sync_table(conn_info, stream, state, desired_columns, md_map):
9090
else:
9191
#if not replication_key_value
9292
select_sql = f"""SELECT {','.join(escaped_columns)}
93-
FROM { post_db.fully_qualified_table_name(schema_name, stream['table_name']),}
93+
FROM { post_db.fully_qualified_table_name(schema_name, stream['table_name'])}
9494
ORDER BY {post_db.prepare_columns_sql(replication_key)} ASC"""
9595

9696
LOGGER.info('select statement: %s with itersize %s', select_sql, cur.itersize)

0 commit comments

Comments
 (0)