Add a contingency for temporary read error

2025-08-24 04:00:28 +00:00 · 2021-04-02 11:54:38 -04:00
parent 4a0d419f85
commit 2d43fac1b5
1 changed files with 4 additions and 1 deletions
--- 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: