From c47a84db5524d55a6376dbd94eefe6bc3ee3c147 Mon Sep 17 00:00:00 2001 From: Nunzio Andrea Galante Date: Thu, 13 Jul 2017 16:38:03 +0000 Subject: [PATCH] git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-analysis/dataminer-pool-manager@151070 82a268e6-3cf1-43bd-a215-b396298e98cf --- .../poolmanager/service/StagingJob.java | 22 ++++++++++++------- 1 file changed, 14 insertions(+), 8 deletions(-) diff --git a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/service/StagingJob.java b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/service/StagingJob.java index ee7a9fb..ff0c1a1 100644 --- a/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/service/StagingJob.java +++ b/src/main/java/org/gcube/dataanalysis/dataminer/poolmanager/service/StagingJob.java @@ -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 = "";