airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lah...@apache.org
Subject git commit: fixing a file transfer error
Date Fri, 03 Oct 2014 16:42:37 GMT
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 <lahiru@apache.org>
Authored: Fri Oct 3 12:42:31 2014 -0400
Committer: lahiru <lahiru@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();
                 }


Mime
View raw message