diff --git a/app/workers/classify_worker.py b/app/workers/classify_worker.py index bb28943..f8be607 100644 --- a/app/workers/classify_worker.py +++ b/app/workers/classify_worker.py @@ -479,8 +479,11 @@ async def _apply_triage_result( # enqueue deep_summary if escalate: try: + # PR-A envelope.ValidFromStage 기준 — P3a 에서 에스컬레이션은 'summarize_short'. + # 내부 task 이름 'summary_triage' 는 analyze_events.prompt_version 에만 쓰고, + # envelope.from_stage 는 PR-A 가 정의한 enum 값을 따른다. envelope = EscalationEnvelope( - from_stage="summary_triage", + from_stage="summarize_short", escalation_reasons=tuple([escalation_reason] if escalation_reason else []), risk_flags=tuple(routing_decision.risk_flags) if routing_decision else tuple(triage_out.risk_flags),