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

feat(1.4.0-beta1): 修复job调度失败问题

Browse Source
This commit is contained in:
opensnail 2025-02-25 21:31:47 +08:00
parent 87f11776d1
commit 2de9457d60
2 changed files with 3 additions and 3 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/dispatch/JobTaskPrepareActor.java
View File

@ -77,8 +77,6 @@ public class JobTaskPrepareActor extends AbstractActor {
// 模拟完成情况
jobTaskBatch.setTaskBatchStatus(JobTaskBatchStatusEnum.SUCCESS.getStatus());
notCompleteJobTaskBatchList = Lists.newArrayList(jobTaskBatch);
// TerminalJobPrepareHandler terminalJobPrepareHandler = SnailSpringContext.getBeanByType(TerminalJobPrepareHandler.class);
// terminalJobPrepareHandler.handle(prepare);
}
boolean onlyTimeoutCheck = false;

4
snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/prepare/job/TerminalJobPrepareHandler.java
View File

@ -12,6 +12,8 @@ import org.springframework.stereotype.Component;
import java.util.Objects;
import static com.aizuda.snailjob.common.core.enums.JobTaskBatchStatusEnum.COMPLETED;
/**
* 处理处于已完成 {@link JobTaskBatchStatusEnum::COMPLETED} 状态的任务
*
@ -29,7 +31,7 @@ public class TerminalJobPrepareHandler extends AbstractJobPrepareHandler {
@Override
public boolean matches(Integer status) {
return Objects.isNull(status);
return COMPLETED.contains(status);
}
@Override