From da7b4fd11aedc16e85139d511d4cfb94720fcb98 Mon Sep 17 00:00:00 2001
From: Yuanpei-Wu <fiverwyp@gmail.com>
Date: Tue, 20 Aug 2024 15:08:33 +0800
Subject: [PATCH] send sync not redis

---
 server.py | 24 ++++++++++++------------
 1 file changed, 12 insertions(+), 12 deletions(-)

diff --git a/server.py b/server.py
index 411e8355a..0f98a5184 100644
--- a/server.py
+++ b/server.py
@@ -655,18 +655,18 @@ class PromptServer():
             await send_socket_catch_exception(self.sockets[sid].send_json, message)
 
     def send_sync(self, event, data, sid=None):
-        if hasattr(self, "last_prompt_id") is not True:
-            logging.warning("server has not attr last_prompt_id")
-            return
-        prompt_id = self.last_prompt_id
-        key = "comfy_response_" + prompt_id
-        message = {
-            "type": event,
-            "data": data,
-        }
-        res = self.redis_op.zadd_with_expire(key, json.dumps(message), int(time.time()), 120)
-        if not res:
-            logging.warning(f"Failed to send {event}")
+        # if hasattr(self, "last_prompt_id") is not True:
+        #     logging.warning("server has not attr last_prompt_id")
+        #     return
+        # prompt_id = self.last_prompt_id
+        # key = "comfy_response_" + prompt_id
+        # message = {
+        #     "type": event,
+        #     "data": data,
+        # }
+        # res = self.redis_op.zadd_with_expire(key, json.dumps(message), int(time.time()), 120)
+        # if not res:
+        #     logging.warning(f"Failed to send {event}")
         self.loop.call_soon_threadsafe(
             self.messages.put_nowait, (event, data, sid))