You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by la...@apache.org on 2014/10/03 18:42:37 UTC
git commit: fixing a file transfer error
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 <la...@apache.org>
Authored: Fri Oct 3 12:42:31 2014 -0400
Committer: lahiru <la...@apache.org>
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();
}