airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lah...@apache.org
Subject [1/2] git commit: fixing a file transfer error
Date Fri, 03 Oct 2014 16:34:18 GMT
Repository: airavata
Updated Branches:
  refs/heads/master c2b9158ea -> 18f70920d


fixing a file transfer error


Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/b810ee50
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/b810ee50
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/b810ee50

Branch: refs/heads/master
Commit: b810ee505b1c5a50bf099f3f1dfddf98ff114ca1
Parents: 10139ba
Author: lahiru <lahiru@apache.org>
Authored: Fri Oct 3 12:34:05 2014 -0400
Committer: lahiru <lahiru@apache.org>
Committed: Fri Oct 3 12:34:05 2014 -0400

----------------------------------------------------------------------
 .../airavata/gfac/monitor/impl/pull/qstat/HPCPullMonitor.java   | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/airavata/blob/b810ee50/modules/gfac/gfac-monitor/src/main/java/org/apache/airavata/gfac/monitor/impl/pull/qstat/HPCPullMonitor.java
----------------------------------------------------------------------
diff --git a/modules/gfac/gfac-monitor/src/main/java/org/apache/airavata/gfac/monitor/impl/pull/qstat/HPCPullMonitor.java
b/modules/gfac/gfac-monitor/src/main/java/org/apache/airavata/gfac/monitor/impl/pull/qstat/HPCPullMonitor.java
index 96edf3c..6b3ebc3 100644
--- a/modules/gfac/gfac-monitor/src/main/java/org/apache/airavata/gfac/monitor/impl/pull/qstat/HPCPullMonitor.java
+++ b/modules/gfac/gfac-monitor/src/main/java/org/apache/airavata/gfac/monitor/impl/pull/qstat/HPCPullMonitor.java
@@ -240,8 +240,9 @@ public class HPCPullMonitor extends PullMonitor {
 
                         if (iMonitorID.getFailedCount() > FAILED_COUNT) {
                             iMonitorID.setLastMonitored(new Timestamp((new Date()).getTime()));
-                            JobDescriptor jobDescriptor = JobDescriptor.fromXML(iMonitorID.getJobExecutionContext().getJobDetails().getJobDescription());
-                            List<String> stdOut = connection.getCluster().listDirectory(jobDescriptor.getOutputDirectory());
// check the outputs directory
+                            String outputDir = iMonitorID.getJobExecutionContext().getApplicationContext()
+                                    .getApplicationDeploymentDescription().getType().getOutputDataDirectory();
+                            List<String> stdOut = connection.getCluster().listDirectory(outputDir);
// check the outputs directory
                             if (stdOut.size() > 0) { // have to be careful with this
                                 completedJobs.put(iMonitorID.getJobName(), iMonitorID);
                                 logger.errorId(iMonitorID.getJobID(), "Job monitoring failed
{} times, removed job {} from " +


Mime
View raw message