This is an automated email from the ASF dual-hosted git repository.
dhanak pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/incubator-kie-kogito-apps.git
The following commit(s) were added to refs/heads/main by this push:
new 1291fa3fe [incubator-kie-issues-1324] Live reload does not work for KN
CLI plugin (#2074)
1291fa3fe is described below
commit 1291fa3fe8c79eac857f6cfb0d2cb5ac27ef29c6
Author: Dmitrii Tikhomirov <[email protected]>
AuthorDate: Thu Jul 11 23:28:26 2024 -0700
[incubator-kie-issues-1324] Live reload does not work for KN CLI plugin
(#2074)
---
.../kie/kogito/jobs/service/management/JobServiceInstanceManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 5261170c5..fea4350a0 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 @@ public class JobServiceInstanceManager {
}
protected Uni<Void> 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();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
