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@151136 82a268e6-3cf1-43bd-a215-b396298e98cf

This commit is contained in:
Nunzio Andrea Galante 2017-07-18 13:22:29 +00:00
parent 619156bcc6
commit 1217ed589b
1 changed files with 13 additions and 15 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/StagingJob.java
View File

@ -39,7 +39,6 @@ public class StagingJob extends DMPMJob ***REMOVED***
***REMOVED*** this.rProtoCluster = rProtoCluster; ***REMOVED*** this.rProtoCluster = rProtoCluster;
this.rProtoVREName = rProtoVREName; this.rProtoVREName = rProtoVREName;
File m = new File(this.jobLogs + File.separator + this.id + "_exitStatus"); File m = new File(this.jobLogs + File.separator + this.id + "_exitStatus");
PrintWriter writer = new PrintWriter(m, "UTF-8"); PrintWriter writer = new PrintWriter(m, "UTF-8");
writer.println(this.getStatus(0)); writer.println(this.getStatus(0));
@ -73,16 +72,11 @@ public class StagingJob extends DMPMJob ***REMOVED***
int ret = this.executeAnsibleWorker(createWorker(this.algorithm, this.stagingCluster, false, "root")); int ret = this.executeAnsibleWorker(createWorker(this.algorithm, this.stagingCluster, false, "root"));
***REMOVED*** Integer s = null;
***REMOVED*** s = Integer.valueOf(ret);
***REMOVED***
***REMOVED*** if (s == null) ***REMOVED***
***REMOVED*** this.getStatus(0);
***REMOVED*** ***REMOVED***
if (ret != 0) ***REMOVED*** if (ret != 0) ***REMOVED***
this.getStatus(2); this.getStatus(2);
sm.sendNotification(nh.getFailedSubject(), nh.getFailedBody("Installation failed. Return code=" + ret)); sm.sendNotification(nh.getFailedSubject(), nh.getFailedBody("Installation failed. Return code=" + ret));
return;
***REMOVED*** ***REMOVED***
if (ret == 0) ***REMOVED*** if (ret == 0) ***REMOVED***
@ -99,12 +93,16 @@ public class StagingJob extends DMPMJob ***REMOVED***
this.getStatus(9); this.getStatus(9);
sm.sendNotification(nh.getSuccessSubject(), nh.getSuccessBody()); sm.sendNotification(nh.getSuccessSubject(), nh.getSuccessBody());
return;
***REMOVED*** else ***REMOVED*** else
this.getStatus(2); this.getStatus(2);
sm.sendNotification(nh.getFailedSubject(), sm.sendNotification(nh.getFailedSubject(),
nh.getFailedBody("Installation completed but DataMiner Interface not working correctly or files " + this.algorithm.getName() nh.getFailedBody(
+ ".jar and " + this.algorithm.getName() "Installation completed but DataMiner Interface not working correctly or files "
+ this.algorithm.getName() + ".jar and " + this.algorithm.getName()
+ "_interface.jar not availables at the expected path")); + "_interface.jar not availables at the expected path"));
return;
***REMOVED*** ***REMOVED***
***REMOVED*** catch (Exception e) ***REMOVED*** ***REMOVED*** catch (Exception e) ***REMOVED***
e.printStackTrace(); e.printStackTrace();