Merge branch 'transferwise:master' into master

Author: judahrand

CHANGELOG.md

@@ -1,3 +1,8 @@
+1.8.3 (2022-01-18)
+-------------------
+**Fixes**
+- INCREMENTAL: generate valid SQL to extract data from tables where no `replication_key_value` in the state file.
+
 1.8.2 (2022-01-14)
 -------------------
 **Fixes**

setup.py

@@ -6,7 +6,7 @@
     long_description = f.read()
 
 setup(name='pipelinewise-tap-postgres',
-      version='1.8.2',
+      version='1.8.3',
       description='Singer.io tap for extracting data from PostgresSQL - PipelineWise compatible',
       long_description=long_description,
       long_description_content_type='text/markdown',

tap_postgres/sync_strategies/incremental.py

@@ -90,7 +90,7 @@ def sync_table(conn_info, stream, state, desired_columns, md_map):
                 else:
                     #if not replication_key_value
                     select_sql = f"""SELECT {','.join(escaped_columns)}
-                                    FROM { post_db.fully_qualified_table_name(schema_name, stream['table_name']),}
+                                    FROM { post_db.fully_qualified_table_name(schema_name, stream['table_name'])}
                                     ORDER BY {post_db.prepare_columns_sql(replication_key)} ASC"""
 
                 LOGGER.info('select statement: %s with itersize %s', select_sql, cur.itersize)