airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From shame...@apache.org
Subject [40/42] airavata git commit: updated process status to cancelling with cron job cancelling task
Date Wed, 13 Jan 2016 17:03:17 GMT
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 <shameerainfo@gmail.com>
Authored: Wed Jan 13 11:02:40 2016 -0500
Committer: Shameera Rathnayaka <shameerainfo@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);


Mime
View raw message