diff --git a/src/main/java/org/gcube/vremanagement/executor/SmartExecutorInitializator.java b/src/main/java/org/gcube/vremanagement/executor/SmartExecutorInitializator.java index c85cd7b..b1e3daf 100644 --- a/src/main/java/org/gcube/vremanagement/executor/SmartExecutorInitializator.java +++ b/src/main/java/org/gcube/vremanagement/executor/SmartExecutorInitializator.java @@ -30,6 +30,7 @@ import org.gcube.smartgears.ApplicationManager; import org.gcube.smartgears.ContextProvider; import org.gcube.smartgears.configuration.container.ContainerConfiguration; import org.gcube.vremanagement.executor.api.types.LaunchParameter; +import org.gcube.vremanagement.executor.json.ObjectMapperManager; import org.gcube.vremanagement.executor.persistence.SmartExecutorPersistenceConnector; import org.gcube.vremanagement.executor.persistence.SmartExecutorPersistenceFactory; import org.gcube.vremanagement.executor.plugin.PluginDeclaration; @@ -39,6 +40,8 @@ import org.gcube.vremanagement.executor.scheduler.SmartExecutorScheduler; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +import com.fasterxml.jackson.databind.ObjectMapper; + /** * @author Luca Frosini (ISTI - CNR) * @@ -324,12 +327,19 @@ public class SmartExecutorInitializator implements ApplicationManager { logger.debug("someone else is going to take in charge the scheduled task. Skipping."); continue; } + + final ObjectMapper mapper = ObjectMapperManager.getObjectMapper(); Thread thread = new Thread(){ @Override public void run(){ LaunchParameter launchParameter = scheduledTask.getLaunchParameter(); + try { + logger.info("Going to schedule an already scheduled task with the following parameters {}", mapper.writeValueAsString(launchParameter)); + } catch (Exception e1) { + + } SmartExecutorScheduler smartExecutorScheduler = SmartExecutorScheduler.getInstance();