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: 修复 DispatchService#dispatch 方法的 jobId 取值问题

Browse Source
This commit is contained in:
Echo009 2021-02-18 15:21:11 +08:00
parent c3cc8aef4c
commit 6671bcf6f7
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
powerjob-server/src/main/java/com/github/kfcfans/powerjob/server/service/DispatchService.java
View File

@ -80,7 +80,7 @@ public class DispatchService {
public void dispatch(JobInfoDO jobInfo, long instanceId) { public void dispatch(JobInfoDO jobInfo, long instanceId) {
// 检查当前任务是否被取消 // 检查当前任务是否被取消
InstanceInfoDO instanceInfo = instanceInfoRepository.findByInstanceId(instanceId); InstanceInfoDO instanceInfo = instanceInfoRepository.findByInstanceId(instanceId);
Long jobId = instanceInfo.getId(); Long jobId = instanceInfo.getJobId();
if (CANCELED.getV() == instanceInfo.getStatus()) { if (CANCELED.getV() == instanceInfo.getStatus()) {
log.info("[Dispatcher-{}|{}] cancel dispatch due to instance has been canceled", jobId, instanceId); log.info("[Dispatcher-{}|{}] cancel dispatch due to instance has been canceled", jobId, instanceId);
return; return;