76 lines
2.5 KiB
Java
76 lines
2.5 KiB
Java
package org.gcube.dataanalysis.dataminer.poolmanager.service;
|
|
|
|
import java.io.File;
|
|
import java.io.FileNotFoundException;
|
|
***REMOVED***
|
|
import java.util.Scanner;
|
|
|
|
***REMOVED***
|
|
***REMOVED***
|
|
import org.gcube.dataanalysis.dataminer.poolmanager.datamodel.Cluster;
|
|
import org.gcube.dataanalysis.dataminer.poolmanager.util.ClusterBuilder;
|
|
import org.gcube.dataanalysis.dataminer.poolmanager.util.ServiceConfiguration;
|
|
import org.gcube.dataanalysis.dataminer.poolmanager.util.SVNUpdater;
|
|
***REMOVED***
|
|
|
|
public class DataminerPoolManager ***REMOVED***
|
|
|
|
|
|
private SVNUpdater svnUpdater;
|
|
|
|
public DataminerPoolManager() ***REMOVED***
|
|
try ***REMOVED***
|
|
***REMOVED***TODO: read this from configuration
|
|
this.svnUpdater = new SVNUpdater(new ServiceConfiguration());
|
|
***REMOVED*** catch (SVNException e) ***REMOVED***
|
|
e.printStackTrace();
|
|
***REMOVED***
|
|
***REMOVED***
|
|
|
|
|
|
***REMOVED***Algorithm algo,String targetVRE, String category, String algorithm_type/*,String env*/) throws IOException, InterruptedException ***REMOVED***
|
|
|
|
Cluster stagingCluster = ClusterBuilder.getStagingDataminerCluster();
|
|
|
|
|
|
***REMOVED***Cluster rProtoCluster = ClusterBuilder.getRProtoCluster();
|
|
|
|
DMPMJob job = new StagingJob(this.svnUpdater, algo, stagingCluster, /*rProtoCluster,*/ targetVRE, category, algorithm_type/*,env*/);
|
|
String id = job.start();
|
|
return id;
|
|
***REMOVED***
|
|
|
|
***REMOVED***Algorithm algo, String targetVRE, String category, String algorithm_type/*, String env*/) throws IOException, InterruptedException ***REMOVED***
|
|
|
|
***REMOVED***Cluster prodCluster = ClusterBuilder.getVRECluster(targetVREToken, targetVRE);
|
|
|
|
DMPMJob job = new ProductionPublishingJob(this.svnUpdater, algo, /*prodCluster,*/ targetVRE, category, algorithm_type/*,env*/);
|
|
String id = job.start();
|
|
return id;
|
|
***REMOVED***
|
|
|
|
|
|
public String getLogById(String id) throws FileNotFoundException***REMOVED***
|
|
|
|
***REMOVED***TODO: load dir from configuration file
|
|
File path = new File(System.getProperty("user.home") + File.separator + "dataminer-pool-manager/jobs/"
|
|
+ id);
|
|
|
|
return new Scanner(path).useDelimiter("\\Z").next();
|
|
***REMOVED***
|
|
|
|
|
|
public String getMonitorById(String id) throws FileNotFoundException***REMOVED***
|
|
|
|
***REMOVED***TODO: load dir from configuration file
|
|
File path = new File(System.getProperty("user.home") + File.separator + "dataminer-pool-manager/jobs/"
|
|
+ id + "_exitStatus");
|
|
|
|
return new Scanner(path).useDelimiter("\\Z").next();
|
|
***REMOVED***
|
|
|
|
|
|
|
|
|
|
***REMOVED***
|