You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kie.apache.org by fj...@apache.org on 2024/05/14 15:37:11 UTC
(incubator-kie-kogito-runtimes) branch main updated: [Fix #3513] Different jsonnode instance for parent and children process (#3514)
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-runtimes.git
The following commit(s) were added to refs/heads/main by this push:
new 0359cebfff [Fix #3513] Different jsonnode instance for parent and children process (#3514)
0359cebfff is described below
commit 0359cebfff03a8ed9f8b186a578ab0bd72c08ba2
Author: Francisco Javier Tirado Sarti <65...@users.noreply.github.com>
AuthorDate: Tue May 14 17:37:05 2024 +0200
[Fix #3513] Different jsonnode instance for parent and children process (#3514)
---
.../kie/kogito/serverless/workflow/models/JsonNodeModel.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/kogito-serverless-workflow/kogito-serverless-workflow-runtime/src/main/java/org/kie/kogito/serverless/workflow/models/JsonNodeModel.java b/kogito-serverless-workflow/kogito-serverless-workflow-runtime/src/main/java/org/kie/kogito/serverless/workflow/models/JsonNodeModel.java
index 72b8c8145f..fd7596ec6e 100644
--- a/kogito-serverless-workflow/kogito-serverless-workflow-runtime/src/main/java/org/kie/kogito/serverless/workflow/models/JsonNodeModel.java
+++ b/kogito-serverless-workflow/kogito-serverless-workflow-runtime/src/main/java/org/kie/kogito/serverless/workflow/models/JsonNodeModel.java
@@ -82,22 +82,22 @@ public class JsonNodeModel implements Model, MapInput, MapInputId, MapOutput, Ma
@Override
public void update(Map<String, Object> params) {
- update(params, w -> w);
+ update(params, w -> w instanceof JsonNode ? ((JsonNode) w).deepCopy() : JsonObjectUtils.fromValue(w));
}
@Override
public Map<String, Object> updatePartially(Map<String, Object> params) {
- update(params, w -> MergeUtils.merge(w, this.workflowdata));
+ update(params, w -> MergeUtils.merge(JsonObjectUtils.fromValue(w), this.workflowdata));
return toMap();
}
- private void update(Map<String, Object> params, Function<JsonNode, JsonNode> merger) {
+ private void update(Map<String, Object> params, Function<Object, JsonNode> merger) {
if (params.containsKey(SWFConstants.DEFAULT_WORKFLOW_VAR)) {
params = mutableMap(params);
- this.workflowdata = merger.apply(JsonObjectUtils.fromValue(params.remove(SWFConstants.DEFAULT_WORKFLOW_VAR)));
+ this.workflowdata = merger.apply(params.remove(SWFConstants.DEFAULT_WORKFLOW_VAR));
this.additionalProperties = params;
} else {
- this.workflowdata = merger.apply(JsonObjectUtils.fromValue(params));
+ this.workflowdata = merger.apply(params);
this.additionalProperties = Collections.emptyMap();
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@kie.apache.org
For additional commands, e-mail: commits-help@kie.apache.org