Revision 60361
Added by Michele Artini over 2 years ago
| modules/dnet-openaireplus-workflows/trunk/src/main/java/eu/dnetlib/msro/openaireplus/workflows/nodes/dhp/SubmitDnetHadoopJobNode.java | ||
|---|---|---|
| 40 | 40 |
private void updateProgressProvider() {
|
| 41 | 41 |
final Message mess = dnetMessageManager.findMessage(wfId); |
| 42 | 42 |
if (mess != null && mess.getBody() != null) {
|
| 43 |
if (mess.getBody().containsKey("current")) {
|
|
| 43 |
if (mess.getBody().containsKey(Message.CURRENT_PARAM)) {
|
|
| 44 | 44 |
try {
|
| 45 |
setCurrentValue(Integer.parseInt(mess.getBody().get("current")));
|
|
| 45 |
setCurrentValue(Integer.parseInt(mess.getBody().get(Message.CURRENT_PARAM)));
|
|
| 46 | 46 |
} catch (final Throwable e) {
|
| 47 | 47 |
log.error("Error parsing value", e);
|
| 48 | 48 |
} |
| 49 | 49 |
} |
| 50 | 50 |
} |
| 51 |
if (mess.getBody().containsKey("total")) {
|
|
| 51 |
if (mess.getBody().containsKey(Message.TOTAL_PARAM)) {
|
|
| 52 | 52 |
try {
|
| 53 |
setTotalValue(Integer.parseInt(mess.getBody().get("total")));
|
|
| 53 |
setTotalValue(Integer.parseInt(mess.getBody().get(Message.TOTAL_PARAM)));
|
|
| 54 | 54 |
setAccurate(true); |
| 55 | 55 |
} catch (final Throwable e) {
|
| 56 | 56 |
log.error("Error parsing value", e);
|
Also available in: Unified diff
constants