airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From shame...@apache.org
Subject [07/35] airavata git commit: Save job model on error
Date Sat, 23 Apr 2016 02:00:19 GMT
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 <shameerainfo@gmail.com>
Authored: Fri Apr 1 16:20:03 2016 -0400
Committer: Shameera Rathnayaka <shameerainfo@gmail.com>
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();


Mime
View raw message