diff --git a/sanguo_factor/batch_eval.py b/sanguo_factor/batch_eval.py index 456eab9..d522c94 100644 --- a/sanguo_factor/batch_eval.py +++ b/sanguo_factor/batch_eval.py @@ -116,7 +116,8 @@ def run_batch_eval( errors.append(name) buffer.append(row) done += 1 - if len(buffer) >= 20 or done == len(factor_names): + # 逐因子即存:容器重启风暴下单次最多丢在途 1 因子(buffer=20 曾丢 6 个) + if len(buffer) >= 1 or done == len(factor_names): eval_store.save_results(eval_db, run_id, buffer) buffer = [] if progress_cb: