From e6b4fe6d880e4796e0f8a2a85b80fe07e756e7f6 Mon Sep 17 00:00:00 2001
From: "jieying.li" <jieying.li@northking.net>
Date: Mon, 25 Nov 2024 20:34:16 +0800
Subject: [PATCH] =?UTF-8?q?fix=EF=BC=9A=E6=89=A7=E8=A1=8C=E5=BC=95?=
 =?UTF-8?q?=E6=93=8E=201.=E4=BF=AE=E5=A4=8D=E9=87=8D=E8=AF=95=E7=AD=96?=
 =?UTF-8?q?=E7=95=A5=E9=80=89=E6=8B=A9=E5=8D=95=E6=AC=A1=E9=87=8D=E8=AF=95?=
 =?UTF-8?q?=E6=97=B6=E4=BC=9A=E5=AF=BC=E8=87=B4=E4=BB=BB=E5=8A=A1=E8=B6=85?=
 =?UTF-8?q?=E6=97=B6=E7=9A=84=E9=97=AE=E9=A2=98=E3=80=82=E6=9B=B4=E6=94=B9?=
 =?UTF-8?q?=E5=88=A4=E6=96=AD=E6=9D=A1=E4=BB=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/net/northking/cctp/se/exec/DefaultExecThread.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/cctp-atu/atu-engine/atu-script-engine/src/main/java/net/northking/cctp/se/exec/DefaultExecThread.java b/cctp-atu/atu-engine/atu-script-engine/src/main/java/net/northking/cctp/se/exec/DefaultExecThread.java
index 2c947ea..8c54465 100644
--- a/cctp-atu/atu-engine/atu-script-engine/src/main/java/net/northking/cctp/se/exec/DefaultExecThread.java
+++ b/cctp-atu/atu-engine/atu-script-engine/src/main/java/net/northking/cctp/se/exec/DefaultExecThread.java
@@ -480,7 +480,7 @@ public class DefaultExecThread implements AtuExecThread{
             RabbitTemplate rabbitTemplate = SpringUtil.getBean(RabbitTemplate.class);
             rabbitTemplate.convertAndSend(AtuExecConstant.TASK_EXEC_RESULT, JsonUtils.toJson(result));
 
-            if (!AtuExecConstant.TASK_START.equalsIgnoreCase(type) && !AtuExecConstant.TASK_RETRY.equals(type)) {
+            if (!AtuExecConstant.TASK_START.equalsIgnoreCase(type) && !result.isNeedRetry()) {
                 log.debug("清理正在执行中任务数据");
                 AtuTaskExecHeartbeatSchedule.execTaskMap.remove(result.getTaskId());
             }