Signed-off-by: Daniel <845765@qq.com>
This commit is contained in:
Daniel 2026-01-17 21:15:36 +08:00
parent f9aa99bff8
commit 6c2545e457
No known key found for this signature in database
GPG key ID: 86211BA83DF03017

View file

@ -163,6 +163,7 @@ func FlushQueue() {
context["total"] = groupOpsTotal[op.action]
if err = execOp(op, tx, context); err != nil {
tx.Rollback()
closeTxPreparedStmts(tx)
logging.LogErrorf("queue operation [%s] failed: %s", op.action, err)
continue
}