Revision 53015
Added by Alessia Bardi over 5 years ago
| StoreMDStoreRecordsJobNode.java | ||
|---|---|---|
| 15 | 15 |
import eu.dnetlib.msro.workflows.util.ProgressProvider; |
| 16 | 16 |
import eu.dnetlib.msro.workflows.util.ResultsetProgressProvider; |
| 17 | 17 |
import eu.dnetlib.msro.workflows.util.WorkflowsConstants; |
| 18 |
import org.apache.commons.lang3.StringUtils; |
|
| 18 | 19 |
import org.apache.commons.logging.Log; |
| 19 | 20 |
import org.apache.commons.logging.LogFactory; |
| 20 | 21 |
import org.springframework.beans.factory.annotation.Required; |
| ... | ... | |
| 43 | 44 |
this.progressProvider = processCountingResultSetFactory.createProgressProvider(token.getProcess(), eprS); |
| 44 | 45 |
|
| 45 | 46 |
final String overrideStoringType = token.getFullEnv().getAttribute("operationType");
|
| 46 |
|
|
| 47 |
if (StringUtils.isNotBlank(overrideStoringType)) {
|
|
| 48 |
token.getFullEnv().setAttribute("storingType", overrideStoringType);
|
|
| 49 |
setStoringType(overrideStoringType); |
|
| 50 |
} |
|
| 47 | 51 |
job.getParameters().put("epr", progressProvider.getEpr().toString());
|
| 48 |
job.getParameters().put("storingType", overrideStoringType!= null? overrideStoringType: getStoringType());
|
|
| 52 |
job.getParameters().put("storingType", getStoringType());
|
|
| 49 | 53 |
job.getParameters().put("mdId", getMdId());
|
| 50 | 54 |
} |
| 51 | 55 |
|
Also available in: Unified diff
Override the value of storingType so that its value is consistent with the operationType param, when available.