handle NoneType in document_stream (#155)

JSCU-CNI · web-flow · commit 25d783a95dd0 · 2025-01-08T18:03:09.000+01:00
diff --git a/flow/record/adapter/elastic.py b/flow/record/adapter/elastic.py
@@ -128,6 +128,8 @@ def document_stream(self) -> Iterator[dict]:
             record = self.queue.get()
             if record is StopIteration:
                 break
+            if not record:
+                continue
             yield self.record_to_document(record, index=self.index)
 
     def streaming_bulk_thread(self) -> None:
