From b78b99e0608f983d9c3e693f0b37665b76f5188f Mon Sep 17 00:00:00 2001 From: acidvegas Date: Thu, 7 Mar 2024 22:57:59 -0500 Subject: [PATCH] Changed yield to return when sentinal value is recieved through the FIFO --- ingestors/ingest_massdns.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/ingestors/ingest_massdns.py b/ingestors/ingest_massdns.py index 7e74040..862d7f9 100644 --- a/ingestors/ingest_massdns.py +++ b/ingestors/ingest_massdns.py @@ -77,7 +77,7 @@ async def process_data(file_path: str): # Sentinel value to indicate the end of a process (for closing out a FIFO stream) if line == '~eof': - yield last + return last # Skip empty lines if not line: