出错时返回错误信息

zhaoqingang

2025-01-08 966f9e7367684f93349a347c9dbd69c763d3ae7b

出错时返回错误信息

 app/api/chat.py

@@ -577,6 +577,7 @@

                                                        message = answer.get("title", "")


                                                    result = {"message": message, "type": "system"}
                                            elif data.get("event") == "node_finished":
                                                workflow_list.append({
@@ -588,6 +589,18 @@
                                                    "elapsed_time":data.get("data", {}).get("elapsed_time", 0),
                                                    "error":data.get("data", {}).get("error", ""),
                                                })
                                                answer = data.get("data", "")
                                                if isinstance(answer, str):
                                                    logger.error("----------------未知数据--------------------")
                                                    logger.error(data)
                                                    continue
                                                elif isinstance(answer, dict):

                                                    message = answer.get("title", "")
                                                    if answer.get("status") == "failed":
                                                        message = answer.get("error", "")
                                                        result = {"message": message, "type": "system"}

                                            elif data.get("event") == "workflow_finished":
                                                answer = data.get("data", "")
                                                if isinstance(answer, str):
@@ -630,7 +643,7 @@
                                                                                              "conversation_id"))
                                                        node_list = []
                                                    except Exception as e:
                                                        logger.error("保存dcd ify的会话异常！")
                                                        logger.error("保存dify的会话异常！")
                                                        logger.error(e)
                                                    try:
                                                        await websocket.send_json(result)
@@ -711,6 +724,18 @@
                                                    "elapsed_time":data.get("data", {}).get("elapsed_time", 0),
                                                    "error":data.get("data", {}).get("error", ""),
                                                })

                                                answer = data.get("data", "")
                                                if isinstance(answer, str):
                                                    logger.error("----------------未知数据--------------------")
                                                    logger.error(data)
                                                    continue
                                                elif isinstance(answer, dict):

                                                    message = answer.get("title", "")
                                                    if answer.get("status") == "failed":
                                                        message = answer.get("error", "")
                                                    result = {"message": message, "type": "system"}
                                            elif data.get("event") == "message":
                                                answer_str = data.get("answer", "")
                                                # try: