fix for singer-io#48

parisholley · Oct 21, 2021 · 5e5f956 · 5e5f956
1 parent 49878ec
commit 5e5f956
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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,