Update app.py

app.py

@@ -15,6 +15,10 @@ import leximind_prompts
 # --- Together AI SDK ---
 from together import Together
 
+# --- eventlet monkey patch (Gunicorn + SocketIO 필수!) ---
+import eventlet
+eventlet.monkey_patch()
+
 # --- Flask & SocketIO 설정 ---
 app = Flask(__name__)
 socketio = SocketIO(app, cors_allowed_origins="*", async_mode='eventlet')
@@ -42,11 +46,10 @@ lexi_prompts = leximind_prompts.PromptLibrary()
 # --- RAG 객체 ---
 region_rag_objects = {}
 
-# --- Together AI 클라이언트 (Hugging Face Secrets에서 API 키 가져오기) ---
+# --- Together AI 클라이언트 ---
 TOGETHER_API_KEY = os.getenv("TOGETHER_API_KEY")
 if not TOGETHER_API_KEY:
     raise EnvironmentError("TOGETHER_API_KEY가 설정되지 않았습니다. Hugging Face Secrets에 추가하세요.")
-
 client = Together(api_key=TOGETHER_API_KEY)
 
 # --- RAG 로딩 ---
@@ -118,7 +121,8 @@ def get_reg_list():
     all_reg_list_part = []
     for region in selected_regions:
         rag = region_rag_objects.get(region)
-        if not rag: continue
+        if not rag:
+            continue
         try:
             conn = rag["sqlite_conn"]
             parts = reg_embedding_system.get_unique_metadata_values(conn, "regulation_part")
@@ -190,7 +194,8 @@ def search_DB_from_multiple_regions(query, selected_regions, region_rag_objects)
     combined_results = []
     for region in selected_regions:
         rag = region_rag_objects.get(region)
-        if not rag: continue
+        if not rag:
+            continue
 
         retriever = rag["ensemble_retriever"]
         vectorstore = rag["vectorstore"]
@@ -235,17 +240,14 @@ def RegAI(query, Rag_Results, ResultFile_FolderAddress):
 
 # --- 실행 ---
 if __name__ == '__main__':
-    # 로컬 개발용 (flask run 또는 python app.py)
+    # 로컬 개발용
     threading.Thread(target=load_rag_objects, daemon=True).start()
     time.sleep(2)
     socketio.emit('message', {'message': '데이터 로딩 시작...'})
     socketio.run(app, host='0.0.0.0', port=7860, debug=False)
 else:
-    # Gunicorn으로 실행될 때는 백그라운드 로딩만 시작
-    # (Gunicorn 워커가 시작된 후 로딩 시작되도록)
+    # Gunicorn용: 워커 시작 후 로딩
     import atexit
     loading_thread = threading.Thread(target=load_rag_objects, daemon=True)
     loading_thread.start()
-    
-    # 서버 종료 시 정리
     atexit.register(cleanup_connections)