Revision 56132
Added by Alessia Bardi almost 5 years ago
| modules/dnet-openaireplus-workflows/trunk/src/main/java/eu/dnetlib/msro/openaireplus/workflows/nodes/IncrementalOperationJobNode.java | ||
|---|---|---|
| 59 | 59 |
final Iterator<Map<String, String>> iter = dnetLogger.find(WorkflowsConstants.SYSTEM_WF_PROFILE_ID, profId); |
| 60 | 60 |
while (iter.hasNext()) {
|
| 61 | 61 |
final Map<String, String> map = iter.next(); |
| 62 |
log.debug("Iterating on the logs");
|
|
| 63 | 62 |
if ("true".equalsIgnoreCase(map.get(WorkflowsConstants.SYSTEM_COMPLETED_SUCCESSFULLY))) {
|
| 64 | 63 |
final long curr = NumberUtils.toLong(map.get(WorkflowsConstants.SYSTEM_END_DATE), -1); |
| 65 | 64 |
if (curr > res) {
|
| ... | ... | |
| 67 | 66 |
} |
| 68 | 67 |
} |
| 69 | 68 |
} |
| 69 |
log.debug("D-Net logger says the last success end date was on "+res);
|
|
| 70 | 70 |
return res; |
| 71 | 71 |
} |
| 72 | 72 |
|
Also available in: Unified diff
logs