Update agent.py
Browse files
agent.py
CHANGED
|
@@ -187,25 +187,9 @@ def build_graph(provider: str = "google"):
|
|
| 187 |
# return {"messages": [sys_msg] + state["messages"] + [example_msg]}
|
| 188 |
|
| 189 |
def retriever(state: MessagesState):
|
| 190 |
-
|
| 191 |
-
|
| 192 |
-
|
| 193 |
-
page_content = similar_doc.page_content.strip()
|
| 194 |
-
|
| 195 |
-
try:
|
| 196 |
-
lines = page_content.splitlines()
|
| 197 |
-
final_line = next(line for line in lines if "final answer" in line.lower())
|
| 198 |
-
extracted_answer = final_line.split(":", 1)[1].strip()
|
| 199 |
-
|
| 200 |
-
return {
|
| 201 |
-
"messages": [{"type": "system", "content": extracted_answer}],
|
| 202 |
-
"should_end": True
|
| 203 |
-
}
|
| 204 |
-
except Exception:
|
| 205 |
-
return {
|
| 206 |
-
"messages": [{"type": "system", "content": "Retriever error: no answer found."}],
|
| 207 |
-
"should_end": True
|
| 208 |
-
}
|
| 209 |
|
| 210 |
# builder = StateGraph(MessagesState)
|
| 211 |
#builder.add_node("retriever", retriever)
|
|
|
|
| 187 |
# return {"messages": [sys_msg] + state["messages"] + [example_msg]}
|
| 188 |
|
| 189 |
def retriever(state: MessagesState):
|
| 190 |
+
question = state["messages"][-1].content
|
| 191 |
+
similar_doc = vector_store.similarity_search(question, k=1)[0]
|
| 192 |
+
return {"output": similar_doc.page_content.strip()}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| 193 |
|
| 194 |
# builder = StateGraph(MessagesState)
|
| 195 |
#builder.add_node("retriever", retriever)
|