}
nodeNames.add(node.getNodename());
context.getExecutionListener().log(3, "Create task for node: " + node.getNodename());
final CallableWrapperTask callableWrapperTask1 = new CallableWrapperTask(tocall);
callableWrapperTask1.setProject(project);
parallelTask.addTask(callableWrapperTask1);
}
if (null != failedListener) {
failedListener.matchedNodes(nodeNames);
}
context.getExecutionListener().log(3, "parallel dispatch to nodes: " + nodeNames);