From da5ee5cbb22f81b946f1dd3825059bfa95cc418f Mon Sep 17 00:00:00 2001 From: Gianpaolo Coro Date: Tue, 20 Oct 2015 10:51:25 +0000 Subject: [PATCH] git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/data-analysis/EcologicalEngineSmartExecutor@119881 82a268e6-3cf1-43bd-a215-b396298e98cf --- .../dataanalysis/executor/job/management/QueueJobManager.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) 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()));