gtsoft/gtsoft-snail-job-server
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects 1 Releases Wiki Activity

feat:(1.2.0-beta2): 定时任务使用恢复阻塞策略时，只重新调用不成功的任务

Browse Source
This commit is contained in:
srzou 2024-10-11 14:07:07 +08:00
parent 8384f9a746
commit bde37ee3e8
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/block/job/RecoveryBlockStrategy.java
View File

@ -68,7 +68,7 @@ public class RecoveryBlockStrategy extends AbstracJobBlockStrategy {
jobExecutor.execute(buildJobExecutorContext(context, job, jobExecutor.execute(buildJobExecutorContext(context, job,
StreamUtils.filter(jobTasks, StreamUtils.filter(jobTasks,
(jobTask) -> JobTaskStatusEnum.NOT_SUCCESS.contains(jobTask.getTaskStatus()) (jobTask) -> JobTaskStatusEnum.NOT_SUCCESS.contains(jobTask.getTaskStatus())
|| JobTaskStatusEnum.NOT_COMPLETE.contains(jobTask.getTaskStatus())))); )));
} }
@Override @Override