Skip to content
Snippets Groups Projects
Commit fadd54a9 authored by Martin Blanchard's avatar Martin Blanchard
Browse files

_monitoring.py: Ensure buffer gets flushed in non-async mode

parent 50f3f63b
No related branches found
No related tags found
Loading
......@@ -156,9 +156,11 @@ class MonitoringBus:
output_writers.append(output_file)
while True:
if await __streaming_worker(iter(output_file)):
if await __streaming_worker([output_file]):
self.__sequence_number += 1
output_file.flush()
else:
output_writers.append(sys.stdout.buffer)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment