fix(nas): bs_5m --limit冒烟禁推chunk state——2026-08-22 09:17独立容器冒烟(--limit 3)实锤把state从2025-08-20多推到2025-02-18,[2025-02-18,2025-08-20]半年片被3只股'代表'5548只跳过(当日上午巡检发现:state mtime 09:17恰=冒烟时刻,窗口算术反推+代码链路三证合一);根因=limit_reached只盯DAILY_LIMIT配额防线(bs_5m_eod.py:220),--limit预截断列表后循环'正常跑完'lr=False,286行推进守卫畅通;修=chunk state推进闸门加not args.limit;+测试钉死冒烟不落state(Red复现→Green);NAS侧state两步手动补回(今晚23:5x→2025-08-20补跳过片,明晨完工后→2024-08-19跳过重跑);venv310全套177绿 [nas]
This commit is contained in:
@@ -283,8 +283,10 @@ def _run(args):
|
||||
log.info("[CHUNK] %s~%s ok=%d empty=%d failed=%d rows=%d",
|
||||
chunk[0], chunk[1], cs["ok"], cs["empty"], cs["failed"],
|
||||
cs["db_rows"])
|
||||
if not lr and swept[0] < DAILY_LIMIT:
|
||||
# 整片扫完才推进 state; 没扫完次日重拉同片(OR REPLACE 幂等续跑)
|
||||
if not lr and swept[0] < DAILY_LIMIT and not args.limit:
|
||||
# 整片扫完才推进 state; 没扫完次日重拉同片(OR REPLACE 幂等续跑);
|
||||
# --limit 冒烟只拉 N 只 ≠ 整片完成, 同禁推进(2026-08-22 冒烟
|
||||
# 实锤多推一片跳过半年窗口)
|
||||
save_chunk_state({"next_end": chunk[0]})
|
||||
# 每日增量照跑(回灌期也跑, 近端 7 天始终新鲜)
|
||||
istats, lr = _sweep(conn, stocks, inc_start, inc_end, swept, "inc")
|
||||
|
||||
Reference in New Issue
Block a user