fix(promote_candidates): DB锁自动重试(busy_timeout+指数退避5次)

2026-08-22 01:27:46 +08:00
parent 89ac3b688a
commit 8e9b280442
1 changed files with 2 additions and 2 deletions
@@ -77,7 +77,7 @@ def main():
            (code,)
        ).fetchone()
        if exists:
-            conn.execute("UPDATE candidates SET promoted=1 WHERE code=?", (code,))
+            _exec_retry(conn, "UPDATE candidates SET promoted=1 WHERE code=?", (code,))
            processed += 1
            continue
        
@@ -258,7 +258,7 @@ def main():
        """, (code, name, _price, el, eh, sl, tp, timing_signal, action, _rr, source_strategy, now, now))
        newly_added = cur.rowcount > 0
        
-        conn.execute("UPDATE candidates SET promoted=1 WHERE code=?", (code,))
+        _exec_retry(conn, "UPDATE candidates SET promoted=1 WHERE code=?", (code,))
        if newly_added:
            promoted += 1
            processed += 1