Readd 1 second queue get timeout
Otherwise daemon stops will sometimes inexplicably block.
This commit is contained in:
parent
99fd7ebe63
commit
5be968123f
|
@ -192,7 +192,7 @@ class ZookeeperLogger(Thread):
|
||||||
while self.running:
|
while self.running:
|
||||||
# Get a new message
|
# Get a new message
|
||||||
try:
|
try:
|
||||||
message = self.queue.get()
|
message = self.queue.get(timeout=1)
|
||||||
if not message:
|
if not message:
|
||||||
continue
|
continue
|
||||||
except Exception:
|
except Exception:
|
||||||
|
|
Loading…
Reference in New Issue