gCubeSystem
/
smart-executor-client
16
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

refs #579: Use Persistence to persist Scheduled Task configuration on smart-executor 

https://support.d4science.org/issues/579

Substituted argument "String pluginName" with "PluginDeclaration pluginDeclaration"

git-svn-id: https://svn.d4science.research-infrastructures.eu/gcube/trunk/vre-management/smart-executor-client@119437 82a268e6-3cf1-43bd-a215-b396298e98cf
This commit is contained in:
Luca Frosini 2015-10-06 12:32:07 +00:00
parent 8b19ae097b
commit 3d7bd2746f
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/org/gcube/vremanagement/executor/client/proxies/DefaultSmartExecutorProxy.java
View File

@ -14,6 +14,7 @@ import org.gcube.vremanagement.executor.exception.InputsNullException;
import org.gcube.vremanagement.executor.exception.LaunchException;
import org.gcube.vremanagement.executor.exception.PluginInstanceNotFoundException;
import org.gcube.vremanagement.executor.exception.PluginNotFoundException;
import org.gcube.vremanagement.executor.plugin.PluginDeclaration;
import org.gcube.vremanagement.executor.plugin.PluginState;
import org.quartz.SchedulerException;
import org.slf4j.Logger;
@ -126,14 +127,14 @@ public class DefaultSmartExecutorProxy implements SmartExecutorProxy {
/** {@inheritDoc} */
@Override
public PluginState getState(final String pluginName, final String executionIdentifier)
public PluginState getState(final PluginDeclaration pluginDeclaration, final String executionIdentifier)
throws PluginInstanceNotFoundException, ExecutorException {
Call<SmartExecutor, PluginState> call = new Call<SmartExecutor, PluginState>() {
@Override
public PluginState call(SmartExecutor endpoint) throws Exception {
logger.debug("Calling getState() function");
return endpoint.getState(pluginName, executionIdentifier);
return endpoint.getState(pluginDeclaration, executionIdentifier);
}
};
@ -148,14 +149,14 @@ public class DefaultSmartExecutorProxy implements SmartExecutorProxy {
/** {@inheritDoc} */
@Override
public PluginState getIterationState(final String pluginName, final String executionIdentifier, final int iterationNumber)
public PluginState getIterationState(final PluginDeclaration pluginDeclaration, final String executionIdentifier, final int iterationNumber)
throws PluginInstanceNotFoundException, ExecutorException {
Call<SmartExecutor, PluginState> call = new Call<SmartExecutor, PluginState>() {
@Override
public PluginState call(SmartExecutor endpoint) throws Exception {
logger.debug("Calling getState() function");
return endpoint.getIterationState(pluginName, executionIdentifier, iterationNumber);
return endpoint.getIterationState(pluginDeclaration, executionIdentifier, iterationNumber);
}
};