This is an automated email from the ASF dual-hosted git repository.
fjtiradosarti 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 c3b36c424 [Fix apache/incubator-kie-issues#987] Update state to error
(#2011)
c3b36c424 is described below
commit c3b36c424d9855b654ab65dd6a198e1500dcec28
Author: Francisco Javier Tirado Sarti
<[email protected]>
AuthorDate: Thu Mar 7 10:44:58 2024 +0100
[Fix apache/incubator-kie-issues#987] Update state to error (#2011)
---
.../src/main/java/org/kie/kogito/index/CommonUtils.java | 1 +
.../index/storage/merger/ProcessInstanceErrorDataEventMerger.java | 2 ++
.../org/kie/kogito/index/jpa/storage/ProcessInstanceEntityStorage.java | 2 ++
3 files changed, 5 insertions(+)
diff --git
a/data-index/data-index-common/src/main/java/org/kie/kogito/index/CommonUtils.java
b/data-index/data-index-common/src/main/java/org/kie/kogito/index/CommonUtils.java
index ba47c72d4..3bc4b724d 100644
---
a/data-index/data-index-common/src/main/java/org/kie/kogito/index/CommonUtils.java
+++
b/data-index/data-index-common/src/main/java/org/kie/kogito/index/CommonUtils.java
@@ -22,6 +22,7 @@ import java.util.Set;
public class CommonUtils {
+ public static final int ERROR_STATE = 5;
private static final Set<String> finalStates = Set.of("Completed",
"Aborted");
public static boolean isTaskCompleted(String status) {
diff --git
a/data-index/data-index-storage/data-index-storage-common/src/main/java/org/kie/kogito/index/storage/merger/ProcessInstanceErrorDataEventMerger.java
b/data-index/data-index-storage/data-index-storage-common/src/main/java/org/kie/kogito/index/storage/merger/ProcessInstanceErrorDataEventMerger.java
index 87b656643..3408a7247 100644
---
a/data-index/data-index-storage/data-index-storage-common/src/main/java/org/kie/kogito/index/storage/merger/ProcessInstanceErrorDataEventMerger.java
+++
b/data-index/data-index-storage/data-index-storage-common/src/main/java/org/kie/kogito/index/storage/merger/ProcessInstanceErrorDataEventMerger.java
@@ -20,6 +20,7 @@ package org.kie.kogito.index.storage.merger;
import org.kie.kogito.event.process.ProcessInstanceDataEvent;
import org.kie.kogito.event.process.ProcessInstanceErrorDataEvent;
+import org.kie.kogito.index.CommonUtils;
import org.kie.kogito.index.model.ProcessInstance;
import org.kie.kogito.index.model.ProcessInstanceError;
@@ -36,6 +37,7 @@ public class ProcessInstanceErrorDataEventMerger extends
ProcessInstanceEventMer
error.setMessage(event.getData().getErrorMessage());
error.setNodeDefinitionId(event.getData().getNodeDefinitionId());
pi.setError(error);
+ pi.setState(CommonUtils.ERROR_STATE);
return pi;
}
diff --git
a/data-index/data-index-storage/data-index-storage-jpa-common/src/main/java/org/kie/kogito/index/jpa/storage/ProcessInstanceEntityStorage.java
b/data-index/data-index-storage/data-index-storage-jpa-common/src/main/java/org/kie/kogito/index/jpa/storage/ProcessInstanceEntityStorage.java
index 5ea98dda3..386aabcf7 100644
---
a/data-index/data-index-storage/data-index-storage-jpa-common/src/main/java/org/kie/kogito/index/jpa/storage/ProcessInstanceEntityStorage.java
+++
b/data-index/data-index-storage/data-index-storage-jpa-common/src/main/java/org/kie/kogito/index/jpa/storage/ProcessInstanceEntityStorage.java
@@ -33,6 +33,7 @@ import
org.kie.kogito.event.process.ProcessInstanceStateDataEvent;
import org.kie.kogito.event.process.ProcessInstanceStateEventBody;
import org.kie.kogito.event.process.ProcessInstanceVariableDataEvent;
import org.kie.kogito.event.process.ProcessInstanceVariableEventBody;
+import org.kie.kogito.index.CommonUtils;
import org.kie.kogito.index.jpa.mapper.ProcessInstanceEntityMapper;
import org.kie.kogito.index.jpa.model.MilestoneEntity;
import org.kie.kogito.index.jpa.model.NodeInstanceEntity;
@@ -116,6 +117,7 @@ public class ProcessInstanceEntityStorage extends
AbstractJPAStorageFetcher<Stri
}
errorEntity.setMessage(error.getErrorMessage());
errorEntity.setNodeDefinitionId(error.getNodeDefinitionId());
+ pi.setState(CommonUtils.ERROR_STATE);
repository.flush();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
