Project

General

Profile

« Previous | Next » 

Revision 46679

moved some classes/enum in common

View differences:

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