remove unused code
Browse files
climateqa/engine/chains/retrieve_documents.py
CHANGED
@@ -258,7 +258,6 @@ async def retrieve_documents(state,config, vectorstore,reranker,llm,rerank_by_qu
|
|
258 |
# Add to the list of docs
|
259 |
docs.extend(docs_question)
|
260 |
related_content.extend(images_question)
|
261 |
-
# related_content=[]
|
262 |
new_state = {"documents":docs, "related_contents": related_content,"remaining_questions":remaining_questions}
|
263 |
return new_state
|
264 |
|
|
|
258 |
# Add to the list of docs
|
259 |
docs.extend(docs_question)
|
260 |
related_content.extend(images_question)
|
|
|
261 |
new_state = {"documents":docs, "related_contents": related_content,"remaining_questions":remaining_questions}
|
262 |
return new_state
|
263 |
|
climateqa/engine/graph.py
CHANGED
@@ -43,7 +43,6 @@ class GraphState(TypedDict):
|
|
43 |
documents: List[Document]
|
44 |
related_contents : Dict[str,Document]
|
45 |
recommended_content : List[Document]
|
46 |
-
# graphs_returned: Dict[str,str]
|
47 |
|
48 |
def search(state): #TODO
|
49 |
return state
|
@@ -108,16 +107,10 @@ def make_graph_agent(llm, vectorstore_ipcc, vectorstore_graphs, reranker, thresh
|
|
108 |
workflow.add_node("answer_search", answer_search)
|
109 |
workflow.add_node("transform_query", transform_query)
|
110 |
workflow.add_node("translate_query", translate_query)
|
111 |
-
# workflow.add_node("transform_query_ai", transform_query)
|
112 |
-
# workflow.add_node("translate_query_ai", translate_query)
|
113 |
workflow.add_node("answer_chitchat", answer_chitchat)
|
114 |
workflow.add_node("chitchat_categorize_intent", chitchat_categorize_intent)
|
115 |
-
# workflow.add_node("answer_ai_impact", answer_ai_impact)
|
116 |
workflow.add_node("retrieve_graphs", retrieve_graphs)
|
117 |
workflow.add_node("retrieve_graphs_chitchat", retrieve_graphs)
|
118 |
-
# workflow.add_node("retrieve_graphs_ai", retrieve_graphs)
|
119 |
-
# workflow.add_node("answer_rag_graph", answer_rag_graph)
|
120 |
-
# workflow.add_node("answer_rag_graph_ai", answer_rag_graph)
|
121 |
workflow.add_node("retrieve_documents", retrieve_documents)
|
122 |
workflow.add_node("answer_rag", answer_rag)
|
123 |
workflow.add_node("answer_rag_no_docs", answer_rag_no_docs)
|
@@ -161,27 +154,14 @@ def make_graph_agent(llm, vectorstore_ipcc, vectorstore_graphs, reranker, thresh
|
|
161 |
)
|
162 |
|
163 |
# Define the edges
|
164 |
-
# workflow.add_edge("set_defaults", "categorize_intent")
|
165 |
workflow.add_edge("translate_query", "transform_query")
|
166 |
-
# workflow.add_edge("transform_query", "retrieve_graphs")
|
167 |
workflow.add_edge("transform_query", "retrieve_documents")
|
168 |
|
169 |
-
# workflow.add_edge("retrieve_graphs", "answer_rag_graph")
|
170 |
workflow.add_edge("retrieve_graphs", END)
|
171 |
-
# workflow.add_edge("retrieve_graphs", "retrieve_documents")
|
172 |
-
# workflow.add_edge("answer_rag_graph", "retrieve_documents")
|
173 |
workflow.add_edge("answer_rag", END)
|
174 |
workflow.add_edge("answer_rag_no_docs", END)
|
175 |
workflow.add_edge("answer_chitchat", "chitchat_categorize_intent")
|
176 |
-
|
177 |
-
# workflow.add_edge("answer_ai_impact", END)
|
178 |
-
# workflow.add_edge("retrieve_graphs_chitchat", END)
|
179 |
-
# workflow.add_edge("answer_ai_impact", "translate_query_ai")
|
180 |
-
# workflow.add_edge("translate_query_ai", "transform_query_ai")
|
181 |
-
# workflow.add_edge("transform_query_ai", "retrieve_graphs_ai")
|
182 |
-
# workflow.add_edge("retrieve_graphs_ai", "answer_rag_graph_ai")
|
183 |
-
# workflow.add_edge("answer_rag_graph_ai", END)
|
184 |
-
# workflow.add_edge("retrieve_graphs_ai", END)
|
185 |
|
186 |
# Compile
|
187 |
app = workflow.compile()
|
|
|
43 |
documents: List[Document]
|
44 |
related_contents : Dict[str,Document]
|
45 |
recommended_content : List[Document]
|
|
|
46 |
|
47 |
def search(state): #TODO
|
48 |
return state
|
|
|
107 |
workflow.add_node("answer_search", answer_search)
|
108 |
workflow.add_node("transform_query", transform_query)
|
109 |
workflow.add_node("translate_query", translate_query)
|
|
|
|
|
110 |
workflow.add_node("answer_chitchat", answer_chitchat)
|
111 |
workflow.add_node("chitchat_categorize_intent", chitchat_categorize_intent)
|
|
|
112 |
workflow.add_node("retrieve_graphs", retrieve_graphs)
|
113 |
workflow.add_node("retrieve_graphs_chitchat", retrieve_graphs)
|
|
|
|
|
|
|
114 |
workflow.add_node("retrieve_documents", retrieve_documents)
|
115 |
workflow.add_node("answer_rag", answer_rag)
|
116 |
workflow.add_node("answer_rag_no_docs", answer_rag_no_docs)
|
|
|
154 |
)
|
155 |
|
156 |
# Define the edges
|
|
|
157 |
workflow.add_edge("translate_query", "transform_query")
|
|
|
158 |
workflow.add_edge("transform_query", "retrieve_documents")
|
159 |
|
|
|
160 |
workflow.add_edge("retrieve_graphs", END)
|
|
|
|
|
161 |
workflow.add_edge("answer_rag", END)
|
162 |
workflow.add_edge("answer_rag_no_docs", END)
|
163 |
workflow.add_edge("answer_chitchat", "chitchat_categorize_intent")
|
164 |
+
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
165 |
|
166 |
# Compile
|
167 |
app = workflow.compile()
|