You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by ch...@apache.org on 2014/08/11 21:44:24 UTC
git commit: fixing build issue in tests
Repository: airavata
Updated Branches:
refs/heads/master f29d7e66a -> 722de6d1f
fixing build issue in tests
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/722de6d1
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/722de6d1
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/722de6d1
Branch: refs/heads/master
Commit: 722de6d1fe5eea90bad2ccf9815e4cb28e633274
Parents: f29d7e6
Author: Chathuri Wimalasena <ka...@gmail.com>
Authored: Mon Aug 11 15:44:15 2014 -0400
Committer: Chathuri Wimalasena <ka...@gmail.com>
Committed: Mon Aug 11 15:44:15 2014 -0400
----------------------------------------------------------------------
.../airavata/gfac/local/provider/impl/LocalProvider.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/722de6d1/modules/gfac/gfac-local/src/main/java/org/apache/airavata/gfac/local/provider/impl/LocalProvider.java
----------------------------------------------------------------------
diff --git a/modules/gfac/gfac-local/src/main/java/org/apache/airavata/gfac/local/provider/impl/LocalProvider.java b/modules/gfac/gfac-local/src/main/java/org/apache/airavata/gfac/local/provider/impl/LocalProvider.java
index 514f901..9672767 100644
--- a/modules/gfac/gfac-local/src/main/java/org/apache/airavata/gfac/local/provider/impl/LocalProvider.java
+++ b/modules/gfac/gfac-local/src/main/java/org/apache/airavata/gfac/local/provider/impl/LocalProvider.java
@@ -225,8 +225,10 @@ public class LocalProvider extends AbstractProvider {
Map<String, Object> output = jobExecutionContext.getOutMessageContext().getParameters();
OutputUtils.fillOutputFromStdout(output, stdOutStr, stdErrStr, outputArray);
TaskDetails taskDetails = (TaskDetails)registry.get(RegistryModelType.TASK_DETAIL, jobExecutionContext.getTaskData().getTaskID());
- taskDetails.setApplicationOutputs(outputArray);
- registry.update(RegistryModelType.TASK_DETAIL, taskDetails, taskDetails.getTaskID());
+ if (taskDetails != null){
+ taskDetails.setApplicationOutputs(outputArray);
+ registry.update(RegistryModelType.TASK_DETAIL, taskDetails, taskDetails.getTaskID());
+ }
registry.add(ChildDataType.EXPERIMENT_OUTPUT, outputArray, jobExecutionContext.getExperimentID());
MonitorID monitorId = createMonitorID(jobExecutionContext);
getMonitorPublisher().publish(new TaskOutputDataChangedEvent(new TaskIdentity(monitorId.getExperimentID(), monitorId.getWorkflowNodeID(), monitorId.getTaskID()), outputArray));