From 63a918f442caf5afe0e531975fc7d869fc8d5fde Mon Sep 17 00:00:00 2001 From: Gabriele Giammatteo Date: Wed, 10 May 2017 09:04:04 +0000 Subject: [PATCH] refactoring (part 3) git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-analysis/dataminer-pool-manager@148427 82a268e6-3cf1-43bd-a215-b396298e98cf --- .../service/DataminerPoolManager.java | 16 ++++++++++------ 1 file changed, 10 insertions(+), 6 deletions(-) diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/service/DataminerPoolManager.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/service/DataminerPoolManager.java index fc162ef..4196712 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/service/DataminerPoolManager.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/service/DataminerPoolManager.java @@ -38,6 +38,7 @@ public class DataminerPoolManager { public DataminerPoolManager(){ try { + ***REMOVED***TODO: read this from configuration this.svnUpdater = new SVNUpdater( "https:***REMOVED***svn.d4science.research-infrastructures.eu/gcube/trunk/data-analysis/RConfiguration/RPackagesManagement/"); ***REMOVED*** catch (SVNException e) { @@ -49,10 +50,8 @@ public class DataminerPoolManager { public String stageAlgorithm(Algorithm algo) throws IOException, InterruptedException { - Cluster cluster = new Cluster(); - Host h = new Host(); - h.setName(getStagingDataminerHostname()); - cluster.addHost(h); + + Cluster cluster = getStagingDataminerCluster(); ***REMOVED***Assumes the service is running in RPrototypingLab String token = SecurityTokenProvider.instance.get(); @@ -70,8 +69,13 @@ public class DataminerPoolManager { ***REMOVED*** - private String getStagingDataminerHostname(){ - return null; + private Cluster getStagingDataminerCluster(){ + Cluster cluster = new Cluster(); + Host h = new Host(); + ***REMOVED***TODO: read this from configuration + h.setName("test"); + cluster.addHost(h); + return cluster; ***REMOVED*** private void updateSVNDependencies(Algorithm algo, boolean stagingVRE) throws IOException, SVNException {