Revision 40096
Added by Michele Artini over 8 years ago
| ScheduledWorkflowLauncher.java | ||
|---|---|---|
| 7 | 7 |
import eu.dnetlib.enabling.is.lookup.rmi.ISLookUpService; |
| 8 | 8 |
import eu.dnetlib.enabling.locators.UniqueServiceLocator; |
| 9 | 9 |
import eu.dnetlib.miscutils.datetime.DateUtils; |
| 10 |
import eu.dnetlib.msro.workflows.graph.Process; |
|
| 11 |
import eu.dnetlib.msro.workflows.graph.ProcessRegistry; |
|
| 12 | 10 |
import eu.dnetlib.msro.workflows.graph.WorkflowExecutor; |
| 11 |
import eu.dnetlib.msro.workflows.procs.ProcessRegistry; |
|
| 12 |
import eu.dnetlib.msro.workflows.procs.WorkflowProcess; |
|
| 13 | 13 |
import org.apache.commons.lang.StringUtils; |
| 14 | 14 |
import org.apache.commons.lang.math.NumberUtils; |
| 15 | 15 |
import org.apache.commons.logging.Log; |
| ... | ... | |
| 103 | 103 |
|
| 104 | 104 |
// TODO: it should be already implemented in WorkflowExecutor |
| 105 | 105 |
private boolean isAlreadyRunning(final String wfId) {
|
| 106 |
for (final Process p : processRegistry.findProcsByOtherId(wfId)) {
|
|
| 106 |
for (final WorkflowProcess p : processRegistry.findProcsByOtherId(wfId)) {
|
|
| 107 | 107 |
switch (p.getStatus()) {
|
| 108 | 108 |
case CREATED: |
| 109 | 109 |
return true; |
Also available in: Unified diff
partial reimplementation of the wf engine