Skip to content

B
byit-myth-job
Commit cd8cf883 by huangfusuper
Options

重跑的节点无参数问题

parent 9e94cfbd
Showing with 2 additions and 0 deletions
byit-myth-admin/src/main/java/com/byit/service/impl/ApiFlowServiceImpl.java
...@@ -510,6 +510,7 @@ public class ApiFlowServiceImpl implements ApiFlowService { ...@@ -510,6 +510,7 @@ public class ApiFlowServiceImpl implements ApiFlowService {
//设置为重跑 //设置为重跑
waitingTask.setScheduleType(ScheduleTypeEnum.REPEAT.getCode()); waitingTask.setScheduleType(ScheduleTypeEnum.REPEAT.getCode());
waitingTask.setOperator(userName); waitingTask.setOperator(userName);
waitingTask.setRunParam(jobTaskRunLog.getRunParams());
List<WaitingTask> waitingTaskList = new ArrayList<>(); List<WaitingTask> waitingTaskList = new ArrayList<>();
waitingTaskList.add(waitingTask); waitingTaskList.add(waitingTask);
...@@ -657,6 +658,7 @@ public class ApiFlowServiceImpl implements ApiFlowService { ...@@ -657,6 +658,7 @@ public class ApiFlowServiceImpl implements ApiFlowService {
//设置为重跑 //设置为重跑
waitingTask.setScheduleType(ScheduleTypeEnum.REPEAT.getCode()); waitingTask.setScheduleType(ScheduleTypeEnum.REPEAT.getCode());
waitingTask.setOperator(userName); waitingTask.setOperator(userName);
waitingTask.setRunParam(jobTaskRunLog.getRunParams());
//查询当前节点的依赖节点 //查询当前节点的依赖节点
List<Integer> dependNodeIdList = nodeDependencyMapper.findDependIdByNodeId(jobTaskRunLog.getNodeId()); List<Integer> dependNodeIdList = nodeDependencyMapper.findDependIdByNodeId(jobTaskRunLog.getNodeId());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment