You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by di...@apache.org on 2018/04/05 19:42:46 UTC
[airavata] branch develop updated: Handling Failed jobs
This is an automated email from the ASF dual-hosted git repository.
dimuthuupe pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/airavata.git
The following commit(s) were added to refs/heads/develop by this push:
new 66750af Handling Failed jobs
66750af is described below
commit 66750afae72be1cfe6d9574c3229dbed2f4858fe
Author: dimuthu <di...@gmail.com>
AuthorDate: Thu Apr 5 15:42:40 2018 -0400
Handling Failed jobs
---
.../apache/airavata/helix/impl/workflow/PostWorkflowManager.java | 9 ++++-----
1 file changed, 4 insertions(+), 5 deletions(-)
diff --git a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/workflow/PostWorkflowManager.java b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/workflow/PostWorkflowManager.java
index 39c857b..c8a3f8d 100644
--- a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/workflow/PostWorkflowManager.java
+++ b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/workflow/PostWorkflowManager.java
@@ -200,7 +200,9 @@ public class PostWorkflowManager extends WorkflowManager {
// TODO to be implemented
} else {
- if (jobStatusResult.getState() == JobState.COMPLETE) {
+ if (jobStatusResult.getState() == JobState.COMPLETE || jobStatusResult.getState() == JobState.FAILED) {
+ // if the job is FAILED, still run output staging tasks to debug the reason for failure. And update
+ // the experiment status as COMPLETED as this job failure is not related to Airavata scope.
logger.info("Starting the post workflow for job id : " + jobStatusResult.getJobId() + " with process id "
+ processId + ", gateway " + gateway + " and status " + jobStatusResult.getState().name());
@@ -286,10 +288,7 @@ public class PostWorkflowManager extends WorkflowManager {
}
} else if (jobStatusResult.getState() == JobState.CANCELED) {
logger.info("Job " + jobStatusResult.getJobId() + " was externally cancelled");
-
- } else if (jobStatusResult.getState() == JobState.FAILED) {
- logger.info("Job " + jobStatusResult.getJobId() + " was failed.");
-
+ //
} else if (jobStatusResult.getState() == JobState.SUBMITTED) {
logger.info("Job " + jobStatusResult.getJobId() + " was submitted");
--
To stop receiving notification emails like this one, please contact
dimuthuupe@apache.org.