Working on [Project Activity #11690] Execute Data Miner processes from Workspace

git-svn-id: http://svn.research-infrastructures.eu/public/d4science/gcube/trunk/Common/workspace-task-executor-library@167239 82a268e6-3cf1-43bd-a215-b396298e98cf
This commit is contained in:
Francesco Mangiacrapa 2018-04-26 10:38:33 +00:00
parent 0e33d32f8f
commit 063842ad48
3 changed files with 104 additions and 6 deletions

View File

@ -11,20 +11,20 @@ import org.gcube.common.workspacetaskexecutor.shared.ItemNotExecutable;
*
* @author Francesco Mangiacrapa francesco.mangiacrapa@isti.cnr.it
* Apr 26, 2018
* @param <I> the generic type
*/
public interface ConfigurableTask {
public interface ConfigurableTask<I> {
/**
* Removes the task config.
*
* @param config the config
* @param workspaceItemId the workspace item id
* @return the boolean
* @throws ItemNotExecutable the item not executable
* @throws Exception the exception
*/
Boolean removeTaskConfig(TaskConfiguration config) throws ItemNotExecutable, Exception;
Boolean removeTaskConfig(String workspaceItemId) throws ItemNotExecutable, Exception;
/**
@ -35,5 +35,5 @@ public interface ConfigurableTask {
* @throws ItemNotExecutable the item not executable
* @throws Exception the exception
*/
Boolean addTaskConfig(TaskConfiguration config) throws ItemNotExecutable, Exception;
Boolean addTaskConfig(I config) throws ItemNotExecutable, Exception;
}

View File

@ -0,0 +1,98 @@
package org.gcube.common.workspacetaskexecutor.dataminer;
import org.gcube.common.workspacetaskexecutor.CheckableTask;
import org.gcube.common.workspacetaskexecutor.ConfigurableTask;
import org.gcube.common.workspacetaskexecutor.ExecutableTask;
import org.gcube.common.workspacetaskexecutor.shared.ItemNotExecutable;
import org.gcube.common.workspacetaskexecutor.shared.dataminer.AlgorithmConfiguration;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
// TODO: Auto-generated Javadoc
/**
* The Class WorkspaceThreddsSynchronize.
*
* @author Francesco Mangiacrapa francesco.mangiacrapa@isti.cnr.it
* Feb 14, 2018
*/
public class WorkspaceDataMinerTaskExecute implements ExecutableTask<AlgorithmConfiguration>, ConfigurableTask<AlgorithmConfiguration>, CheckableTask<AlgorithmConfiguration>{
/** The logger. */
private static Logger logger = LoggerFactory.getLogger(WorkspaceDataMinerTaskExecute.class);
/* (non-Javadoc)
* @see org.gcube.common.workspacetaskexecutor.CheckableTask#checkItemExecutable(java.lang.String)
*/
@Override
public AlgorithmConfiguration checkItemExecutable(String itemId) throws ItemNotExecutable, Exception {
// TODO Auto-generated method stub
return null;
}
/* (non-Javadoc)
* @see org.gcube.common.workspacetaskexecutor.ConfigurableTask#removeTaskConfig(java.lang.Object)
*/
@Override
public Boolean removeTaskConfig(String workspaceItemId) throws ItemNotExecutable, Exception {
// TODO Auto-generated method stub
return null;
}
/* (non-Javadoc)
* @see org.gcube.common.workspacetaskexecutor.ConfigurableTask#addTaskConfig(java.lang.Object)
*/
@Override
public Boolean addTaskConfig(AlgorithmConfiguration config) throws ItemNotExecutable, Exception {
// TODO Auto-generated method stub
return null;
}
/* (non-Javadoc)
* @see org.gcube.common.workspacetaskexecutor.ExecutableTask#doRun(java.lang.String)
*/
@Override
public AlgorithmConfiguration doRun(String itemId)
throws ItemNotExecutable, Exception {
// TODO Auto-generated method stub
return null;
}
/* (non-Javadoc)
* @see org.gcube.common.workspacetaskexecutor.ExecutableTask#stopRun(java.lang.String)
*/
@Override
public Boolean stopRun(String itemId)
throws ItemNotExecutable, Exception {
// TODO Auto-generated method stub
return null;
}
/* (non-Javadoc)
* @see org.gcube.common.workspacetaskexecutor.ExecutableTask#monitorRunStatus(java.lang.String)
*/
@Override
public AlgorithmConfiguration monitorRunStatus(String itemId)
throws ItemNotExecutable, Exception {
// TODO Auto-generated method stub
return null;
}
/* (non-Javadoc)
* @see org.gcube.common.workspacetaskexecutor.ExecutableTask#registerCallbackForId(java.lang.String)
*/
@Override
public void registerCallbackForId(String itemId)
throws Exception {
// TODO Auto-generated method stub
}
}

View File

@ -2,7 +2,7 @@
*
*/
package org.gcube.common.workspacetaskexecutor.shared.homelibrary;
package org.gcube.common.workspacetaskexecutor.shared.dataminer;
import java.io.Serializable;
import java.util.Map;