Revision 40101
Added by Michele Artini over 8 years ago
| WorkflowExecutor.java | ||
|---|---|---|
| 87 | 87 |
final String name = doc.valueOf("//WORKFLOW_NAME");
|
| 88 | 88 |
final String family = doc.valueOf("//WORKFLOW_FAMILY");
|
| 89 | 89 |
final int priority = NumberUtils.toInt("//WORKFLOW_PRIORITY", WorkflowsConstants.DEFAULT_WF_PRIORITY);
|
| 90 |
final boolean isReady = doc.selectNodes("//PARAM[@required='true' and string-length(normalize-space(.)) = 0]").isEmpty();
|
|
| 90 |
final boolean isReady = doc.valueOf("//CONFIGURATION/@status").equals(WorkflowsConstants.WorkflowStatus.EXECUTABLE.toString());
|
|
| 91 |
final boolean isDisabled = doc.valueOf("//CONFIGURATION/@start").equals("disabled");
|
|
| 91 | 92 |
|
| 92 | 93 |
if (isPaused()) {
|
| 93 | 94 |
log.warn("Wf " + profileId + " not launched, because WorkflowExecutor is preparing for shutdown");
|
| 94 | 95 |
throw new MSROException("WorkflowExecutor is preparing for shutdown");
|
| 95 | 96 |
} |
| 96 |
if (isReady) {
|
|
| 97 |
if (!isReady) {
|
|
| 97 | 98 |
log.warn("Wf " + profileId + " not launched, because it is not ready to start");
|
| 98 | 99 |
throw new MSROException("Workflow " + profileId + " is not ready to start");
|
| 99 | 100 |
} |
Also available in: Unified diff
partial reimplementation of the wf engine