From 5e5f95649d4705205b654a1b09a533f006e0126e Mon Sep 17 00:00:00 2001 From: Paris Holley Date: Thu, 21 Oct 2021 15:53:21 -0400 Subject: [PATCH] fix for #48 --- tap_mongodb/sync_strategies/full_table.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/tap_mongodb/sync_strategies/full_table.py b/tap_mongodb/sync_strategies/full_table.py index 6934757..7ddaa28 100644 --- a/tap_mongodb/sync_strategies/full_table.py +++ b/tap_mongodb/sync_strategies/full_table.py @@ -110,7 +110,7 @@ def sync_collection(client, stream, state, projection): rows_saved += 1 schema_build_start_time = time.time() - if common.row_to_schema(schema, row): + if 'schema' not in stream and common.row_to_schema(schema, row): singer.write_message(singer.SchemaMessage( stream=common.calculate_destination_stream_name(stream), schema=schema,