From d20c9cf4b0d390f66860c0c15abd4731d52d8c18 Mon Sep 17 00:00:00 2001 From: seanglynn-thrive <93200565+seanglynn-thrive@users.noreply.github.com> Date: Tue, 31 May 2022 15:41:14 +0100 Subject: [PATCH] Update __init__.py --- tap_postgres/__init__.py | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/tap_postgres/__init__.py b/tap_postgres/__init__.py index 5c7c2ac1..a14f24b8 100644 --- 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)