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/09/09 21:29:26 UTC
airavata git commit: Save complete and queue job status in email job
monitor
Repository: airavata
Updated Branches:
refs/heads/master b0c793f06 -> 95cc3c4ab
Save complete and queue job status in email job monitor
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/95cc3c4a
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/95cc3c4a
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/95cc3c4a
Branch: refs/heads/master
Commit: 95cc3c4abbc497f7a1e9431b003f9cb35c803324
Parents: b0c793f
Author: Shameera Rathanyaka <sh...@gmail.com>
Authored: Wed Sep 9 15:29:22 2015 -0400
Committer: Shameera Rathanyaka <sh...@gmail.com>
Committed: Wed Sep 9 15:29:22 2015 -0400
----------------------------------------------------------------------
.../airavata/gfac/monitor/email/EmailBasedMonitor.java | 10 +++++++---
1 file changed, 7 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/95cc3c4a/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/monitor/email/EmailBasedMonitor.java
----------------------------------------------------------------------
diff --git a/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/monitor/email/EmailBasedMonitor.java b/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/monitor/email/EmailBasedMonitor.java
index 616373d..dd15cfa 100644
--- a/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/monitor/email/EmailBasedMonitor.java
+++ b/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/monitor/email/EmailBasedMonitor.java
@@ -269,11 +269,15 @@ public class EmailBasedMonitor implements JobMonitor, Runnable{
// TODO - Handle all other valid JobStates
if (resultState == JobState.COMPLETE) {
jobMonitorMap.remove(jobStatusResult.getJobId());
- runOutflowTasks = true;
+ jobStatus.setJobState(JobState.COMPLETE);
+ jobStatus.setReason("Complete email received");
+ runOutflowTasks = true;
log.info("[EJM]: Job Complete email received , removed job from job monitoring. " + jobDetails);
}else if (resultState == JobState.QUEUED) {
- // nothing special thing to do, update the status change to rabbit mq at the end of this method.
- log.info("[EJM]: Job Queued email received, " + jobDetails);
+ // nothing special thing to do, update the status change to rabbit mq at the end of this method.
+ jobStatus.setJobState(JobState.QUEUED);
+ jobStatus.setReason("Queue email received");
+ log.info("[EJM]: Job Queued email received, " + jobDetails);
}else if (resultState == JobState.ACTIVE) {
// nothing special thing to do, update the status change to rabbit mq at the end of this method.
jobStatus.setJobState(JobState.ACTIVE);