Revision 40096
Added by Michele Artini over 8 years ago
UpdateIndexJobNode.java | ||
---|---|---|
24 | 24 |
import eu.dnetlib.enabling.resultset.rmi.ResultSetException; |
25 | 25 |
import eu.dnetlib.enabling.tools.blackboard.BlackboardJob; |
26 | 26 |
import eu.dnetlib.msro.workflows.graph.Env; |
27 |
import eu.dnetlib.msro.workflows.graph.Process; |
|
28 |
import eu.dnetlib.msro.workflows.graph.ProcessAware; |
|
29 | 27 |
import eu.dnetlib.msro.workflows.nodes.BlackboardJobNode; |
30 | 28 |
import eu.dnetlib.msro.workflows.nodes.ProgressJobNode; |
29 |
import eu.dnetlib.msro.workflows.procs.ProcessAware; |
|
30 |
import eu.dnetlib.msro.workflows.procs.WorkflowProcess; |
|
31 | 31 |
import eu.dnetlib.msro.workflows.resultset.ProcessCountingResultSetFactory; |
32 | 32 |
import eu.dnetlib.msro.workflows.util.ProgressProvider; |
33 | 33 |
import eu.dnetlib.msro.workflows.util.ResultsetProgressProvider; |
... | ... | |
66 | 66 |
@Resource |
67 | 67 |
private UniqueServiceLocator serviceLocator; |
68 | 68 |
|
69 |
private Process process; |
|
69 |
private WorkflowProcess process;
|
|
70 | 70 |
|
71 | 71 |
@Override |
72 | 72 |
protected String obtainServiceId(final Env env) { |
... | ... | |
227 | 227 |
} |
228 | 228 |
|
229 | 229 |
@Override |
230 |
public void setProcess(final Process process) { |
|
230 |
public void setProcess(final WorkflowProcess process) {
|
|
231 | 231 |
this.process = process; |
232 | 232 |
} |
233 | 233 |
} |
Also available in: Unified diff
partial reimplementation of the wf engine