Update app.py

app.py

@@ -1,16 +1,24 @@
-from graph.rag_pipeline_graph import get_rag_pipeline_graph
-from type.state_schema import RAGState
-
-if __name__ == "__main__":
-    graph = get_rag_pipeline_graph()
-
-    input_data = RAGState(
-        query="유용한 재무정보의 질적특성에 관한 설명",
-        top_k=5
-    )
-
-    final_state = graph.invoke(input_data)
-    # print("\n🧠 최종 응답:", final_state.final_response)
-    # print("\n🧠 최종 응답:", final_state["final_response"])
-    print("\n🧠 최종 응답:", final_state.get("final_response", "[응답 없음]"))
-
+from fastapi import FastAPI
+
+from graph.rag_pipeline_graph import get_rag_pipeline_graph
+from type.state_schema import RAGState
+
+
+api = FastAPI()
+
+# if __name__ == "__main__":
+@app.get("/")
+def rag_pipeline_graph():
+    graph = get_rag_pipeline_graph()
+
+    input_data = RAGState(
+        query="유용한 재무정보의 질적특성에 관한 설명",
+        top_k=5
+    )
+
+    final_state = graph.invoke(input_data)
+    # print("\n🧠 최종 응답:", final_state.final_response)
+    # print("\n🧠 최종 응답:", final_state["final_response"])
+    # print("\n🧠 최종 응답:", final_state.get("final_response", "[응답 없음]"))
+    return  final_state.get("final_response", "[응답 없음]")
+