Repository: airavata Updated Branches: refs/heads/master 538e37f0e -> b19a8e06d refs/heads/messaging_framework dcc647ebc -> 8a8a02b88
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/messaging_framework Commit: 722de6d1fe5eea90bad2ccf9815e4cb28e633274 Parents: f29d7e6 Author: Chathuri Wimalasena <[email protected]> Authored: Mon Aug 11 15:44:15 2014 -0400 Committer: Chathuri Wimalasena <[email protected]> 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));
