You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sh...@apache.org on 2015/04/03 17:24:42 UTC
[02/11] airavata git commit: fixing AIRAVATA-1567
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 <gl...@gmail.com>
Authored: Tue Mar 31 10:22:40 2015 -0400
Committer: Lahiru Gunathilake <gl...@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;
}