writer-work-flow

kai/writer-work-flow

Fork 0

Commit Graph

Author	SHA1	Message	Date
Yaojia Wang	b5002a9864	fix(chain): checkpointer 连接串剥离 SQLAlchemy 驱动后缀多章链 job 一发起即 failed（exc_type=ProgrammingError）。根因：runtime checkpointer 工厂把 settings 的 sync URL `postgresql+psycopg://…` 原样喂给 `AsyncPostgresSaver.from_conn_string`，psycopg 不识别 `+psycopg` 方言段 → `ProgrammingError: missing "=" …`，链在打开 saver 时即崩。 E2E 用 MemorySaver 覆盖 get_checkpointer_factory，从不走真 conn string，故此路径无回归保护、bug 未被测出（迁移 d3e4f5a6b7c8 里 `_psycopg_conn_string` 已正确剥离，runtime 缝漏了同款处理）。修复：chain_deps 加 `_libpq_conn_string()`，剥离 `+psycopg`/`+asyncpg` 还原为标准 libpq 串后再交 from_conn_string。+ 单测 test_chain_deps.py（3 参数化用例）。已直连真 pg 复验：saver.aget OK，ProgrammingError 消除。	2026-06-24 12:40:40 +02:00
Yaojia Wang	29349dc7ee	feat(api): C2 多章链服务+端点+schema+checkpointer 接线承 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>	2026-06-23 17:12:53 +02:00

Author

SHA1

Message

Date

Yaojia Wang

b5002a9864

fix(chain): checkpointer 连接串剥离 SQLAlchemy 驱动后缀

多章链 job 一发起即 failed（exc_type=ProgrammingError）。根因：runtime
checkpointer 工厂把 settings 的 sync URL `postgresql+psycopg://…` 原样喂给
`AsyncPostgresSaver.from_conn_string`，psycopg 不识别 `+psycopg` 方言段 →
`ProgrammingError: missing "=" …`，链在打开 saver 时即崩。

E2E 用 MemorySaver 覆盖 get_checkpointer_factory，从不走真 conn string，故此
路径无回归保护、bug 未被测出（迁移 d3e4f5a6b7c8 里 `_psycopg_conn_string` 已
正确剥离，runtime 缝漏了同款处理）。

修复：chain_deps 加 `_libpq_conn_string()`，剥离 `+psycopg`/`+asyncpg` 还原为
标准 libpq 串后再交 from_conn_string。+ 单测 test_chain_deps.py（3 参数化用例）。
已直连真 pg 复验：saver.aget OK，ProgrammingError 消除。

2026-06-24 12:40:40 +02:00

Yaojia Wang

29349dc7ee

feat(api): C2 多章链服务+端点+schema+checkpointer 接线

承 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>

2026-06-23 17:12:53 +02:00

2 Commits