You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by ra...@apache.org on 2014/11/13 20:29:59 UTC
airavata git commit: Cluster was null. Fixed in the branch.
AIRAVATA-1521
Repository: airavata
Updated Branches:
refs/heads/safekeeping a594912ff -> e5e383775
Cluster was null. Fixed in the branch. AIRAVATA-1521
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/e5e38377
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/e5e38377
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/e5e38377
Branch: refs/heads/safekeeping
Commit: e5e38377524a7f4ac20c57824c5447884252ea07
Parents: a594912
Author: raminder <ra...@indiana.edu>
Authored: Thu Nov 13 14:29:47 2014 -0500
Committer: raminder <ra...@indiana.edu>
Committed: Thu Nov 13 14:29:47 2014 -0500
----------------------------------------------------------------------
.../org/apache/airavata/gfac/ssh/handler/SSHInputHandler.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/e5e38377/modules/gfac/gfac-ssh/src/main/java/org/apache/airavata/gfac/ssh/handler/SSHInputHandler.java
----------------------------------------------------------------------
diff --git a/modules/gfac/gfac-ssh/src/main/java/org/apache/airavata/gfac/ssh/handler/SSHInputHandler.java b/modules/gfac/gfac-ssh/src/main/java/org/apache/airavata/gfac/ssh/handler/SSHInputHandler.java
index c279378..c519c79 100644
--- a/modules/gfac/gfac-ssh/src/main/java/org/apache/airavata/gfac/ssh/handler/SSHInputHandler.java
+++ b/modules/gfac/gfac-ssh/src/main/java/org/apache/airavata/gfac/ssh/handler/SSHInputHandler.java
@@ -83,7 +83,8 @@ public class SSHInputHandler extends AbstractHandler {
log.info("Invoking SCPInputHandler");
super.invoke(jobExecutionContext);
-
+ cluster = ((SSHSecurityContext) jobExecutionContext.getSecurityContext(hostAddress)).getPbsCluster();
+
MessageContext input = jobExecutionContext.getInMessageContext();
Set<String> parameters = input.getParameters().keySet();
for (String paramName : parameters) {