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 2016/01/13 18:03:17 UTC
[40/42] airavata git commit: updated process status to cancelling
with cron job cancelling task
updated process status to cancelling with cron job cancelling task
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/06647364
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/06647364
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/06647364
Branch: refs/heads/develop
Commit: 066473649714e5b22b1964267d0cc06f4c9d3f53
Parents: 7c935e7
Author: Shameera Rathnayaka <sh...@gmail.com>
Authored: Wed Jan 13 11:02:40 2016 -0500
Committer: Shameera Rathnayaka <sh...@gmail.com>
Committed: Wed Jan 13 11:02:40 2016 -0500
----------------------------------------------------------------------
.../apache/airavata/gfac/monitor/email/EmailBasedMonitor.java | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/06647364/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 9e802ae..b2df00b 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
@@ -138,6 +138,10 @@ public class EmailBasedMonitor implements JobMonitor, Runnable{
jobModel.setJobStatus(newJobStatus);
GFacUtils.saveJobStatus(pc, jobModel);
}
+ ProcessStatus pStatus = new ProcessStatus(ProcessState.CANCELLING);
+ pStatus.setReason("Job cancelled");
+ pc.setProcessStatus(pStatus);
+ GFacUtils.saveAndPublishProcessStatus(pc);
GFacThreadPoolExecutor.getCachedThreadPool().execute(new GFacWorker(pc));
} catch (GFacException e) {
log.info("[EJM]: Error while running output tasks", e);