(streampipes) branch dev updated: fix(#3097): Avoid that pipeline element version gets lost (#3107)

[ri...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

riemer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/streampipes.git


The following commit(s) were added to refs/heads/dev by this push:
     new 0c19ec12ff fix(#3097): Avoid that pipeline element version gets lost (#3107)
0c19ec12ff is described below

commit 0c19ec12ff4dfb232ae5b53f8f66f4604048ab44
Author: Dominik Riemer <do...@gmail.com>
AuthorDate: Mon Aug 5 16:10:18 2024 +0200

    fix(#3097): Avoid that pipeline element version gets lost (#3107)
---
 .../java/org/apache/streampipes/model/graph/DataProcessorInvocation.java | 1 +
 .../main/java/org/apache/streampipes/model/graph/DataSinkInvocation.java | 1 +
 2 files changed, 2 insertions(+)

diff --git a/streampipes-model/src/main/java/org/apache/streampipes/model/graph/DataProcessorInvocation.java b/streampipes-model/src/main/java/org/apache/streampipes/model/graph/DataProcessorInvocation.java
index 23c651074a..4414f2b749 100644
--- a/streampipes-model/src/main/java/org/apache/streampipes/model/graph/DataProcessorInvocation.java
+++ b/streampipes-model/src/main/java/org/apache/streampipes/model/graph/DataProcessorInvocation.java
@@ -56,6 +56,7 @@ public class DataProcessorInvocation extends InvocableStreamPipesEntity implemen
     this.setIncludedAssets(other.getIncludedAssets());
     this.setIncludedLocales(other.getIncludedLocales());
     this.setElementId(ElementIdGenerator.makeElementId(this));
+    this.setVersion(other.getVersion());
     this.serviceTagPrefix = SpServiceTagPrefix.DATA_PROCESSOR;
   }
 
diff --git a/streampipes-model/src/main/java/org/apache/streampipes/model/graph/DataSinkInvocation.java b/streampipes-model/src/main/java/org/apache/streampipes/model/graph/DataSinkInvocation.java
index a7df9500fd..bc95f269c9 100644
--- a/streampipes-model/src/main/java/org/apache/streampipes/model/graph/DataSinkInvocation.java
+++ b/streampipes-model/src/main/java/org/apache/streampipes/model/graph/DataSinkInvocation.java
@@ -53,6 +53,7 @@ public class DataSinkInvocation extends InvocableStreamPipesEntity {
     this.setElementId(ElementIdGenerator.makeElementId(this));
     this.setIncludedAssets(other.getIncludedAssets());
     this.setIncludedLocales(other.getIncludedLocales());
+    this.setVersion(other.getVersion());
     this.serviceTagPrefix = SpServiceTagPrefix.DATA_SINK;
   }