Update main.py

main.py

@@ -640,13 +640,12 @@ async def consume_loop():
             # ✅ threadpool에서 호출될 progress 콜백
             def progress_cb(percent: int, stage: str, message: str):
                 # threadpool(다른 스레드) -> 현재 이벤트루프에서 코루틴 실행
-                fut = asyncio.run_coroutine_threadsafe(
+                try:
+                    asyncio.run_coroutine_threadsafe(
                     produce_progress(analysis_id, user_id, percent, stage, message),
                     loop
-                )
-                # (선택) progress 전송 실패 로그 보고 싶으면:
-                try:
-                    fut.result(timeout=2)
+                    )
+                
                 except Exception as e:
                     logger.warning(f"[KAFKA] progress send failed: {e}")