v0.0.7

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)

app/services/webhook.py

@@ -29,3 +29,25 @@ async def notify_be(
         resp = await client.post(be_url, json=payload, headers=headers)
         resp.raise_for_status()
     logger.info("[Webhook] 전송 완료: %s", ai_job_id)
+
+
+async def notify_be_roadmap(
+    ai_job_id: str,
+    result: list | None = None,
+    error_message: str | None = None,
+) -> None:
+    settings = get_settings()
+    status = "DONE" if result is not None else "ERROR"
+    payload = {
+        "ai_job_id":     ai_job_id,
+        "status":        status,
+        "result":        result,
+        "error_message": error_message,
+    }
+    be_url  = f"{settings.be_base_url}/api/v1/ai/roadmap/complete"
+    headers = {"X-INTERNAL-API-KEY": settings.passfolio_internal_api_key}
+    logger.info("[Webhook] POST %s | status=%s | job=%s", be_url, status, ai_job_id)
+    async with httpx.AsyncClient(timeout=10.0) as client:
+        resp = await client.post(be_url, json=payload, headers=headers)
+        resp.raise_for_status()
+    logger.info("[Webhook] 로드맵 콜백 완료: %s", ai_job_id)