fix: only create file if more than 1 message arrived (#11)

kgpayne · Jan 8, 2023 · c0a0b0a · c0a0b0a
1 parent d26ab2b
commit c0a0b0a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/target_singer_jsonl/__init__.py b/target_singer_jsonl/__init__.py
@@ -196,7 +196,8 @@ def persist_lines(config, lines):
             raise Exception(f"Unknown message type {t} in message {message}")
 
     for stream, messages in stream_lines.items():
-        write_lines(config, stream, messages)
+        if len[messages] > 1:  # don't write SCHEMA without any RECORDs
+            write_lines(config, stream, messages)
 
     return state