Changed yield to return when sentinal value is recieved through the FIFO
This commit is contained in:
parent
da065c6889
commit
b78b99e060
@ -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:
|
||||
|
Loading…
Reference in New Issue
Block a user