Repository: airavata Updated Branches: refs/heads/master 18f70920d -> 73856bd2a
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/73856bd2 Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/73856bd2 Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/73856bd2 Branch: refs/heads/master Commit: 73856bd2a9a96e01d6c1b50a0a599f18c758ed15 Parents: 18f7092 Author: lahiru <[email protected]> Authored: Fri Oct 3 12:42:31 2014 -0400 Committer: lahiru <[email protected]> Committed: Fri Oct 3 12:42:31 2014 -0400 ---------------------------------------------------------------------- .../airavata/gfac/monitor/impl/pull/qstat/HPCPullMonitor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/73856bd2/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 6b3ebc3..49ceb28 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 @@ -273,9 +273,9 @@ public class HPCPullMonitor extends PullMonitor { Set<String> keys = completedJobs.keySet(); for (String jobName: keys) { MonitorID completedJob = completedJobs.get(jobName); + CommonUtils.removeMonitorFromQueue(queue, completedJob); gfac.invokeOutFlowHandlers(completedJob.getJobExecutionContext()); // GFacThreadPoolExecutor.getCachedThreadPool().submit(new OutHandlerWorker(gfac, completedJob, publisher)); - CommonUtils.removeMonitorFromQueue(queue, completedJob); if (zk == null) { zk = completedJob.getJobExecutionContext().getZk(); }
