Merge branch 'dev-xym-update' of algorithm/RAG into master

data_handle.py

@@ -0,0 +1,5 @@
+from utils.keywords_utils import KeywordSummaryTask
+
+if __name__ == '__main__':
+    keyword_summary_task = KeywordSummaryTask()
+    keyword_summary_task.process_texts_concurrently()

main.py

@@ -50,10 +50,5 @@ async def lifespan(app: FastAPI):
 
 if __name__ == "__main__":
     import uvicorn
-
     os.environ['RAG_ENV'] = 'prod'
-    keyword_summary_task = KeywordSummaryTask()
-
-    # 启动单独的线程来执行 process_texts_concurrently 方法
-    threading.Thread(target=keyword_summary_task.process_texts_concurrently, daemon=True).start()
     uvicorn.run(app, host="0.0.0.0", port=5000)