diff --git a/server.py b/server.py index bdfe4a652..7409bd1af 100644 --- a/server.py +++ b/server.py @@ -287,6 +287,7 @@ class PromptServer(): async def send(self, event, data, sid=None): message = {"type": event, "data": data} + self.poll_messages.append({"type": event, "data": data, "sid": sid, "poll_id": poll_id++}) if isinstance(message, str) == False: message = json.dumps(message) @@ -298,7 +299,6 @@ class PromptServer(): await self.sockets[sid].send_str(message) def send_sync(self, event, data, sid=None): - self.poll_messages.append({"type": event, "data": data, "sid": sid, "poll_id": poll_id++}) self.loop.call_soon_threadsafe( self.messages.put_nowait, (event, data, sid))