diff --git a/src/main/java/org/gcube/dataanalysis/executor/job/management/QueueJobManager.java b/src/main/java/org/gcube/dataanalysis/executor/job/management/QueueJobManager.java index b2b74b4..173fcb0 100644 --- a/src/main/java/org/gcube/dataanalysis/executor/job/management/QueueJobManager.java +++ b/src/main/java/org/gcube/dataanalysis/executor/job/management/QueueJobManager.java @@ -441,6 +441,7 @@ public class QueueJobManager { */ ScopeProvider.instance.set(scope); + ExecutorPlugin runExecutorPlugin = new ExecutorPlugin(); SmartExecutorPluginQuery runQuery = new SmartExecutorPluginQuery(runExecutorPlugin); @@ -453,7 +454,7 @@ public class QueueJobManager { SpecificEndpointDiscoveryFilter sedf = new SpecificEndpointDiscoveryFilter(selectedEPR); runQuery.setEndpointDiscoveryFilter(sedf); SmartExecutorProxy proxy = new ProxyBuilderImpl(runExecutorPlugin, runQuery).build(); - + AnalysisLogger.getLogger().debug("Launching Smart Executor in namely Scope: "+scope+" real scope "+ScopeProvider.instance.get()); LaunchParameter launchParameter = new LaunchParameter(pluginName, inputs); String excecutionIdentifier = proxy.launch(launchParameter); tasksProxies.add(new WorkerWatcher(proxy, excecutionIdentifier, AnalysisLogger.getLogger()));