From 2d43fac1b5570969f0842c3f708929ec21271a02 Mon Sep 17 00:00:00 2001 From: Jarrod Johnson Date: Fri, 2 Apr 2021 11:54:38 -0400 Subject: [PATCH] Add a contingency for temporary read error --- confluent_server/confluent/consoleserver.py | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/confluent_server/confluent/consoleserver.py b/confluent_server/confluent/consoleserver.py index 152fa162..ad01585c 100644 --- a/confluent_server/confluent/consoleserver.py +++ b/confluent_server/confluent/consoleserver.py @@ -73,7 +73,10 @@ def get_buffer_output(nodename): out.flush() select.select((instream,), (), (), 30) while not outdata or outdata[-1]: - chunk = instream.read(128) + try: + chunk = instream.read(128) + except IOError: + chunk = None if chunk: outdata.extend(chunk) else: