You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by sh...@apache.org on 2015/11/11 23:01:41 UTC
airavata git commit: fixed taskcontext issue
Repository: airavata
Updated Branches:
refs/heads/develop 30d230c44 -> 6aaea39d1
fixed taskcontext issue
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/6aaea39d
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/6aaea39d
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/6aaea39d
Branch: refs/heads/develop
Commit: 6aaea39d12aec2ffc8d969ebaa5eccd90aaa7f2f
Parents: 30d230c
Author: Shameera Rathnayaka <sh...@gmail.com>
Authored: Wed Nov 11 17:01:37 2015 -0500
Committer: Shameera Rathnayaka <sh...@gmail.com>
Committed: Wed Nov 11 17:01:37 2015 -0500
----------------------------------------------------------------------
.../main/java/org/apache/airavata/gfac/impl/GFacEngineImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/6aaea39d/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/GFacEngineImpl.java
----------------------------------------------------------------------
diff --git a/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/GFacEngineImpl.java b/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/GFacEngineImpl.java
index 96d3302..d59f460 100644
--- a/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/GFacEngineImpl.java
+++ b/modules/gfac/gfac-impl/src/main/java/org/apache/airavata/gfac/impl/GFacEngineImpl.java
@@ -289,7 +289,7 @@ public class GFacEngineImpl implements GFacEngine {
.add(ExpCatChildDataType.TASK, streamingTaskModel, processContext.getProcessId());
streamingTaskModel.setTaskId(streamTaskId);
streamingTaskContext.setTaskModel(streamingTaskModel);
- executeDataStreaming(taskContext, processContext.isRecovery());
+ executeDataStreaming(streamingTaskContext, processContext.isRecovery());
}
} catch (URISyntaxException | TException | RegistryException e) {
log.error("Error while streaming output " + output.getValue());