gCubeSystem
/
dataminer-pool-manager
16
0
Fork 0
Code Issues Pull Requests Releases 2 Wiki Activity

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
This commit is contained in:
Gabriele Giammatteo 2017-05-10 09:04:04 +00:00
parent ec7d888eb1
commit 63a918f442
1 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/service/DataminerPoolManager.java
View File

@ -38,6 +38,7 @@ public class DataminerPoolManager {
public DataminerPoolManager(){ public DataminerPoolManager(){
try { try {
***REMOVED***TODO: read this from configuration
this.svnUpdater = new SVNUpdater( this.svnUpdater = new SVNUpdater(
"https:***REMOVED***svn.d4science.research-infrastructures.eu/gcube/trunk/data-analysis/RConfiguration/RPackagesManagement/"); "https:***REMOVED***svn.d4science.research-infrastructures.eu/gcube/trunk/data-analysis/RConfiguration/RPackagesManagement/");
***REMOVED*** catch (SVNException e) { ***REMOVED*** catch (SVNException e) {
@ -49,10 +50,8 @@ public class DataminerPoolManager {
public String stageAlgorithm(Algorithm algo) throws IOException, InterruptedException { public String stageAlgorithm(Algorithm algo) throws IOException, InterruptedException {
Cluster cluster = new Cluster();
Host h = new Host(); Cluster cluster = getStagingDataminerCluster();
h.setName(getStagingDataminerHostname());
cluster.addHost(h);
***REMOVED***Assumes the service is running in RPrototypingLab ***REMOVED***Assumes the service is running in RPrototypingLab
String token = SecurityTokenProvider.instance.get(); String token = SecurityTokenProvider.instance.get();
@ -70,8 +69,13 @@ public class DataminerPoolManager {
***REMOVED*** ***REMOVED***
private String getStagingDataminerHostname(){ private Cluster getStagingDataminerCluster(){
return null; Cluster cluster = new Cluster();
Host h = new Host();
***REMOVED***TODO: read this from configuration
h.setName("test");
cluster.addHost(h);
return cluster;
***REMOVED*** ***REMOVED***
private void updateSVNDependencies(Algorithm algo, boolean stagingVRE) throws IOException, SVNException { private void updateSVNDependencies(Algorithm algo, boolean stagingVRE) throws IOException, SVNException {