Do not refresh streams schema on sync

See discussion at transferwisegh-129. Fix transferwisegh-101, fix transferwisegh-128.
astrojuanlu · May 11, 2022 · d6d5898 · d6d5898
1 parent 14a0be5
commit d6d5898
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/tap_postgres/__init__.py b/tap_postgres/__init__.py
@@ -287,7 +287,9 @@ def do_sync(conn_config, catalog, default_replication_method, state, state_file=
     else:
         end_lsn = None
 
-    refresh_streams_schema(conn_config, streams)
+    # Do *not* refresh streams schema on sync
+    # See https://github.com/transferwise/pipelinewise-tap-postgres/pull/129
+    # refresh_streams_schema(conn_config, streams)
 
     sync_method_lookup, traditional_streams, logical_streams = \
         sync_method_for_streams(streams, state, default_replication_method)