diff --git a/k8s/consumers.py b/k8s/consumers.py index a1c1712..f2c94d1 100644 --- 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: