Revision 52040
Added by Alessia Bardi almost 6 years ago
| modules/dnet-msro-service/trunk/src/main/java/eu/dnetlib/msro/workflows/nodes/mdstore/FetchMDStoreRecordsJobNode.java | ||
|---|---|---|
| 51 | 51 |
token.getEnv().setAttribute(WorkflowsConstants.MAIN_LOG_PREFIX + "sourceSize", size); |
| 52 | 52 |
log.info(String.format("getting MDRecords from: %s, sourceSize: %s", getMdId(), size));
|
| 53 | 53 |
|
| 54 |
final W3CEndpointReference epr = mdStoreService.deliverMDRecords(getMdId(), dateFromFilter != null ? "" + dateFromFilter : "", "", ""); |
|
| 54 |
final String from = dateFromFilter != null ? "" + dateFromFilter : ""; |
|
| 55 |
final W3CEndpointReference epr = mdStoreService.deliverMDRecords(getMdId(), from, "", ""); |
|
| 55 | 56 |
if (epr == null) { throw new MSROException("unable to read MDRecords from: " + getMdId()); }
|
| 56 | 57 |
token.getEnv().setAttribute(getEprParam(), epr.toString()); |
| 57 | 58 |
return Arc.DEFAULT_ARC; |
Also available in: Unified diff
On Claudio's request Sandro's variable has been extracted