fix sse get non-exist key get lots error logs on the plugin daemon

Author: junjie.miao

endpoints/sse.py

@@ -23,16 +23,11 @@ def generate():
             yield create_sse_message("endpoint", endpoint)
 
             while True:
-                message = None
-                try:
+                if self.session.storage.exist(session_id):
                     message = self.session.storage.get(session_id)
-                except:
-                    pass
-                if message is None:
-                    time.sleep(0.5)
-                    continue
-                message = message.decode()
-                self.session.storage.delete(session_id)
-                yield create_sse_message("message", message)
+                    message = message.decode()
+                    self.session.storage.delete(session_id)
+                    yield create_sse_message("message", message)
+                time.sleep(0.5)
 
         return Response(generate(), status=200, content_type="text/event-stream")

requirements.txt

@@ -1 +1 @@
-dify_plugin>=0.1.0,<0.2.0
+dify_plugin>=0.2.1,<0.3.0