yineng.huang
/
hz
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix：执行引擎 

1.修复重试策略选择单次重试时会导致任务超时的问题。更改判断条件
hz_1122_temp
李杰应 2024-11-25 20:34:16 +08:00
parent bd78df1ae4
commit e6b4fe6d88
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
cctp-atu/atu-engine/atu-script-engine/src/main/java/net/northking/cctp/se/exec/DefaultExecThread.java
View File

@ -480,7 +480,7 @@ public class DefaultExecThread implements AtuExecThread{
RabbitTemplate rabbitTemplate = SpringUtil.getBean(RabbitTemplate.class); RabbitTemplate rabbitTemplate = SpringUtil.getBean(RabbitTemplate.class);
rabbitTemplate.convertAndSend(AtuExecConstant.TASK_EXEC_RESULT, JsonUtils.toJson(result)); 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("清理正在执行中任务数据"); log.debug("清理正在执行中任务数据");
AtuTaskExecHeartbeatSchedule.execTaskMap.remove(result.getTaskId()); AtuTaskExecHeartbeatSchedule.execTaskMap.remove(result.getTaskId());
} }