v0.4.2 优化k8s webssh 连接

2026-05-04 19:22:29 +08:00 · 2019-06-18 10:31:04 +08:00
parent e7be025c86
commit f134790dcb
1 changed files with 0 additions and 2 deletions
--- a/k8s/consumers.py
+++ b/k8s/consumers.py
@@ -18,10 +18,8 @@ class K8SStreamThread(threading.Thread):
        self.stream = container_stream

    def run(self):
-        # while not self.ws.exit_status_ready():
        while self.stream.is_open():
            time.sleep(0.1)
-
            if not self.stream.is_open():
                self.ws.close()
            try: