From 460636b6a4d25a26d7d95e3c3226db533373c1e2 Mon Sep 17 00:00:00 2001 From: Paris Holley Date: Thu, 21 Oct 2021 15:51:12 -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,