Commit f123938b by huangfusuper

修改日志界别 返回查询工作流实例

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