Files

15 lines
1.2 KiB
Markdown
Raw Permalink Normal View History

2026-08-11 13:32:21 +08:00
# 实施计划
1. 先补失败测试:worker 上限、完成顺序、单股隔离、共享频控和集合覆盖率。
2. 在 domain/application 定义 `SyncItemOutcome`,把 `_process_bar` 重构为无共享可变状态的返回式流程。
3. 在 Tushare adapter 增加 coordinated client/request coordinator,设置 SDK `retry_count=1`,补错误分类测试。
4. 把 `market_data_max_workers` 默认改为 8 并完成正整数校验;CLI 注入同步用例。
5. 引入 Psycopg connection pool,保持 advisory lock 与单股事务的独立连接语义。
6. 增加 `record_items` 和 `count_valid_stocks`,删除编排中的逐股覆盖率查询。
7. 用固定线程池执行 bar futures,主线程聚合、分批审计和记录有界进度。
8. 更新 `.env.example`、Compose 参数传递、市场同步文档和依赖锁文件。
9. 运行 `uv lock --check`、Ruff format/check、Pyright、pytest;有测试数据库时运行 market_data integration tests。
10. 运行 5002 fake 股票无网络基准,记录最大并发、耗时和 repository 调用次数。
回滚点:连接池改造和并发编排分别保持独立变更;出现供应商问题时配置 worker=1。