feat: continue after sleep

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):