diff --git a/src/main/java/com/iexec/core/task/listener/TaskListeners.java b/src/main/java/com/iexec/core/task/listener/TaskListeners.java index 1f38db785..6dbb9c226 100644 --- a/src/main/java/com/iexec/core/task/listener/TaskListeners.java +++ b/src/main/java/com/iexec/core/task/listener/TaskListeners.java @@ -52,6 +52,7 @@ public void onTaskContributionTimeout(ContributionTimeoutEvent event) { List workerAddresses = new ArrayList<>(); for (Replicate replicate : replicatesService.getReplicates(chainTaskId)) { workerAddresses.add(replicate.getWalletAddress()); + workerService.removeChainTaskIdFromWorker(chainTaskId, replicate.getWalletAddress()); } notificationService.sendTaskNotification(TaskNotification.builder()