Update main.py

main.py

@@ -680,7 +680,6 @@ async def consume_loop():
             except Exception as e:
                 logger.error(f"[KAFKA] analysis failed analysisId={analysis_id}: {repr(e)}", exc_info=True)
                 await produce_progress(analysis_id, user_id, 100, "ERROR", f"오류: {type(e).__name__}")
-                "에러 결과"로 반드시 보내기 (프론트 로딩 종료용)
                 if producer:
                     err_payload = {
                     "analysisId": analysis_id,
@@ -690,7 +689,7 @@ async def consume_loop():
                     "message": f"분석 실패: {type(e).__name__}",
                     "url": url,
                     }
-                }
+                    }
                     await producer.send_and_wait(
                         KAFKA_DONE_TOPIC,
                         key=analysis_id.encode("utf-8"),