Revision 40094
Added by Michele Artini over 8 years ago
| UpdateWfStatusJobNode.java | ||
|---|---|---|
| 2 | 2 |
|
| 3 | 3 |
import javax.annotation.Resource; |
| 4 | 4 |
|
| 5 |
import com.googlecode.sarasvati.Arc; |
|
| 6 |
import com.googlecode.sarasvati.NodeToken; |
|
| 7 | 5 |
import eu.dnetlib.enabling.is.registry.rmi.ISRegistryService; |
| 8 | 6 |
import eu.dnetlib.enabling.locators.UniqueServiceLocator; |
| 7 |
import eu.dnetlib.msro.workflows.graph.Arc; |
|
| 8 |
import eu.dnetlib.msro.workflows.graph.Env; |
|
| 9 | 9 |
import eu.dnetlib.msro.workflows.nodes.SimpleJobNode; |
| 10 | 10 |
import eu.dnetlib.msro.workflows.util.WorkflowsConstants; |
| 11 | 11 |
import eu.dnetlib.msro.workflows.util.WorkflowsConstants.WorkflowStatus; |
| ... | ... | |
| 16 | 16 |
private UniqueServiceLocator serviceLocator; |
| 17 | 17 |
|
| 18 | 18 |
@Override |
| 19 |
protected String execute(final NodeToken token) throws Exception {
|
|
| 20 |
final String wfId = token.getFullEnv().getAttribute("WORKFLOW_ID");
|
|
| 21 |
final String dsId = token.getFullEnv().getAttribute(WorkflowsConstants.DATASOURCE_ID);
|
|
| 22 |
final String ifaceId = token.getFullEnv().getAttribute(WorkflowsConstants.DATASOURCE_INTERFACE);
|
|
| 19 |
protected String execute(final Env env) throws Exception {
|
|
| 20 |
final String wfId = env.getAttribute("WORKFLOW_ID", String.class);
|
|
| 21 |
final String dsId = env.getAttribute(WorkflowsConstants.DATASOURCE_ID, String.class);
|
|
| 22 |
final String ifaceId = env.getAttribute(WorkflowsConstants.DATASOURCE_INTERFACE, String.class);
|
|
| 23 | 23 |
|
| 24 | 24 |
updateDatasource(dsId, ifaceId); |
| 25 | 25 |
|
Also available in: Unified diff
partial reimplementation of the wf engine