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/04/01 22:20:10 UTC
airavata git commit: Save job model on error
Repository: airavata
Updated Branches:
refs/heads/develop cfee70c32 -> 6b4960809
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/develop
Commit: 6b4960809334c745b76d6af16787c035e9e3f096
Parents: cfee70c
Author: Shameera Rathnayaka <sh...@gmail.com>
Authored: Fri Apr 1 16:20:03 2016 -0400
Committer: Shameera Rathnayaka <sh...@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();