Spaces:
Runtime error
Runtime error
Update agent.py
Browse files
agent.py
CHANGED
|
@@ -168,42 +168,4 @@ sup = create_client(os.getenv("SUPABASE_URL"), os.getenv("SUPABASE_SERVICE_ROLE_
|
|
| 168 |
vector_store = SupabaseVectorStore(
|
| 169 |
client=sup, embedding=emb,
|
| 170 |
table_name=os.getenv("VECTORTABLE_NAME", "documents2"),
|
| 171 |
-
query_name=os.getenv("VECTOR_QUERY_NAME",
|
| 172 |
-
)
|
| 173 |
-
|
| 174 |
-
# build_graph always uses OpenAI
|
| 175 |
-
def build_graph():
|
| 176 |
-
llm = ChatOpenAI(
|
| 177 |
-
model=os.getenv("OPENAI_MODEL", "gpt-3.5-turbo"),
|
| 178 |
-
temperature=0,
|
| 179 |
-
openai_api_key=os.getenv("OPENAI_API_KEY")
|
| 180 |
-
)
|
| 181 |
-
llm_with_tools = llm.bind_tools(tools)
|
| 182 |
-
|
| 183 |
-
def retriever(state: MessagesState):
|
| 184 |
-
query = state["messages"][0].content
|
| 185 |
-
hits = vector_store.similarity_search(query, k=1)
|
| 186 |
-
if hits:
|
| 187 |
-
return {"messages": [sys_msg, HumanMessage(content=hits[0].page_content)]}
|
| 188 |
-
return {"messages": [sys_msg] + state["messages"]}
|
| 189 |
-
|
| 190 |
-
def assistant(state: MessagesState):
|
| 191 |
-
resp = llm_with_tools.invoke(state["messages"])
|
| 192 |
-
return {"messages": [resp]}
|
| 193 |
-
|
| 194 |
-
builder = StateGraph(MessagesState)
|
| 195 |
-
builder.add_node("retriever", retriever)
|
| 196 |
-
builder.add_node("assistant", assistant)
|
| 197 |
-
builder.add_node("tools", ToolNode(tools))
|
| 198 |
-
builder.add_edge(START, "retriever")
|
| 199 |
-
builder.add_edge("retriever", "assistant")
|
| 200 |
-
builder.add_conditional_edges("assistant", tools_condition)
|
| 201 |
-
builder.add_edge("tools", "assistant")
|
| 202 |
-
return builder.compile()
|
| 203 |
-
|
| 204 |
-
# optional test
|
| 205 |
-
if __name__ == "__main__":
|
| 206 |
-
graph = build_graph()
|
| 207 |
-
msgs = graph.invoke({"messages": [HumanMessage(content="Hello world")]})
|
| 208 |
-
for m in msgs["messages"]:
|
| 209 |
-
print(m.content)
|
|
|
|
| 168 |
vector_store = SupabaseVectorStore(
|
| 169 |
client=sup, embedding=emb,
|
| 170 |
table_name=os.getenv("VECTORTABLE_NAME", "documents2"),
|
| 171 |
+
query_name=os.getenv("VECTOR_QUERY_NAME","match_documents_langchain")
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|