No need to wait here

plugins/sqs.py

@@ -66,7 +66,7 @@ async def get_payloads(server: pypubsub.Server, config: dict):
                                 js = json.loads(body)
                                 path = js.get('pubsub_path', '/')  # Default to catch-all pubsub topic
                                 payload = pypubsub.Payload(path, js)
-                                server.pending_events.put(payload)
+                                server.pending_events.put_nowait(payload)
                                 backlog_size = server.config.backlog.queue_size
                                 if backlog_size > 0:
                                     server.backlog.append(payload)