feat(1.5.0-beta1): 修复重试失败设置错误Deleted问题
This commit is contained in:
parent
e3fdc8dce2
commit
03a5b73937
@ -81,7 +81,6 @@ public class RetryFailureHandler extends AbstractRetryResultHandler {
|
|||||||
} else if (context.isIncrementRetryCount()) {
|
} else if (context.isIncrementRetryCount()) {
|
||||||
retry.setRetryCount(retry.getRetryCount() + 1);
|
retry.setRetryCount(retry.getRetryCount() + 1);
|
||||||
retry.setUpdateDt(LocalDateTime.now());
|
retry.setUpdateDt(LocalDateTime.now());
|
||||||
retry.setDeleted(retry.getId());
|
|
||||||
Assert.isTrue(1 == retryMapper.updateById(retry),
|
Assert.isTrue(1 == retryMapper.updateById(retry),
|
||||||
() -> new SnailJobServerException("更新重试任务失败. groupName:[{}]", retry.getGroupName()));
|
() -> new SnailJobServerException("更新重试任务失败. groupName:[{}]", retry.getGroupName()));
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user