diff --git a/deploy/profile-scripts/promote_candidates.py b/deploy/profile-scripts/promote_candidates.py index 9de0ca9a..f1bad2f9 100644 --- a/deploy/profile-scripts/promote_candidates.py +++ b/deploy/profile-scripts/promote_candidates.py @@ -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