}
// initialized is true only if flowKey and flowQueueKey are initialized
WorkflowId workflowId = new WorkflowId(cluster, username,
appId, flowKey.getRunId(), flowQueueKey.getTimestamp(),
flowQueueKey.getFlowId());
return workflowId.toId();
}
@Override
public void sendDagNodeNameMap(String workflowId,
Map dagNodeMap) throws IOException {