diff --git a/jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/management/JobServiceInstanceManager.java b/jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/management/JobServiceInstanceManager.java index 5261170c51..fea4350a02 100644 --- a/jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/management/JobServiceInstanceManager.java +++ b/jobs-service/jobs-service-common/src/main/java/org/kie/kogito/jobs/service/management/JobServiceInstanceManager.java @@ -173,9 +173,9 @@ protected Uni tryBecomeLeader(JobServiceManagementInfo } protected Uni release(JobServiceManagementInfo info) { + leader.set(false); return repository.set(new JobServiceManagementInfo(info.getId(), null, null)) .onItem().invoke(this::disableCommunication) - .onItem().invoke(i -> leader.set(false)) .onItem().invoke(i -> LOGGER.info("Leader instance released")) .onFailure().invoke(ex -> LOGGER.error("Error releasing leader")) .replaceWithVoid();