diff --git a/src/main/java/org/gcube/dataanalysys/dataminerpoolmanager/service/DataminerPoolManager.java b/src/main/java/org/gcube/dataanalysys/dataminerpoolmanager/service/DataminerPoolManager.java index 7b35f8b..27ea0ca 100644 --- a/src/main/java/org/gcube/dataanalysys/dataminerpoolmanager/service/DataminerPoolManager.java +++ b/src/main/java/org/gcube/dataanalysys/dataminerpoolmanager/service/DataminerPoolManager.java @@ -114,6 +114,19 @@ public class DataminerPoolManager { ***REMOVED*** + public void addAlgorithmsToVRE(AlgorithmSet algorithms, String vre) throws IOException { + + ***REMOVED*** create the cluster (dataminers in the vre) + Cluster cluster = new Cluster(); + for(Host h:new ISClient().listDataminersInVRE(vre)) { + cluster.addHost(h); + ***REMOVED*** + + ***REMOVED*** apply the changes + new AnsibleBridge().applyAlgorithmSetToCluster(algorithms, cluster); + + ***REMOVED*** + ***REMOVED*** private void updateClusters() { ***REMOVED*** System.out.println("flushing changes to all clusters"); ***REMOVED*** ***REMOVED***