airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From scnakand...@apache.org
Subject [4/8] airavata git commit: fixed taskcontext issue
Date Mon, 14 Dec 2015 16:27:16 GMT
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/f28ea2a0
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/f28ea2a0
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/f28ea2a0

Branch: refs/heads/master
Commit: f28ea2a0c7d8f8f6e0bf186db6fa83b29a855ac0
Parents: a5ae2f2
Author: Shameera Rathnayaka <shameerainfo@gmail.com>
Authored: Wed Nov 11 17:01:37 2015 -0500
Committer: scnakandala <supun.nakandala@gmail.com>
Committed: Mon Dec 14 11:18:01 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/f28ea2a0/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 db6b2ab..38fcfdf 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
@@ -336,7 +336,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());


Mime
View raw message