From 93cb62ab99e78a6dc258bf4de5cd1c6a77400f28 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 d230881..d47cd13 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 ***REMOVED*** public StagingJob(SVNUpdater svnUpdater, Algorithm algorithm, Cluster stagingCluster, /* Cluster rProtoCluster, */ - String rProtoVREName) ***REMOVED*** + String rProtoVREName) throws FileNotFoundException, UnsupportedEncodingException ***REMOVED*** 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 ***REMOVED*** 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*** ***REMOVED*** @@ -66,12 +73,12 @@ public class StagingJob extends DMPMJob ***REMOVED*** int ret = this.executeAnsibleWorker(createWorker(this.algorithm, this.stagingCluster, false, "root")); - Integer s = null; - s = Integer.valueOf(ret); - - if (s == null) ***REMOVED*** - this.getStatus(0); - ***REMOVED*** +***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*** this.getStatus(2); @@ -104,7 +111,6 @@ public class StagingJob extends DMPMJob ***REMOVED*** public String getStatus(int exitstatus) throws FileNotFoundException, UnsupportedEncodingException ***REMOVED*** File m = new File(this.jobLogs + File.separator + this.id + "_exitStatus"); - PrintWriter writer = new PrintWriter(m, "UTF-8"); String response = "";