Spaces:
Sleeping
Sleeping
Update app.py
Browse files
app.py
CHANGED
|
@@ -246,14 +246,16 @@ def create_app():
|
|
| 246 |
try:
|
| 247 |
agent_app = create_agent_app(abs_file_path)
|
| 248 |
socketio.emit("log", {"message": "[INFO]: Agent initialized."})
|
| 249 |
-
|
|
|
|
| 250 |
except Exception as e:
|
| 251 |
error_message = f"Agent initialization failed: {str(e)}"
|
| 252 |
socketio.emit("log", {"message": f"[ERROR]: {error_message}"})
|
| 253 |
socketio.emit("final", {"message": "Agent initialization failed."})
|
| 254 |
-
|
|
|
|
| 255 |
return
|
| 256 |
-
|
| 257 |
query = {"messages": [("user", prompt)]}
|
| 258 |
result = agent_app.invoke(query)
|
| 259 |
try:
|
|
@@ -262,21 +264,25 @@ def create_app():
|
|
| 262 |
result = result["messages"][-1].tool_calls[0]["args"]["final_answer"]
|
| 263 |
else:
|
| 264 |
result = "Query execution did not return a valid final answer."
|
| 265 |
-
|
|
|
|
| 266 |
except KeyError:
|
| 267 |
result = "The agent's response did not contain the expected 'final_answer' key."
|
| 268 |
-
|
|
|
|
| 269 |
except Exception as e:
|
| 270 |
result = f"An error occurred while processing the agent's response: {str(e)}"
|
| 271 |
-
|
| 272 |
-
|
|
|
|
| 273 |
print("final_answer------>", result)
|
| 274 |
socketio.emit("final", {"message": result})
|
| 275 |
except Exception as e:
|
| 276 |
error_message = f"Generation failed: {str(e)}"
|
| 277 |
socketio.emit("log", {"message": f"[ERROR]: {error_message}"})
|
| 278 |
socketio.emit("final", {"message": "Generation failed."})
|
| 279 |
-
|
|
|
|
| 280 |
traceback.print_exc()
|
| 281 |
|
| 282 |
@flask_app.route("/")
|
|
|
|
| 246 |
try:
|
| 247 |
agent_app = create_agent_app(abs_file_path)
|
| 248 |
socketio.emit("log", {"message": "[INFO]: Agent initialized."})
|
| 249 |
+
with app.app_context():
|
| 250 |
+
flash("Agent initialized.", "info")
|
| 251 |
except Exception as e:
|
| 252 |
error_message = f"Agent initialization failed: {str(e)}"
|
| 253 |
socketio.emit("log", {"message": f"[ERROR]: {error_message}"})
|
| 254 |
socketio.emit("final", {"message": "Agent initialization failed."})
|
| 255 |
+
with app.app_context():
|
| 256 |
+
flash(error_message, "error")
|
| 257 |
return
|
| 258 |
+
|
| 259 |
query = {"messages": [("user", prompt)]}
|
| 260 |
result = agent_app.invoke(query)
|
| 261 |
try:
|
|
|
|
| 264 |
result = result["messages"][-1].tool_calls[0]["args"]["final_answer"]
|
| 265 |
else:
|
| 266 |
result = "Query execution did not return a valid final answer."
|
| 267 |
+
with app.app_context():
|
| 268 |
+
flash("Query execution did not return a valid final answer.", "warning")
|
| 269 |
except KeyError:
|
| 270 |
result = "The agent's response did not contain the expected 'final_answer' key."
|
| 271 |
+
with app.app_context():
|
| 272 |
+
flash("Unexpected agent response format.", "warning")
|
| 273 |
except Exception as e:
|
| 274 |
result = f"An error occurred while processing the agent's response: {str(e)}"
|
| 275 |
+
with app.app_context():
|
| 276 |
+
flash("Error processing agent response.", "error")
|
| 277 |
+
|
| 278 |
print("final_answer------>", result)
|
| 279 |
socketio.emit("final", {"message": result})
|
| 280 |
except Exception as e:
|
| 281 |
error_message = f"Generation failed: {str(e)}"
|
| 282 |
socketio.emit("log", {"message": f"[ERROR]: {error_message}"})
|
| 283 |
socketio.emit("final", {"message": "Generation failed."})
|
| 284 |
+
with app.app_context():
|
| 285 |
+
flash(error_message, "error")
|
| 286 |
traceback.print_exc()
|
| 287 |
|
| 288 |
@flask_app.route("/")
|