29349dc7ee
承 C1 链图（build_chain_graph），落地多章工作流链的 apps/api 壳：
- 3 端点 routers/chain.py：POST .../chains/{key}/run→202 ChainRunAccepted；
POST .../chains/runs/{job_id}/resume→202；GET /jobs/{id} 复用。校验：
count 1..50→422、未知 chain_key→404、resume 非 awaiting→409、无凭据→503。
- schemas/chain.py：ChainRunRequest/ChainRunAccepted/ChainResumeRequest
（ConflictDecision 复用 schemas/projects）。
- services/chain_runner.py：run_chain_job 仿 run_job 壳自建独立 session 驱动链图
（set_running→ainvoke→据 __interrupt__ 置 awaiting_input/done/failed）；
build_accept_op 在 apps/api 装配验收事务闭包注入图节点（守 #3/#4）；
token 不入 result/日志。
- services/chain_deps.py：get_checkpointer_factory（运行时 AsyncPostgresSaver
上下文 / 测试 MemorySaver）。
- 零迁移（设计 §7）：复用 jobs，新增 status="awaiting_input" + JobRepo.set_awaiting，
awaiting 章经 result.awaiting_chapter；新错误码 ErrorCode.CONFLICT(409)。
- project_deps：build_chain_gateway/get_chain_gateway（按请求 tier writer/analyst/light
分派——单档网关恒返该档会错路由 review/digest）+ get_digest_gateway_builder。
单测 apps/api/tests/test_chain.py 12 用例（mock 网关 + MemorySaver + fake session/
accept_op，无 DB/无网络/无真 LLM）：run/resume→202、未知 key 404、count 越界 422、
resume 非 awaiting 409、run_chain_job 无冲突→done、冲突→awaiting→resume→done、
错误脱敏、accept_op 冲突缺判→CONFLICT_UNRESOLVED。
门禁绿：ruff/format 干净 · mypy 193 Success · alembic 无漂移 · pytest 600 passed。
守不变量 #1/#3/#4/#5/#9。唯一新增 DDL（langgraph 检查点表）= C3 迁移。
Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
47 lines
1.2 KiB
Python
47 lines
1.2 KiB
Python
"""统一错误码与领域异常（ARCH §7.1）。"""
|
||
|
||
from __future__ import annotations
|
||
|
||
from enum import StrEnum
|
||
|
||
|
||
class ErrorCode(StrEnum):
|
||
NOT_FOUND = "NOT_FOUND"
|
||
VALIDATION = "VALIDATION"
|
||
CONFLICT = "CONFLICT" # 资源状态冲突（如对非 awaiting 链 job 续跑）
|
||
CONFLICT_UNRESOLVED = "CONFLICT_UNRESOLVED" # 未决冲突禁验收
|
||
LLM_UNAVAILABLE = "LLM_UNAVAILABLE" # 回退耗尽
|
||
RATE_LIMITED = "RATE_LIMITED"
|
||
INTERNAL = "INTERNAL"
|
||
|
||
|
||
# 错误码 -> HTTP 状态
|
||
HTTP_STATUS: dict[ErrorCode, int] = {
|
||
ErrorCode.NOT_FOUND: 404,
|
||
ErrorCode.VALIDATION: 422,
|
||
ErrorCode.CONFLICT: 409,
|
||
ErrorCode.CONFLICT_UNRESOLVED: 409,
|
||
ErrorCode.LLM_UNAVAILABLE: 503,
|
||
ErrorCode.RATE_LIMITED: 429,
|
||
ErrorCode.INTERNAL: 500,
|
||
}
|
||
|
||
|
||
class AppError(Exception):
|
||
"""领域异常：在边界处映射为统一错误信封。"""
|
||
|
||
def __init__(
|
||
self,
|
||
code: ErrorCode,
|
||
message: str,
|
||
details: dict[str, object] | None = None,
|
||
) -> None:
|
||
super().__init__(message)
|
||
self.code = code
|
||
self.message = message
|
||
self.details = details or {}
|
||
|
||
@property
|
||
def http_status(self) -> int:
|
||
return HTTP_STATUS.get(self.code, 500)
|