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 <[email protected]> Authored: Wed Jan 13 11:02:40 2016 -0500 Committer: Shameera Rathnayaka <[email protected]> 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);
