Commit 79894bbf by huangfusuper

判断工作流是否完成BUG

parent 7d28c309
...@@ -110,9 +110,8 @@ public class ClosingExampleThreadRunHelper extends BaseThreadRunHelper implement ...@@ -110,9 +110,8 @@ public class ClosingExampleThreadRunHelper extends BaseThreadRunHelper implement
*/ */
private boolean logIsAllEnd(List<JobTaskRunLogWithBLOBs> jobTaskRunLogs){ private boolean logIsAllEnd(List<JobTaskRunLogWithBLOBs> jobTaskRunLogs){
for (JobTaskRunLogWithBLOBs jobTaskRunLog : jobTaskRunLogs) { for (JobTaskRunLogWithBLOBs jobTaskRunLog : jobTaskRunLogs) {
if (NodeRunStatusPropertyEnum.RUN_ING.getCode().equals(jobTaskRunLog.getRunCode())) { if (!(NodeRunStatusPropertyEnum.RUN_SUCCESS.getCode().equals(jobTaskRunLog.getRunCode()) ||
log.debug("--------------节点{},正在运行中-----------",jobTaskRunLog); NodeRunStatusPropertyEnum.RE_RUN_SUCCESS.getCode().equals(jobTaskRunLog.getRunCode()))){
//存在运行中的直接返回false
return false; return false;
} }
} }
......
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