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 2019/06/03 04:48:20 UTC
[airavata] branch master updated: Minor logging improvements
This is an automated email from the ASF dual-hosted git repository.
dimuthuupe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/airavata.git
The following commit(s) were added to refs/heads/master by this push:
new c45222f Minor logging improvements
c45222f is described below
commit c45222f979bf063214ce881ae835ebf69be9c5a9
Author: Dimuthu Wannipurage <di...@gmail.com>
AuthorDate: Mon Jun 3 00:48:06 2019 -0400
Minor logging improvements
---
.../airavata/helix/impl/task/staging/JobVerificationTask.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/staging/JobVerificationTask.java b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/staging/JobVerificationTask.java
index b878392..249e550 100644
--- a/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/staging/JobVerificationTask.java
+++ b/modules/airavata-helix/helix-spectator/src/main/java/org/apache/airavata/helix/impl/task/staging/JobVerificationTask.java
@@ -63,7 +63,12 @@ public class JobVerificationTask extends AiravataTask {
if (jobMonitorOutput.getExitCode() == 0) {
JobStatus jobStatus = jobManagerConfiguration.getParser().parseJobStatus(job.getJobId(), jobMonitorOutput.getStdOut());
- logger.info("Status of job id " + job.getJobId() + " " + jobStatus.getJobState());
+ if (jobStatus != null) {
+ logger.info("Status of job id " + job.getJobId() + " " + jobStatus.getJobState());
+ } else {
+ logger.info("Status for job " + job.getJobId() + " is not available. Ignoring");
+ break;
+ }
if (jobStatus.getJobState() == JobState.ACTIVE ||
jobStatus.getJobState() == JobState.QUEUED ||
jobStatus.getJobState() == JobState.SUBMITTED) {