This commit is contained in:
Paolo Fabriani 2016-11-17 14:32:22 +00:00
parent 2431bdce34
commit c0d6c5d286
1 changed files with 13 additions and 0 deletions

View File

@ -114,6 +114,19 @@ public class DataminerPoolManager {
} }
public void addAlgorithmsToVRE(AlgorithmSet algorithms, String vre) throws IOException {
// create the cluster (dataminers in the vre)
Cluster cluster = new Cluster();
for(Host h:new ISClient().listDataminersInVRE(vre)) {
cluster.addHost(h);
}
// apply the changes
new AnsibleBridge().applyAlgorithmSetToCluster(algorithms, cluster);
}
// private void updateClusters() { // private void updateClusters() {
// System.out.println("flushing changes to all clusters"); // System.out.println("flushing changes to all clusters");
// } // }