From e89e11c421976e30b77a85d12cc319e67a8fe099 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=88=98=E7=A5=A5=E8=B6=85?= <iwind.liu@gmail.com>
Date: Fri, 24 Feb 2023 15:36:18 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E4=BF=AE=E6=94=B9=E6=9C=8D?=
 =?UTF-8?q?=E5=8A=A1=E9=85=8D=E7=BD=AE=E6=97=B6=E5=90=8C=E6=AD=A5=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1=E8=A2=AB=E8=A6=86=E7=9B=96=E7=9A=84=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 internal/db/models/node_task_dao.go | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/internal/db/models/node_task_dao.go b/internal/db/models/node_task_dao.go
index d2862f2c..97c98c26 100644
--- a/internal/db/models/node_task_dao.go
+++ b/internal/db/models/node_task_dao.go
@@ -154,7 +154,8 @@ func (this *NodeTaskDAO) ExtractNodeClusterTask(tx *dbs.Tx, clusterId int64, use
 	_, err = this.Query(tx).
 		Attr("role", nodeconfigs.NodeRoleNode).
 		Attr("clusterId", clusterId).
-		Where("nodeId> 0").
+		Attr("serverId", serverId).
+		Gt("nodeId", 0).
 		Attr("type", taskType).
 		Delete()
 	if err != nil {