diff --git a/pom.xml b/pom.xml index 6824da5dc..782c0c8a6 100644 --- a/pom.xml +++ b/pom.xml @@ -20,7 +20,7 @@ 17 17 UTF-8 - 1.4.0 + 1.5.0-beta1 true 4.1.114.Final diff --git a/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/client/JobEndPoint.java b/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/client/JobEndPoint.java index 298049878..b65167136 100644 --- a/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/client/JobEndPoint.java +++ b/snail-job-client/snail-job-client-job-core/src/main/java/com/aizuda/snailjob/client/job/core/client/JobEndPoint.java @@ -86,7 +86,11 @@ public class JobEndPoint { } } - SnailJobLog.REMOTE.info("批次:[{}] 任务调度成功. ", dispatchJob.getTaskBatchId()); + SnailJobLog.REMOTE.info("任务调度方:[{}] 任务ID:[{}] 任务批次:[{}] 工作流批次:[{}] 任务调度成功. ", + Objects.isNull(dispatchJob.getWorkflowTaskBatchId()) ? "job" : "workflow", + dispatchJob.getJobId(), + dispatchJob.getTaskBatchId(), + dispatchJob.getWorkflowTaskBatchId()); jobExecutor.jobExecute(jobContext);