diff --git a/leopard-server/src/main/java/com/lanyuanxiaoyao/leopard/server/service/QuartzService.java b/leopard-server/src/main/java/com/lanyuanxiaoyao/leopard/server/service/QuartzService.java index c60658c..58f57e6 100644 --- a/leopard-server/src/main/java/com/lanyuanxiaoyao/leopard/server/service/QuartzService.java +++ b/leopard-server/src/main/java/com/lanyuanxiaoyao/leopard/server/service/QuartzService.java @@ -2,6 +2,7 @@ package com.lanyuanxiaoyao.leopard.server.service; import cn.hutool.core.util.IdUtil; import cn.hutool.core.util.ObjectUtil; +import com.lanyuanxiaoyao.leopard.server.service.task.TaskMonitorNodes; import com.yomahub.liteflow.core.FlowExecutor; import java.time.LocalDateTime; import java.time.ZoneId; @@ -95,7 +96,8 @@ public class QuartzService { if (ObjectUtil.isNotNull(templateId)) { var template = taskTemplateService.detail(templateId); var params = (Map) dataMap.getOrDefault("params", Map.of()); - flowExecutor.execute2Resp(template.getChain(), params, context); + var monitorContext = new TaskMonitorNodes.TaskMonitorContext(template); + flowExecutor.execute2Resp(template.getChain(), params, monitorContext); } } }