From 209a853040bfadb1348507882f3841536e6254c5 Mon Sep 17 00:00:00 2001
From: Liang Ding <d@b3log.org>
Date: Tue, 7 Feb 2023 10:11:38 +0800
Subject: [PATCH] =?UTF-8?q?:art:=20=E6=95=B0=E6=8D=AE=E5=BA=93=E4=BA=8B?=
 =?UTF-8?q?=E5=8A=A1=E9=98=9F=E5=88=97=E6=89=A7=E8=A1=8C=E6=8A=A5=E9=94=99?=
 =?UTF-8?q?=E5=9B=9E=E6=BB=9A=E9=87=8A=E6=94=BE=E8=BF=9E=E6=8E=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 kernel/sql/queue.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/kernel/sql/queue.go b/kernel/sql/queue.go
index 8ab363c01..25447d197 100644
--- a/kernel/sql/queue.go
+++ b/kernel/sql/queue.go
@@ -118,6 +118,7 @@ func FlushQueue() {
 		context["current"] = i
 		context["total"] = total
 		if err = execOp(op, tx, context); nil != err {
+			tx.Rollback()
 			logging.LogErrorf("queue operation failed: %s", err)
 			return
 		}