Repository: airavata Updated Branches: refs/heads/master aff5d9288 -> d89236975
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/master Commit: d798cab5209a093d1f08eac591626d10ace13e14 Parents: a8cf35f Author: Lahiru Gunathilake <[email protected]> Authored: Tue Mar 31 10:22:40 2015 -0400 Committer: Lahiru Gunathilake <[email protected]> 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; }
