Update app.py

app.py

@@ -164,12 +164,12 @@ def messages():
         def generate():
             nonlocal total_output_tokens
 
-            yield 'retry: 1000\n\n'  # 设置重试间隔
-
             def send_event(event_type, data):
-                event = create_event(event_type, data)
+                if isinstance(data, dict):
+                    data = json.dumps(data, ensure_ascii=False)
+                event_data = f"event: {event_type}\ndata: {data}\n\n"
                 logger.debug(f"Sending event: {event_type}")
-                return event
+                return event_data
 
             # 发送初始事件
             yield send_event("message_start", {