From 0adacac009c28d0bb6b7db85facee39111ad59bc Mon Sep 17 00:00:00 2001 From: Hooby Date: Thu, 4 Jun 2026 09:40:01 +0900 Subject: [PATCH] =?UTF-8?q?fix(roadmap):=20run=5Fassess=5Ftask=EA=B0=80=20?= =?UTF-8?q?notify=5Fbe=5Froadmap=EC=9D=84=20=ED=98=B8=EC=B6=9C=ED=95=98?= =?UTF-8?q?=EB=8F=84=EB=A1=9D=20=EC=97=B0=EA=B2=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit webhook.notify_be_roadmap(/roadmap/complete, result 포함)은 이미 추가돼 있었으나 run_assess_task가 여전히 공용 notify_be(/jobs/complete, result 없음·항상 ERROR)를 호출하고 있어 로드맵 결과가 BE로 전달되지 않았다. 연결만 수정: - import notify_be → notify_be_roadmap - finally: notify_be_roadmap(ai_job_id, result=results, error_message) 호출 (성공 시 result, 실패 시 None→ERROR) 공용 notify_be(pdf_pipeline)는 무변경. Co-Authored-By: Claude Opus 4.8 (1M context) --- app/services/roadmap_assess.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/app/services/roadmap_assess.py b/app/services/roadmap_assess.py index 2a37dc6..3eb0bed 100644 --- a/app/services/roadmap_assess.py +++ b/app/services/roadmap_assess.py @@ -11,7 +11,7 @@ from app.services.roadmap import rule_filter, llm_analyzer, market_tier, market_loader from app.services.roadmap_merger import run_merged from app.services._rag_utils import _fetch_code_analysis as _fetch_project -from app.services.webhook import notify_be +from app.services.webhook import notify_be_roadmap from app.jobs.store import JobStatus, update_job logger = logging.getLogger(__name__) @@ -197,7 +197,9 @@ def _run() -> list[dict[str, Any]]: logger.error("[로드맵] 평가 태스크 실패: %s", e) update_job(job_id, JobStatus.ERROR, message=error_message) finally: + # 로드맵은 PDF가 없으므로 공용 notify_be(/jobs/complete) 대신 result를 싣는 + # notify_be_roadmap(/roadmap/complete)으로 콜백한다(성공 시 result, 실패 시 None→ERROR). try: - await notify_be(ai_job_id=ai_job_id, output_pdf_url=None, error_message=error_message) + await notify_be_roadmap(ai_job_id=ai_job_id, result=results, error_message=error_message) except Exception as webhook_err: - logger.warning("[Webhook] 콜백 실패 (결과는 저장됨): %s", webhook_err) + logger.warning("[Webhook] 로드맵 콜백 실패 (결과는 저장됨): %s", webhook_err)