fix: 移除不必要的统计回滚注释以清理代码

This commit is contained in:
晓丰 2025-06-01 17:03:59 +08:00
parent af948c48e6
commit 035aadb6d2
2 changed files with 1 additions and 2 deletions

2
DB.py
View File

@ -534,7 +534,7 @@ class DBSA:
cls._buf_vid.append(vid_row) cls._buf_vid.append(vid_row)
cls._buf_payload.append(data) # 保存原始 cls._buf_payload.append(data) # 保存原始
buf_len = len(cls._buf_vid) buf_len = len(cls._buf_vid)
logger.info(f"DB缓冲 -> xid={data['v_xid']}, level={data['level']}, buffer={buf_len}") # logger.info(f"DB缓冲 -> xid={data['v_xid']}, level={data['level']}, buffer={buf_len}")
need_flush = False need_flush = False
flush_reason = "" flush_reason = ""

View File

@ -194,7 +194,6 @@ def integrate_data_parallel():
"level": kitem["level"], "level": kitem["level"],
}) })
DBSA.flush() DBSA.flush()
exit()
if rollback[0]: if rollback[0]:
db.rollback_l0(rollback[0]) db.rollback_l0(rollback[0])
if rollback[1]: if rollback[1]: