Update agent.py
Browse files
agent.py
CHANGED
|
@@ -186,20 +186,19 @@ def build_graph(provider: str = "google"):
|
|
| 186 |
# )
|
| 187 |
# return {"messages": [sys_msg] + state["messages"] + [example_msg]}
|
| 188 |
|
|
|
|
|
|
|
| 189 |
def retriever(state: MessagesState):
|
| 190 |
-
"""Retriever node"""
|
| 191 |
query = state["messages"][-1].content
|
| 192 |
similar_doc = vector_store.similarity_search(query, k=1)[0]
|
| 193 |
|
| 194 |
-
# Final answer extrahieren
|
| 195 |
content = similar_doc.page_content
|
| 196 |
if "Final answer :" in content:
|
| 197 |
answer = content.split("Final answer :")[-1].strip()
|
| 198 |
else:
|
| 199 |
answer = content.strip()
|
| 200 |
|
| 201 |
-
|
| 202 |
-
return {"messages": answer }
|
| 203 |
|
| 204 |
# builder = StateGraph(MessagesState)
|
| 205 |
#builder.add_node("retriever", retriever)
|
|
|
|
| 186 |
# )
|
| 187 |
# return {"messages": [sys_msg] + state["messages"] + [example_msg]}
|
| 188 |
|
| 189 |
+
from langchain_core.messages import AIMessage
|
| 190 |
+
|
| 191 |
def retriever(state: MessagesState):
|
|
|
|
| 192 |
query = state["messages"][-1].content
|
| 193 |
similar_doc = vector_store.similarity_search(query, k=1)[0]
|
| 194 |
|
|
|
|
| 195 |
content = similar_doc.page_content
|
| 196 |
if "Final answer :" in content:
|
| 197 |
answer = content.split("Final answer :")[-1].strip()
|
| 198 |
else:
|
| 199 |
answer = content.strip()
|
| 200 |
|
| 201 |
+
return {"messages": [AIMessage(content=answer)]}
|
|
|
|
| 202 |
|
| 203 |
# builder = StateGraph(MessagesState)
|
| 204 |
#builder.add_node("retriever", retriever)
|