diff --git a/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/result/job/AbstractJobExecutorResultHandler.java b/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/result/job/AbstractJobExecutorResultHandler.java index 6f4249db0..eddf2060d 100644 --- a/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/result/job/AbstractJobExecutorResultHandler.java +++ b/snail-job-server/snail-job-server-job-task/src/main/java/com/aizuda/snailjob/server/job/task/support/result/job/AbstractJobExecutorResultHandler.java @@ -54,6 +54,9 @@ public abstract class AbstractJobExecutorResultHandler implements JobExecutorRes return; } + // 放入任务项, 子类会用到 + context.setJobTaskList(jobTasks); + Map statusCountMap = jobTasks.stream() .collect(Collectors.groupingBy(JobTask::getTaskStatus, Collectors.counting()));