Revision 46679
Added by Michele Artini about 7 years ago
MsroWorkerController.java | ||
---|---|---|
26 | 26 |
import eu.dnetlib.msro.workers.aggregation.collect.plugins.DnetCollectorParam; |
27 | 27 |
import eu.dnetlib.msro.workers.aggregation.collect.plugins.DnetCollectorPlugin; |
28 | 28 |
import eu.dnetlib.msro.workers.aggregation.collect.plugins.ProtocolParameterType; |
29 |
import eu.dnetlib.msro.workflows.ProcessStatus; |
|
29 | 30 |
import eu.dnetlib.msro.workflows.WorkflowInstance; |
30 | 31 |
import eu.dnetlib.msro.workflows.nodes.AbstractParallelProcessNode; |
31 | 32 |
import eu.dnetlib.msro.workflows.procs.ProcessRegistry; |
32 | 33 |
import eu.dnetlib.msro.workflows.procs.WorkflowExecutor; |
33 |
import eu.dnetlib.msro.workflows.procs.WorkflowProcess.Status; |
|
34 | 34 |
import eu.dnetlib.msro.workflows.util.NodeHelper; |
35 | 35 |
import eu.dnetlib.services.BaseService; |
36 | 36 |
import eu.dnetlib.services.ServiceRunningInstance; |
... | ... | |
126 | 126 |
processRegistry.listTerminated() |
127 | 127 |
.stream() |
128 | 128 |
.limit(MAX_NUMBER_OF_TERMINATED_WFS) |
129 |
.map(wf -> new TerminatedWfDesc(wf.getId(), wf.getStatus() == Status.SUCCESS, wf.getEndDate())) |
|
129 |
.map(wf -> new TerminatedWfDesc(wf.getId(), wf.getStatus() == ProcessStatus.SUCCESS, wf.getEndDate()))
|
|
130 | 130 |
.collect(Collectors.toList())); |
131 | 131 |
} |
132 | 132 |
|
Also available in: Unified diff
moved some classes/enum in common