 lhl
|
6a54580ca4
|
feat(orchestrator): DataGate 机制化 + 任务级持久化（T14/T16 架构审查整改）
- T14 (OV5): 新建 src/genesis/orchestrator/datagate.py
- DataGate.load(source, selector) 机制化：子集加载 + 规模保护（超 500 行
无 selector 拒绝全量，1000 行 Excel 防上下文爆炸）+ token 预算（8000，
复用 CJK 保守估算）+ 未知表容错
- agent-runtime §4.2 原则→机制说明
- T16 (OV7): 新建 src/genesis/orchestrator/task_queue.py
- TaskQueue ABC + PersistentTaskQueue（SQLite 落盘）
- enqueue/poll/update_status/get/cancel/recover/close
- 幂等去重（§5.3 缓存结果）+ recover 将 running→failed、pending 保留
- api-design §5.2/5.3、agent-runtime §3.5/3.6、design §8.4.1 同步
- 新增 test_datagate.py（8 用例）+ test_task_queue.py（11 用例）
- TDD: RED（模块缺失）→ GREEN（聚焦 16 passed）→ 全量 218 passed / 100.00%（1140 stmts/278 br）
|
2026-08-12 15:43:10 +08:00 |
|