Spaces:
Runtime error
Runtime error
Update agent.py
Browse files
agent.py
CHANGED
|
@@ -190,60 +190,60 @@ def build_graph(provider: str = "groq"):
|
|
| 190 |
"""Assistant node"""
|
| 191 |
return {"messages": [llm_with_tools.invoke(state["messages"])]}
|
| 192 |
|
| 193 |
-
|
| 194 |
-
|
| 195 |
-
|
| 196 |
-
|
| 197 |
-
|
| 198 |
-
|
| 199 |
-
|
| 200 |
|
| 201 |
-
# def retriever(state: MessagesState):
|
| 202 |
-
# """Retriever node"""
|
| 203 |
-
# messages = state.get("messages", [])
|
| 204 |
-
# if not messages:
|
| 205 |
-
# print("β οΈ No messages received in retriever node.")
|
| 206 |
-
# return {"messages": []}
|
| 207 |
|
| 208 |
-
# query = messages[0].content
|
| 209 |
-
# similar_question = vector_store.similarity_search(query)
|
| 210 |
|
| 211 |
-
# if not similar_question:
|
| 212 |
-
# print("β οΈ No similar questions found.")
|
| 213 |
-
# return {"messages": messages}
|
| 214 |
|
| 215 |
-
# example_msg = HumanMessage(
|
| 216 |
-
# content=f"Here I provide a similar question and answer for reference:\n\n{similar_question[0].page_content}",
|
| 217 |
-
# )
|
| 218 |
|
| 219 |
-
# return {"messages": [sys_msg] + messages + [example_msg]}
|
| 220 |
|
| 221 |
-
|
| 222 |
-
|
| 223 |
-
|
| 224 |
-
|
| 225 |
-
|
| 226 |
-
|
| 227 |
|
| 228 |
-
|
| 229 |
-
|
| 230 |
|
| 231 |
-
|
| 232 |
-
|
| 233 |
-
|
| 234 |
-
|
| 235 |
-
|
| 236 |
-
|
| 237 |
|
| 238 |
-
|
| 239 |
-
|
| 240 |
-
|
| 241 |
|
| 242 |
-
|
| 243 |
-
|
| 244 |
-
|
| 245 |
|
| 246 |
-
|
| 247 |
|
| 248 |
|
| 249 |
builder = StateGraph(MessagesState)
|
|
|
|
| 190 |
"""Assistant node"""
|
| 191 |
return {"messages": [llm_with_tools.invoke(state["messages"])]}
|
| 192 |
|
| 193 |
+
def retriever(state: MessagesState):
|
| 194 |
+
"""Retriever node"""
|
| 195 |
+
similar_question = vector_store.similarity_search(state["messages"][0].content)
|
| 196 |
+
example_msg = HumanMessage(
|
| 197 |
+
content=f"Here I provide a similar question and answer for reference: \n\n{similar_question[0].page_content}",
|
| 198 |
+
)
|
| 199 |
+
return {"messages": [sys_msg] + state["messages"] + [example_msg]}
|
| 200 |
|
| 201 |
+
# # def retriever(state: MessagesState):
|
| 202 |
+
# # """Retriever node"""
|
| 203 |
+
# # messages = state.get("messages", [])
|
| 204 |
+
# # if not messages:
|
| 205 |
+
# # print("β οΈ No messages received in retriever node.")
|
| 206 |
+
# # return {"messages": []}
|
| 207 |
|
| 208 |
+
# # query = messages[0].content
|
| 209 |
+
# # similar_question = vector_store.similarity_search(query)
|
| 210 |
|
| 211 |
+
# # if not similar_question:
|
| 212 |
+
# # print("β οΈ No similar questions found.")
|
| 213 |
+
# # return {"messages": messages}
|
| 214 |
|
| 215 |
+
# # example_msg = HumanMessage(
|
| 216 |
+
# # content=f"Here I provide a similar question and answer for reference:\n\n{similar_question[0].page_content}",
|
| 217 |
+
# # )
|
| 218 |
|
| 219 |
+
# # return {"messages": [sys_msg] + messages + [example_msg]}
|
| 220 |
|
| 221 |
+
# def retriever(state: MessagesState):
|
| 222 |
+
# """Retriever node"""
|
| 223 |
+
# messages = state.get("messages", [])
|
| 224 |
+
# if not messages:
|
| 225 |
+
# print("β οΈ No messages received in retriever node.")
|
| 226 |
+
# return {"messages": []}
|
| 227 |
|
| 228 |
+
# query = messages[0].content
|
| 229 |
+
# print(f"π Querying vector store with: {query}")
|
| 230 |
|
| 231 |
+
# try:
|
| 232 |
+
# similar_question = vector_store.similarity_search(query)
|
| 233 |
+
# print(f"β
Retrieved {len(similar_question)} similar questions.")
|
| 234 |
+
# except Exception as e:
|
| 235 |
+
# print(f"β Error during similarity_search: {e}")
|
| 236 |
+
# return {"messages": messages}
|
| 237 |
|
| 238 |
+
# if not similar_question:
|
| 239 |
+
# print("β οΈ No similar questions found.")
|
| 240 |
+
# return {"messages": messages}
|
| 241 |
|
| 242 |
+
# example_msg = HumanMessage(
|
| 243 |
+
# content=f"Here I provide a similar question and answer for reference:\n\n{similar_question[0].page_content}"
|
| 244 |
+
# )
|
| 245 |
|
| 246 |
+
# return {"messages": [sys_msg] + messages + [example_msg]}
|
| 247 |
|
| 248 |
|
| 249 |
builder = StateGraph(MessagesState)
|