Skip to content

Commit 46fc4bf

Browse files
author
Laurent Gougeon
committed
If the data retrieval is failing allow retrying with dedicated option.
1 parent 64299bb commit 46fc4bf

File tree

1 file changed

+7
-1
lines changed

1 file changed

+7
-1
lines changed

src/main/java/ecmwf/ecpds/master/MasterServer.java

+7-1
Original file line numberDiff line numberDiff line change
@@ -73,6 +73,7 @@
7373
import static ecmwf.common.ectrans.ECtransOptions.HOST_ACQUISITION_REQUEUEON;
7474
import static ecmwf.common.ectrans.ECtransOptions.HOST_ACQUISITION_REQUEUEONSAMESIZE;
7575
import static ecmwf.common.ectrans.ECtransOptions.HOST_ACQUISITION_REQUEUEONUPDATE;
76+
import static ecmwf.common.ectrans.ECtransOptions.HOST_ACQUISITION_REQUEUE_ON_FAILURE;
7677
import static ecmwf.common.ectrans.ECtransOptions.HOST_ACQUISITION_SERVER_LANGUAGE_CODE;
7778
import static ecmwf.common.ectrans.ECtransOptions.HOST_ACQUISITION_SERVER_TIME_ZONE_ID;
7879
import static ecmwf.common.ectrans.ECtransOptions.HOST_ACQUISITION_SHORT_MONTH_NAMES;
@@ -10951,7 +10952,12 @@ public void configurableRun() {
1095110952
// otherwise it would be retried (the FAIL
1095210953
// status will be set in the Transfer
1095310954
// Scheduler)!
10954-
currentStatus = StatusFactory.RETR;
10955+
if (HOST_ACQUISITION.getECtransSetup(_source.getData())
10956+
.getBoolean(HOST_ACQUISITION_REQUEUE_ON_FAILURE)) {
10957+
currentStatus = StatusFactory.SCHE;
10958+
} else {
10959+
currentStatus = StatusFactory.RETR;
10960+
}
1095510961
} else if (Cnf.at("Other", "dontRetryDownloads", false)) {
1095610962
// We don't want to retry the download of the
1095710963
// files which are not on the super computer any

0 commit comments

Comments
 (0)