Skip to content

Commit 122dca7

Browse files
Merge pull request #177 from iExecBlockchainComputing/dont-ask-replicate-if-unsync-node
Dont ask replicate if unsync node
2 parents acc8186 + 9759ad2 commit 122dca7

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

src/main/java/com/iexec/worker/replicate/ReplicateDemandService.java

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -45,12 +45,18 @@ public ReplicateDemandService(TaskExecutorService taskExecutorService,
4545
@Scheduled(fixedRateString = "#{publicConfigurationService.askForReplicatePeriod}")
4646
public void askForReplicate() {
4747
// check if the worker can run a task or not
48-
long lastAvailableBlockNumber = iexecHubService.getLatestBlockNumber();
49-
if (!taskExecutorService.canAcceptMoreReplicates() && lastAvailableBlockNumber == 0) {
48+
if (!taskExecutorService.canAcceptMoreReplicates()) {
5049
log.info("The worker is already full, it can't accept more tasks");
5150
return;
5251
}
5352

53+
long lastAvailableBlockNumber = iexecHubService.getLatestBlockNumber();
54+
if (lastAvailableBlockNumber == 0) {
55+
log.error("Can't askForReplicate, your blockchain node seams unsync [lastAvailableBlockNumber:{}]",
56+
lastAvailableBlockNumber);
57+
return;
58+
}
59+
5460
Optional<ContributionAuthorization> oContributionAuth =
5561
customFeignClient.getAvailableReplicate(lastAvailableBlockNumber);
5662

0 commit comments

Comments
 (0)