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 <[email protected]>
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) {
