wt002 commited on
Commit
4a5b7c8
·
verified ·
1 Parent(s): 01cc5e8

Update agent.py

Browse files
Files changed (1) hide show
  1. agent.py +19 -9
agent.py CHANGED
@@ -286,17 +286,27 @@ def build_graph(provider: str = "google"):
286
  return {"messages": [llm_with_tools.invoke(state["messages"])]}
287
 
288
  def retriever(state: MessagesState):
289
- """Retriever node"""
290
- similar_question = vector_store.similarity_search(state["messages"][0].content)
291
 
292
- if not similar_question:
293
- example_msg = HumanMessage(content="No similar question found.")
 
 
 
 
 
 
 
 
294
  else:
295
- example_msg = HumanMessage(
296
- content=f"Here I provide a similar question and answer for reference:\n\n{similar_question[0].page_content}",
297
- )
298
-
299
- return {"messages": [sys_msg] + state["messages"] + [example_msg]}
 
 
300
 
301
 
302
 
 
286
  return {"messages": [llm_with_tools.invoke(state["messages"])]}
287
 
288
  def retriever(state: MessagesState):
289
+ user_query = state["messages"][0].content
290
+ similar_docs = vector_store.similarity_search(user_query)
291
 
292
+ if not similar_docs:
293
+ print("No similar docs found in FAISS. Using wiki_search.")
294
+ wiki_result = wiki_search.invoke(user_query)
295
+ return {
296
+ "messages": [
297
+ sys_msg,
298
+ state["messages"][0],
299
+ HumanMessage(content=f"Using Wikipedia search:\n\n{wiki_result['wiki_results']}")
300
+ ]
301
+ }
302
  else:
303
+ return {
304
+ "messages": [
305
+ sys_msg,
306
+ state["messages"][0],
307
+ HumanMessage(content=f"Reference question:\n\n{similar_docs[0].page_content}")
308
+ ]
309
+ }
310
 
311
 
312