Revision 39625
Added by Michele Artini over 8 years ago
ValidateDatasourceJobNode.java | ||
---|---|---|
2 | 2 |
|
3 | 3 |
import javax.annotation.Resource; |
4 | 4 |
|
5 |
import org.apache.commons.logging.Log; |
|
6 |
import org.apache.commons.logging.LogFactory; |
|
7 |
|
|
8 | 5 |
import com.googlecode.sarasvati.Arc; |
9 | 6 |
import com.googlecode.sarasvati.NodeToken; |
10 |
|
|
11 | 7 |
import eu.dnetlib.enabling.is.registry.rmi.ISRegistryException; |
12 | 8 |
import eu.dnetlib.enabling.is.registry.rmi.ISRegistryService; |
13 | 9 |
import eu.dnetlib.enabling.locators.UniqueServiceLocator; |
14 | 10 |
import eu.dnetlib.msro.workflows.nodes.SimpleJobNode; |
15 | 11 |
import eu.dnetlib.msro.workflows.util.WorkflowsConstants; |
12 |
import org.apache.commons.logging.Log; |
|
13 |
import org.apache.commons.logging.LogFactory; |
|
16 | 14 |
|
17 | 15 |
public class ValidateDatasourceJobNode extends SimpleJobNode { |
18 | 16 |
|
17 |
private static final Log log = LogFactory.getLog(ValidateDatasourceJobNode.class); |
|
19 | 18 |
@Resource |
20 | 19 |
private UniqueServiceLocator serviceLocator; |
21 | 20 |
|
22 |
private static final Log log = LogFactory.getLog(ValidateDatasourceJobNode.class); |
|
23 |
|
|
24 | 21 |
@Override |
25 | 22 |
protected String execute(final NodeToken token) throws Exception { |
26 |
String oldId = token.getFullEnv().getAttribute(WorkflowsConstants.DATAPROVIDER_ID);
|
|
23 |
String oldId = token.getFullEnv().getAttribute(WorkflowsConstants.DATASOURCE_ID);
|
|
27 | 24 |
String newId = registerDatasourceWorkflow(oldId); |
28 |
token.getFullEnv().setAttribute(WorkflowsConstants.DATAPROVIDER_ID, newId);
|
|
29 |
token.getEnv().setAttribute(WorkflowsConstants.DATAPROVIDER_ID, newId);
|
|
25 |
token.getFullEnv().setAttribute(WorkflowsConstants.DATASOURCE_ID, newId);
|
|
26 |
token.getEnv().setAttribute(WorkflowsConstants.DATASOURCE_ID, newId);
|
|
30 | 27 |
|
31 | 28 |
log.info("Validated datasource - OLD ID: " + oldId); |
32 | 29 |
log.info("Validated datasource - NEW ID: " + newId); |
Also available in: Unified diff