third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: running times of job instance is always 0

Browse Source
This commit is contained in:
Echo009 2021-03-02 10:22:28 +08:00
parent 44ae97d6d8
commit bf5f6ef0db
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/instance/InstanceManager.java
View File

@ -81,8 +81,7 @@ public class InstanceManager {
InstanceStatus receivedInstanceStatus = InstanceStatus.of(req.getInstanceStatus());
Integer timeExpressionType = jobInfo.getTimeExpressionType();
instanceInfo.setStatus(receivedInstanceStatus.getV());
// 更新 最后上报时间 和 修改时间
instanceInfo.setLastReportTime(req.getReportTime());
instanceInfo.setGmtModified(new Date());
@ -90,7 +89,7 @@ public class InstanceManager {
// FREQUENT 任务的 newStatus 只有2中情况，一种是 RUNNING，一种是 FAILED（表示该机器 overload，需要重新选一台机器执行）
// 综上，直接把 status 和 runningNum 同步到DB即可
if (TimeExpressionType.frequentTypes.contains(timeExpressionType)) {
instanceInfo.setStatus(receivedInstanceStatus.getV());
instanceInfo.setResult(req.getResult());
instanceInfo.setRunningTimes(req.getTotalTaskNum());
instanceInfoRepository.saveAndFlush(instanceInfo);
@ -101,6 +100,8 @@ public class InstanceManager {
// 这里不会存在并发问题
instanceInfo.setRunningTimes(instanceInfo.getRunningTimes() + 1);
}
// QAQ ，不能提前变更 status，否则会导致更新运行次数的逻辑不生效继而导致普通任务 无限重试
instanceInfo.setStatus(receivedInstanceStatus.getV());
boolean finished = false;
if (receivedInstanceStatus == InstanceStatus.SUCCEED) {