Skip to content

Commit 1d56278

Browse files
authored
Add missing @Service annotation to new detector (#684)
1 parent 34148bc commit 1d56278

File tree

4 files changed

+6
-3
lines changed

4 files changed

+6
-3
lines changed

CHANGELOG.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ All notable changes to this project will be documented in this file.
66

77
### New Features
88

9-
- Add `ConsensusReachedTaskDetector` to detect missed `TaskConsensus` on-chain events. (#683)
9+
- Add `ConsensusReachedTaskDetector` to detect missed `TaskConsensus` on-chain events. (#683 #684)
1010

1111
### Bug Fixes
1212

src/main/java/com/iexec/core/detector/task/ConsensusReachedTaskDetector.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,11 +24,13 @@
2424
import com.iexec.core.task.update.TaskUpdateRequestManager;
2525
import lombok.extern.slf4j.Slf4j;
2626
import org.springframework.scheduling.annotation.Scheduled;
27+
import org.springframework.stereotype.Service;
2728

2829
import static com.iexec.commons.poco.chain.ChainTaskStatus.REVEALING;
2930
import static com.iexec.core.task.TaskStatus.RUNNING;
3031

3132
@Slf4j
33+
@Service
3234
public class ConsensusReachedTaskDetector implements Detector {
3335

3436
private final IexecHubService iexecHubService;
@@ -46,6 +48,7 @@ public ConsensusReachedTaskDetector(IexecHubService iexecHubService,
4648
@Scheduled(fixedRateString = "#{@cronConfiguration.getConsensusReached()}")
4749
@Override
4850
public void detect() {
51+
log.debug("Trying to detect running tasks with on-chain consensus");
4952
taskService.findByCurrentStatus(RUNNING).stream()
5053
.filter(this::isConsensusReached)
5154
.forEach(this::publishTaskUpdateRequest);

src/main/java/com/iexec/core/detector/task/ContributionTimeoutTaskDetector.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ public ContributionTimeoutTaskDetector(TaskService taskService, ApplicationEvent
4646
@Scheduled(fixedRateString = "#{@cronConfiguration.getContribute()}")
4747
@Override
4848
public void detect() {
49-
log.debug("Detect tasks after contribution deadline");
49+
log.debug("Trying to detect tasks after contribution deadline");
5050
final Instant now = Instant.now();
5151
final Query query = Query.query(Criteria.where("currentStatus").in(TaskStatus.INITIALIZED, TaskStatus.RUNNING)
5252
.and("contributionDeadline").lte(now)

src/main/java/com/iexec/core/detector/task/FinalDeadlineTaskDetector.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -46,7 +46,7 @@ public FinalDeadlineTaskDetector(TaskService taskService, ApplicationEventPublis
4646
@Scheduled(fixedRateString = "#{@cronConfiguration.getFinalDeadline()}")
4747
@Override
4848
public void detect() {
49-
log.debug("Detect tasks after final deadline");
49+
log.debug("Trying to detect tasks after final deadline");
5050
final Query query = Query.query(Criteria.where("currentStatus").nin(TaskStatus.getStatusesWhereFinalDeadlineIsImpossible())
5151
.and("finalDeadline").lte(Instant.now()));
5252
final Update update = Update.update("currentStatus", TaskStatus.FAILED)

0 commit comments

Comments
 (0)