fix: 修复job 取消后未删除队列中job

2024-11-28 10:30:49 +08:00
parent b398e32f2d
commit 28909428fa
1 changed files with 1 additions and 1 deletions
--- a/src/main/java/net/geedge/asw/module/runner/controller/JobController.java
+++ b/src/main/java/net/geedge/asw/module/runner/controller/JobController.java
@@ -122,7 +122,7 @@ public class JobController {
        }

        if (job.getStatus().contains(RunnerConstant.JobStatus.PENDING.getValue())){
-            jobQueueManager.requeueJob(job);
+            jobQueueManager.removeJob(job);
        }

        Thread runningThread = Constants.RUNNING_JOB_THREAD.get(id);