diff --git a/DB.py b/DB.py index 963bb61..470cee6 100644 --- a/DB.py +++ b/DB.py @@ -534,7 +534,7 @@ class DBSA: cls._buf_vid.append(vid_row) cls._buf_payload.append(data) # 保存原始 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 flush_reason = "" diff --git a/main.py b/main.py index 79a10c5..3ff4fa7 100644 --- a/main.py +++ b/main.py @@ -194,7 +194,6 @@ def integrate_data_parallel(): "level": kitem["level"], }) DBSA.flush() - exit() if rollback[0]: db.rollback_l0(rollback[0]) if rollback[1]: