Skip to content

Commit b418f2e

Browse files
authored
fix missing ORDER BY statement during first incremental sync (transferwise#209)
1 parent a97d7d8 commit b418f2e

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

tap_postgres/sync_strategies/incremental.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -141,5 +141,6 @@ def _get_select_sql(params):
141141
select_sql = f"""
142142
SELECT {','.join(escaped_columns)}
143143
FROM {post_db.fully_qualified_table_name(schema_name, stream['table_name'])}
144+
ORDER BY {post_db.prepare_columns_sql(replication_key)} ASC
144145
"""
145146
return select_sql

0 commit comments

Comments
 (0)