From f6e6e57aa7b0faee32f08635491508b091d9b4da Mon Sep 17 00:00:00 2001 From: Paolo Fabriani Date: Thu, 17 Nov 2016 14:32:22 +0000 Subject: [PATCH] git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-analysis/dataminer-pool-manager@134324 82a268e6-3cf1-43bd-a215-b396298e98cf --- .../service/DataminerPoolManager.java | 13 +++++++++++++ 1 file changed, 13 insertions(+) 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***