fix missing ORDER BY statement during first incremental sync (#209)

transferwise · Mar 29, 2023 · b418f2e · b418f2e
1 parent a97d7d8
commit b418f2e
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/tap_postgres/sync_strategies/incremental.py b/tap_postgres/sync_strategies/incremental.py
@@ -141,5 +141,6 @@ def _get_select_sql(params):
         select_sql = f"""
         SELECT {','.join(escaped_columns)}
         FROM {post_db.fully_qualified_table_name(schema_name, stream['table_name'])}
+        ORDER BY {post_db.prepare_columns_sql(replication_key)} ASC
         """
     return select_sql