We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 6d8399a commit 53ec8daCopy full SHA for 53ec8da
1 file changed
pynumaflow/accumulator/servicer/task_manager.py
@@ -263,11 +263,6 @@ async def process_input_stream(
263
fut = task.future
264
await fut
265
266
- # # Send an EOF message to the local result queue
267
- # # This will signal that the task has completed processing
268
- # TODO: remove this and test end to end as we are sending EOF in _invoke_accumulator
269
- await task.result_queue.put(STREAM_EOF)
270
-
271
# Wait for the local queue to write
272
# all the results of this task to the global result queue
273
con_future = task.consumer_future
0 commit comments