rag-gateway
parent: 966f9e73 | 补丁 | 提交 | ignore whitespace
zhaoqingang
2025-01-10 f0a780fecb0e5799f6427cc89da8e5600edc71a2 
节点返回错误日志
1个文件已修改
12 ■■■■■ 已修改文件
app/api/chat.py 12 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史 
 app/api/chat.py


@@ -578,7 +578,7 @@


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






                                                    result = {"message": message, "type": "system"}


                                                    result = {"message": message, "type": "system", "workflow":{"node_data": workflow_list}}


                                            elif data.get("event") == "node_finished":


                                                workflow_list.append({


                                                    "title": data.get("data", {}).get("title", ""),


@@ -599,7 +599,7 @@


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


                                                    if answer.get("status") == "failed":


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


                                                        result = {"message": message, "type": "system"}


                                                        result = {"message": message, "type": "system", "workflow":{"node_data": workflow_list}}




                                            elif data.get("event") == "workflow_finished":


                                                answer = data.get("data", "")


@@ -631,7 +631,7 @@


                                                        "error": answer.get("error", ""),


                                                        "elapsed_time": answer.get("elapsed_time", 0)


                                                    }


                                                    result = {"message": message, "type": "message", "download_url": download_url}


                                                    result = {"message": message, "type": "message", "download_url": download_url, "workflow":workflow_dict}


                                                    try:


                                                        SessionService(db).update_session(chat_id,


                                                                                          message={"role": "assistant",


@@ -713,7 +713,7 @@




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




                                                    result = {"message": message, "type": "system"}


                                                    result = {"message": message, "type": "system", "workflow":{"node_data": workflow_list}}


                                            elif data.get("event") == "node_finished":


                                                workflow_list.append({


                                                    "title": data.get("data", {}).get("title", ""),


@@ -735,7 +735,7 @@


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


                                                    if answer.get("status") == "failed":


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


                                                    result = {"message": message, "type": "system"}


                                                    result = {"message": message, "type": "system", "workflow":{"node_data": workflow_list}}


                                            elif data.get("event") == "message":


                                                answer_str = data.get("answer", "")


                                                # try:


@@ -745,7 +745,7 @@


                                                #     print(e)


                                                #     continue


                                                result = {"message": answer_str, "type": "message",


                                                          "download_url": ""}


                                                          "download_url": "", "workflow": {"node_data": workflow_list}}




                                                # try:


                                                #     await websocket.send_json(result)