diff --git a/deploy/profile-scripts/promote_candidates.py b/deploy/profile-scripts/promote_candidates.py index 42daa66e..b2e63d51 100644 --- a/deploy/profile-scripts/promote_candidates.py +++ b/deploy/profile-scripts/promote_candidates.py @@ -182,6 +182,7 @@ def main(): # 数据异常:先重评(LLM算正确区间),成功则用正确区间,失败则跳过 print(f" ⚠️ {code} {name} 买入区{el}~{eh} 偏离现价{_dev:.0f}%(数据异常),先重评校准...", flush=True) try: + conn.commit() # 2026-08-25 放锁:LLM子进程60-100s,持写锁等=全库撞锁(开盘连环撞锁主嫌疑) _r = subprocess.run(["/home/hmo/MoFin/venv/bin/python", "/home/hmo/MoFin/deploy/profile-scripts/per_stock_reassess.py", code], capture_output=True, text=True, timeout=REASSESS_TIMEOUT) @@ -270,6 +271,7 @@ def main(): if newly_added: try: import subprocess as _sp + conn.commit() # 2026-08-25 放锁:LLM子进程期间不持写锁 r = _sp.run(["python3", "/home/hmo/MoFin/deploy/profile-scripts/per_stock_reassess.py", code], capture_output=True, text=True, timeout=REASSESS_TIMEOUT) if r.returncode == 0: