|
|
@ -520,8 +520,11 @@ public class MasterExecThread implements Runnable { |
|
|
|
List<String> depsNameList = taskNode.getDepList(); |
|
|
|
List<String> depsNameList = taskNode.getDepList(); |
|
|
|
for(String depsNode : depsNameList ){ |
|
|
|
for(String depsNode : depsNameList ){ |
|
|
|
|
|
|
|
|
|
|
|
// dependencies must be fully completed or run prohibited
|
|
|
|
if(forbiddenTaskList.containsKey(depsNode)){ |
|
|
|
if(!completeTaskList.containsKey(depsNode) || !forbiddenTaskList.containsKey(depsNode)){ |
|
|
|
continue; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
// dependencies must be fully completed
|
|
|
|
|
|
|
|
if(!completeTaskList.containsKey(depsNode)){ |
|
|
|
return DependResult.WAITING; |
|
|
|
return DependResult.WAITING; |
|
|
|
} |
|
|
|
} |
|
|
|
ExecutionStatus taskState = completeTaskList.get(depsNode).getState(); |
|
|
|
ExecutionStatus taskState = completeTaskList.get(depsNode).getState(); |
|
|
|