Save job model on error

Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/6b496080
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/6b496080
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/6b496080

Branch: refs/heads/master
Commit: 6b4960809334c745b76d6af16787c035e9e3f096
Parents: cfee70c
Author: Shameera Rathnayaka <[email protected]>
Authored: Fri Apr 1 16:20:03 2016 -0400
Committer: Shameera Rathnayaka <[email protected]>
Committed: Fri Apr 1 16:20:03 2016 -0400

----------------------------------------------------------------------
 .../apache/airavata/gfac/impl/task/DefaultJobSubmissionTask.java    | 1 +
 1 file changed, 1 insertion(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/airavata/blob/6b496080/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/task/DefaultJobSubmissionTask.java
----------------------------------------------------------------------
diff --git 
a/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/task/DefaultJobSubmissionTask.java
 
b/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/task/DefaultJobSubmissionTask.java
index a4be386..b7f150f 100644
--- 
a/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/task/DefaultJobSubmissionTask.java
+++ 
b/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/task/DefaultJobSubmissionTask.java
@@ -94,6 +94,7 @@ public class DefaultJobSubmissionTask implements 
JobSubmissionTask {
                                        if 
(jobSubmissionOutput.isJobSubmissionFailed()) {
                                                jobModel.setJobStatus(new 
JobStatus(JobState.FAILED));
                                                
jobModel.getJobStatus().setReason(jobSubmissionOutput.getFailureReason());
+                                               
GFacUtils.saveJobModel(processContext, jobModel);
                                                log.error("expId: {}, 
processid: {}, taskId: {} :- Job submission failed for job name {}",
                                 experimentId, taskContext.getProcessId(), 
taskContext.getTaskId(), jobModel.getJobName());
                                                ErrorModel errorModel = new 
ErrorModel();

Reply via email to