Commit 9a513f23 by huangfusuper

依赖节点设置首节点不设置

parent bf8f12ff
......@@ -124,6 +124,8 @@ public class JobTaskThreadRunHelper extends BaseThreadRunHelper {
//如果是补批节点 而且没有依赖节点的话,按照开始节点处理
if( ScheduleTypeEnum.REPAIR.getCode().equals(jobTask.getScheduleType()) && StringUtils.isBlank(jobTask.getNodeDepend())){
startNodeOperating(jobTask,jobTaskSchedules);
}else if (ScheduleTypeEnum.REPEAT.getCode().equals(jobTask.getScheduleType()) && StringUtils.isBlank(jobTask.getNodeDepend())) {
startNodeOperating(jobTask,jobTaskSchedules);
}else if (nodeVerification.superiorNodeStatus(jobTask)) {
//断定上级节点是否执行成功
runJobTask(jobTask,jobTaskSchedules);
......
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