You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@airavata.apache.org by la...@apache.org on 2014/05/21 17:28:33 UTC
git commit: fixing issue airavata-1185
Repository: airavata
Updated Branches:
refs/heads/master 4f2ca03e3 -> c27266970
fixing issue airavata-1185
Project: http://git-wip-us.apache.org/repos/asf/airavata/repo
Commit: http://git-wip-us.apache.org/repos/asf/airavata/commit/c2726697
Tree: http://git-wip-us.apache.org/repos/asf/airavata/tree/c2726697
Diff: http://git-wip-us.apache.org/repos/asf/airavata/diff/c2726697
Branch: refs/heads/master
Commit: c27266970bcab6b28ee3dd8f38a21736cae2a558
Parents: 4f2ca03
Author: lahiru <la...@apache.org>
Authored: Wed May 21 11:28:19 2014 -0400
Committer: lahiru <la...@apache.org>
Committed: Wed May 21 11:28:19 2014 -0400
----------------------------------------------------------------------
.../apache/airavata/gfac/core/provider/AbstractProvider.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/airavata/blob/c2726697/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/provider/AbstractProvider.java
----------------------------------------------------------------------
diff --git a/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/provider/AbstractProvider.java b/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/provider/AbstractProvider.java
index 5b65185..afc1894 100644
--- a/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/provider/AbstractProvider.java
+++ b/modules/gfac/gfac-core/src/main/java/org/apache/airavata/gfac/core/provider/AbstractProvider.java
@@ -49,7 +49,11 @@ public abstract class AbstractProvider implements GFacProvider{
public void initialize(JobExecutionContext jobExecutionContext) throws GFacProviderException, GFacException {
log.debug("Initializing " + this.getClass().getName());
- registry = RegistryFactory.getDefaultRegistry();
+ if(jobExecutionContext.getRegistry() == null) {
+ registry = RegistryFactory.getDefaultRegistry();
+ }else{
+ registry = jobExecutionContext.getRegistry();
+ }
details = new JobDetails();
status = new JobStatus();
this.jobExecutionContext=jobExecutionContext;