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());
             }