Repository: airavata Updated Branches: refs/heads/master 4a84e86af -> 2d8e3503a
Fixed bug in email based monitor task context status update Project: http://git-wip-us.apache.org/repos/asf/airavata/repo Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/c62f64ae Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/c62f64ae Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/c62f64ae Branch: refs/heads/master Commit: c62f64ae4c9733f913bb1ec6539888cd2666873c Parents: 18a4c31 Author: Shameera Rathnayaka <[email protected]> Authored: Tue Dec 22 16:30:49 2015 -0500 Committer: Shameera Rathnayaka <[email protected]> Committed: Tue Dec 22 16:30:49 2015 -0500 ---------------------------------------------------------------------- .../org/apache/airavata/gfac/monitor/email/EmailBasedMonitor.java | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/airavata/blob/c62f64ae/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 b529fb5..144465b 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 @@ -388,6 +388,7 @@ public class EmailBasedMonitor implements JobMonitor, Runnable{ TaskStatus taskStatus = new TaskStatus(TaskState.COMPLETED); taskStatus.setTimeOfStateChange(AiravataUtils.getCurrentTimestamp().getTime()); taskStatus.setReason("Job monitoring completed with final state: " + TaskState.COMPLETED.name()); + taskContext.setTaskStatus(taskStatus); GFacUtils.saveAndPublishTaskStatus(taskContext); GFacThreadPoolExecutor.getCachedThreadPool().execute(new GFacWorker(taskContext.getParentProcessContext())); } catch (GFacException e) {
