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

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-analysis/dataminer-pool-manager@151070 82a268e6-3cf1-43bd-a215-b396298e98cf

This commit is contained in:
Nunzio Andrea Galante 2017-07-13 16:38:03 +00:00
parent 1be681a9bd
commit c47a84db55
1 changed files with 14 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/service/StagingJob.java
View File

@ -28,7 +28,7 @@ public class StagingJob extends DMPMJob {
public StagingJob(SVNUpdater svnUpdater, Algorithm algorithm,
Cluster stagingCluster, /* Cluster rProtoCluster, */
String rProtoVREName) {
String rProtoVREName) throws FileNotFoundException, UnsupportedEncodingException {
super(svnUpdater);
this.jobLogs = new File(
System.getProperty("user.home") + File.separator + "dataminer-pool-manager" + File.separator + "jobs");
@ -38,6 +38,13 @@ public class StagingJob extends DMPMJob {
this.stagingCluster = stagingCluster;
***REMOVED*** this.rProtoCluster = rProtoCluster;
this.rProtoVREName = rProtoVREName;
File m = new File(this.jobLogs + File.separator + this.id + "_exitStatus");
PrintWriter writer = new PrintWriter(m, "UTF-8");
writer.println(this.getStatus(0));
writer.close();
***REMOVED***
@Override
@ -66,12 +73,12 @@ public class StagingJob extends DMPMJob {
int ret = this.executeAnsibleWorker(createWorker(this.algorithm, this.stagingCluster, false, "root"));
Integer s = null;
s = Integer.valueOf(ret);
if (s == null) {
this.getStatus(0);
***REMOVED***
***REMOVED*** Integer s = null;
***REMOVED*** s = Integer.valueOf(ret);
***REMOVED***
***REMOVED*** if (s == null) {
***REMOVED*** this.getStatus(0);
***REMOVED*** ***REMOVED***
if (ret != 0) {
this.getStatus(2);
@ -104,7 +111,6 @@ public class StagingJob extends DMPMJob {
public String getStatus(int exitstatus) throws FileNotFoundException, UnsupportedEncodingException {
File m = new File(this.jobLogs + File.separator + this.id + "_exitStatus");
PrintWriter writer = new PrintWriter(m, "UTF-8");
String response = "";