diff --git a/worker.py b/worker.py index 1d5946a..646ad7d 100644 --- a/worker.py +++ b/worker.py @@ -25,6 +25,7 @@ class EventListener(Thread): item = self.pubsub.get_message() if not item: time.sleep(0.01) + continue channel = item['channel'].decode() data = item['data'] if not isinstance(data, bytes):