airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From shame...@apache.org
Subject [02/11] airavata git commit: fixing AIRAVATA-1567
Date Fri, 03 Apr 2015 15:24:42 GMT
fixing AIRAVATA-1567


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

Branch: refs/heads/emailMonitoring
Commit: d798cab5209a093d1f08eac591626d10ace13e14
Parents: a8cf35f
Author: Lahiru Gunathilake <glahiru@gmail.com>
Authored: Tue Mar 31 10:22:40 2015 -0400
Committer: Lahiru Gunathilake <glahiru@gmail.com>
Committed: Tue Mar 31 10:22:40 2015 -0400

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


http://git-wip-us.apache.org/repos/asf/airavata/blob/d798cab5/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 f0b447e..ab934ca 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
@@ -195,6 +195,8 @@ public class HPCPullMonitor extends PullMonitor {
                                 logger.info("Job cancelled: marking the Job as ************CANCELLED************
experiment {}, task {}, job name {} .",
                                         iMonitorID.getExperimentID(), iMonitorID.getTaskID(),
iMonitorID.getJobName());
                                 sendNotification(iMonitorID);
+                                logger.info("To avoid timing issues we sleep sometime and
try to retrieve output files");
+                                Thread.sleep(10000);
                                 GFacThreadPoolExecutor.getFixedThreadPool().submit(new OutHandlerWorker(gfac,
iMonitorID, publisher));
                                 break;
                             }


Mime
View raw message