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: bug #324

Browse Source 
* fix: bug #324

Fail to cancel delay job instance by id via API

* style: correct log

* style: update log

Co-authored-by: Echo009 <ech0.extreme@foxmail.com>
This commit is contained in:
Justin Zhang 2022-08-31 23:12:10 +08:00 committed by GitHub
parent e094c22952
commit 75c88c32ed
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
powerjob-server/powerjob-server-core/src/main/java/tech/powerjob/server/core/instance/InstanceService.java
View File

@ -191,8 +191,8 @@ public class InstanceService {
* @param instanceId 任务实例 * @param instanceId 任务实例
*/ */
@DesignateServer @DesignateServer
public void cancelInstance(Long instanceId) { public void cancelInstance(Long appId, Long instanceId) {
log.info("[Instance-{}] try to cancel the instance.", instanceId); log.info("[Instance-{}] try to cancel the instance with appId {}.", instanceId, appId);
try { try {
InstanceInfoDO instanceInfo = fetchInstanceInfo(instanceId); InstanceInfoDO instanceInfo = fetchInstanceInfo(instanceId);

2
powerjob-server/powerjob-server-starter/src/main/java/tech/powerjob/server/web/controller/OpenAPIController.java
View File

@ -126,7 +126,7 @@ public class OpenAPIController {
@PostMapping(OpenAPIConstant.CANCEL_INSTANCE) @PostMapping(OpenAPIConstant.CANCEL_INSTANCE)
public ResultDTO<Void> cancelInstance(Long instanceId, Long appId) { public ResultDTO<Void> cancelInstance(Long instanceId, Long appId) {
checkInstanceIdValid(instanceId, appId); checkInstanceIdValid(instanceId, appId);
instanceService.cancelInstance(instanceId); instanceService.cancelInstance(appId, instanceId);
return ResultDTO.success(null); return ResultDTO.success(null);
} }