Workflow wf = buildWorkflow(parent, subtasks); Expansion expansion = getPlanningFactory().createExpansion(parent.getPlan(), parent, wf, null); if(logger.isInfoEnabled()) { logger.info("GenerateProjectionsExpander publishing expansion " + dfPlugin.getClusterId()); } dfPlugin.publishAdd(expansion);
  private void createAndPublishExpansion(Task parent, Collection subtasks) {    Iterator subtasksIT = subtasks.iterator();    while (subtasksIT.hasNext()) {      dfPlugin.publishAdd(subtasksIT.next());    }    Workflow wf = buildWorkflow(parent, subtasks);    Expansion expansion = getPlanningFactory().createExpansion(parent.getPlan(), parent, wf, null);    if(logger.isInfoEnabled()) {      logger.info("GenerateProjectionsExpander publishing expansion " + dfPlugin.getClusterId());    }    dfPlugin.publishAdd(expansion);  }