Spaces:
Runtime error
Runtime error
Update app.py
Browse files
app.py
CHANGED
|
@@ -94,11 +94,13 @@ async def on_message(msg: cl.Message):
|
|
| 94 |
final_answer = cl.Message(content="")
|
| 95 |
|
| 96 |
for msg, metadata in graph.stream({"messages": [HumanMessage(content=msg.content)]}, stream_mode="messages", config=RunnableConfig(callbacks=[cb], **config)):
|
|
|
|
| 97 |
if (
|
| 98 |
msg.content
|
| 99 |
and not isinstance(msg, HumanMessage)
|
| 100 |
and metadata["langgraph_node"] == "final"
|
| 101 |
):
|
|
|
|
| 102 |
await final_answer.stream_token(msg.content)
|
| 103 |
|
| 104 |
await final_answer.send()
|
|
|
|
| 94 |
final_answer = cl.Message(content="")
|
| 95 |
|
| 96 |
for msg, metadata in graph.stream({"messages": [HumanMessage(content=msg.content)]}, stream_mode="messages", config=RunnableConfig(callbacks=[cb], **config)):
|
| 97 |
+
#print(msg.content)
|
| 98 |
if (
|
| 99 |
msg.content
|
| 100 |
and not isinstance(msg, HumanMessage)
|
| 101 |
and metadata["langgraph_node"] == "final"
|
| 102 |
):
|
| 103 |
+
print(msg.content)
|
| 104 |
await final_answer.stream_token(msg.content)
|
| 105 |
|
| 106 |
await final_answer.send()
|