Update app.py

app.py

@@ -638,21 +638,44 @@ def create_optimized_gradio_interface():
     # 시스템 초기화
     system = SpeedOptimizedMultiAgentSystem()
     
-    async def process_query_optimized(
+    def process_query_optimized(
         message: str,
         history: List[Dict],
         use_search: bool,
         show_agent_thoughts: bool,
         search_count: int
     ):
-        """최적화된 쿼리 처리"""
+        """최적화된 쿼리 처리 - 동기 버전"""
         
         if not message:
             yield history, "", ""
             return
         
+        # 비동기 함수를 동기적으로 실행
         try:
-            # 검색 수행 (비동기)
+            import nest_asyncio
+            nest_asyncio.apply()
+        except ImportError:
+            pass  # nest_asyncio가 없어도 진행
+        
+        def run_async_function(coro):
+            """비동기 함수를 동기적으로 실행하는 헬퍼"""
+            try:
+                loop = asyncio.get_event_loop()
+                if loop.is_running():
+                    # 이미 실행 중인 루프가 있으면 새 스레드에서 실행
+                    import concurrent.futures
+                    with concurrent.futures.ThreadPoolExecutor() as executor:
+                        future = executor.submit(asyncio.run, coro)
+                        return future.result()
+                else:
+                    return loop.run_until_complete(coro)
+            except RuntimeError:
+                # 루프가 없으면 새로 생성
+                return asyncio.run(coro)
+        
+        try:
+            # 검색 수행 (동기화)
             search_results = []
             search_display = ""
             
@@ -664,8 +687,10 @@ def create_optimized_gradio_interface():
                 ]
                 yield history_with_message, "", ""
                 
-                # 비동기 검색
-                search_results = await system.search.search_async(message, count=search_count)
+                # 비동기 검색을 동기적으로 실행
+                search_results = run_async_function(
+                    system.search.search_async(message, count=search_count)
+                )
                 
                 if search_results:
                     search_display = "## 📚 참고 자료\n\n"
@@ -676,12 +701,22 @@ def create_optimized_gradio_interface():
             # 사용자 메시지 추가
             current_history = history + [{"role": "user", "content": message}]
             
-            # 병렬 처리 실행
-            async for response, thoughts in system.parallel_process_agents(
-                query=message,
-                search_results=search_results,
-                show_progress=show_agent_thoughts
-            ):
+            # 병렬 처리 실행을 동기적으로 수집
+            async def collect_responses():
+                responses = []
+                async for response, thoughts in system.parallel_process_agents(
+                    query=message,
+                    search_results=search_results,
+                    show_progress=show_agent_thoughts
+                ):
+                    responses.append((response, thoughts))
+                return responses
+            
+            # 모든 응답 수집
+            all_responses = run_async_function(collect_responses())
+            
+            # 수집된 응답을 yield
+            for response, thoughts in all_responses:
                 updated_history = current_history + [
                     {"role": "assistant", "content": response}
                 ]
@@ -790,22 +825,8 @@ def create_optimized_gradio_interface():
         )
         
         # 이벤트 바인딩
-        def process_wrapper(message, history, use_search, show_thoughts, search_count):
-            """동기 래퍼 for Gradio"""
-            loop = asyncio.new_event_loop()
-            asyncio.set_event_loop(loop)
-            
-            async def run():
-                async for result in process_query_optimized(
-                    message, history, use_search, show_thoughts, search_count
-                ):
-                    yield result
-            
-            for result in loop.run_until_complete(run()):
-                yield result
-        
         submit.click(
-            process_wrapper,
+            process_query_optimized,
             inputs=[msg, chatbot, use_search, show_agent_thoughts, search_count],
             outputs=[chatbot, agent_thoughts, search_sources]
         ).then(
@@ -815,7 +836,7 @@ def create_optimized_gradio_interface():
         )
         
         msg.submit(
-            process_wrapper,
+            process_query_optimized,
             inputs=[msg, chatbot, use_search, show_agent_thoughts, search_count],
             outputs=[chatbot, agent_thoughts, search_sources]
         ).then(