diff --git a/daemon-common/log.py b/daemon-common/log.py index 02ea1a6d..e1375a88 100644 --- a/daemon-common/log.py +++ b/daemon-common/log.py @@ -192,7 +192,7 @@ class ZookeeperLogger(Thread): while self.running: # Get a new message try: - message = self.queue.get() + message = self.queue.get(timeout=1) if not message: continue except Exception: