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 <[email protected]> Authored: Thu Nov 13 14:29:47 2014 -0500 Committer: raminder <[email protected]> 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) {
