Update agent.py

agent.py

@@ -112,6 +112,8 @@ def arvix_search(query: str) -> str:
         ])
     return {"arvix_results": formatted_search_docs}
 
+
+
 # load the system prompt from the file
 with open("system_prompt.txt", "r", encoding="utf-8") as f:
     system_prompt = f.read()
@@ -120,16 +122,23 @@ with open("system_prompt.txt", "r", encoding="utf-8") as f:
 sys_msg = SystemMessage(content=system_prompt)
 
 # build a retriever
-embeddings = HuggingFaceEmbeddings(model_name="sentence-transformers/all-mpnet-base-v2") # dim=768
+embeddings = HuggingFaceEmbeddings(model_name="sentence-transformers/all-mpnet-base-v2") #  dim=768
 supabase: Client = create_client(
     os.environ.get("SUPABASE_URL"), 
     os.environ.get("SUPABASE_SERVICE_KEY"))
 vector_store = SupabaseVectorStore(
     client=supabase,
-    embedding=embeddings,
+    embedding= embeddings,
     table_name="documents",
     query_name="match_documents_langchain",
 )
+create_retriever_tool = create_retriever_tool(
+    retriever=vector_store.as_retriever(),
+    name="Question Search",
+    description="A tool to retrieve similar questions from a vector store.",
+)
+
+
 
 tools = [
     multiply,
@@ -151,7 +160,7 @@ def build_graph(provider: str = "groq"):
         llm = ChatGoogleGenerativeAI(model="gemini-2.0-flash", temperature=0)
     elif provider == "groq":
         # Groq https://console.groq.com/docs/models
-        llm = ChatGroq(model="llama-3.1-8b-instant", temperature=0)  # Updated model name
+        llm = ChatGroq(model="qwen-qwq-32b", temperature=0) # optional : qwen-qwq-32b gemma2-9b-it
     elif provider == "huggingface":
         # TODO: Add huggingface endpoint
         llm = ChatHuggingFace(
@@ -168,24 +177,14 @@ def build_graph(provider: str = "groq"):
     # Node
     def assistant(state: MessagesState):
         """Assistant node"""
-        # For debugging: Force a wiki_search call for the question
-        if "Mercedes Sosa" in state["messages"][-1].content:
-            wiki_results = wiki_search.invoke({"query": "Mercedes Sosa discography"})
-            state["messages"].append(HumanMessage(content=f"Wikipedia search results:\n{wiki_results['wiki_results']}"))
         return {"messages": [llm_with_tools.invoke(state["messages"])]}
     
     def retriever(state: MessagesState):
         """Retriever node"""
-        query = state["messages"][0].content
-        similar_questions = vector_store.similarity_search(query)
-        if similar_questions:
-            example_msg = HumanMessage(
-                content=f"Here I provide a similar question and answer for reference: \n\n{similar_questions[0].page_content}",
-            )
-        else:
-            example_msg = HumanMessage(
-                content="No similar questions found in the vector store."
-            )
+        similar_question = vector_store.similarity_search(state["messages"][0].content)
+        example_msg = HumanMessage(
+            content=f"Here I provide a similar question and answer for reference: \n\n{similar_question[0].page_content}",
+        )
         return {"messages": [sys_msg] + state["messages"] + [example_msg]}
 
     builder = StateGraph(MessagesState)
@@ -205,11 +204,11 @@ def build_graph(provider: str = "groq"):
 
 # test
 if __name__ == "__main__":
-    question = "How many studio albums were published by Mercedes Sosa between 2000 and 2009 (included)?"
+    question = "When was a picture of St. Thomas Aquinas first added to the Wikipedia page on the Principle of double effect?"
     # Build the graph
     graph = build_graph(provider="groq")
     # Run the graph
     messages = [HumanMessage(content=question)]
     messages = graph.invoke({"messages": messages})
     for m in messages["messages"]:
-        m.pretty_print()
+        m.pretty_print()