xiangpei
2025-02-14 c5dafd7dba14635643b4340597fb14c563c8dc7e
business/src/main/java/com/ycl/task/FlowableTask.java
@@ -42,7 +42,7 @@
    public void expireTask() {
        log.info("开始赋码");
        //当前正在运行的所有任务节点
        List<Task> taskList = taskService.createTaskQuery().list();
        List<Task> taskList = taskService.createTaskQuery().active().list();
        if (CollectionUtils.isEmpty(taskList)) return;
        List<String> taskIds = taskList.stream().map(TaskInfo::getId).collect(Collectors.toList());
        //需要监控的赋码任务