diff --git a/apps-integration-tests/integration-tests-jobs-service/integration-tests-jobs-service-quarkus/integration-tests-jobs-service-quarkus-embedded/pom.xml b/apps-integration-tests/integration-tests-jobs-service/integration-tests-jobs-service-quarkus/integration-tests-jobs-service-quarkus-embedded/pom.xml index b1656f477c..72383b29ad 100644 --- a/apps-integration-tests/integration-tests-jobs-service/integration-tests-jobs-service-quarkus/integration-tests-jobs-service-quarkus-embedded/pom.xml +++ b/apps-integration-tests/integration-tests-jobs-service/integration-tests-jobs-service-quarkus/integration-tests-jobs-service-quarkus-embedded/pom.xml @@ -37,11 +37,6 @@ org.kie kogito-addons-quarkus-jobs-service-embedded - - org.jbpm - jbpm-quarkus - true - org.apache.kie.sonataflow sonataflow-quarkus @@ -119,4 +114,4 @@ - \ No newline at end of file + diff --git a/apps-integration-tests/integration-tests-jobs-service/integration-tests-jobs-service-quarkus/integration-tests-jobs-service-quarkus-knative-eventing/pom.xml b/apps-integration-tests/integration-tests-jobs-service/integration-tests-jobs-service-quarkus/integration-tests-jobs-service-quarkus-knative-eventing/pom.xml index 2067360419..309ff02dcb 100644 --- a/apps-integration-tests/integration-tests-jobs-service/integration-tests-jobs-service-quarkus/integration-tests-jobs-service-quarkus-knative-eventing/pom.xml +++ b/apps-integration-tests/integration-tests-jobs-service/integration-tests-jobs-service-quarkus/integration-tests-jobs-service-quarkus-knative-eventing/pom.xml @@ -37,10 +37,6 @@ org.kie kogito-addons-quarkus-jobs-knative-eventing - - org.jbpm - jbpm-quarkus - org.apache.kie.sonataflow sonataflow-quarkus @@ -106,4 +102,4 @@ - \ No newline at end of file + diff --git a/apps-integration-tests/integration-tests-jobs-service/integration-tests-jobs-service-quarkus/integration-tests-jobs-service-quarkus-management/pom.xml b/apps-integration-tests/integration-tests-jobs-service/integration-tests-jobs-service-quarkus/integration-tests-jobs-service-quarkus-management/pom.xml index 826aced81a..ade7cbe17e 100644 --- a/apps-integration-tests/integration-tests-jobs-service/integration-tests-jobs-service-quarkus/integration-tests-jobs-service-quarkus-management/pom.xml +++ b/apps-integration-tests/integration-tests-jobs-service/integration-tests-jobs-service-quarkus/integration-tests-jobs-service-quarkus-management/pom.xml @@ -37,10 +37,6 @@ org.kie kogito-addons-quarkus-jobs-management - - org.jbpm - jbpm-quarkus - org.apache.kie.sonataflow sonataflow-quarkus @@ -109,4 +105,4 @@ - \ No newline at end of file + 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();