(streampipes) branch dev updated: fix: Pipeline id in start all pipelines, retention serialization (#4560)

[riemer]

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

dominikriemer 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 e2750309e6 fix: Pipeline id in start all pipelines, retention 
serialization (#4560)
e2750309e6 is described below

commit e2750309e62d29e7558429c9f8a3a826488015c3
Author: Dominik Riemer <dominik.rie...@gmail.com>
AuthorDate: Mon Jun 15 11:07:51 2026 +0200

    fix: Pipeline id in start all pipelines, retention serialization (#4560)
---
 .../model/datalake/RetentionExportConfig.java         |  6 +++++-
 .../start-all-pipelines-dialog.component.ts           | 19 +++++++++++--------
 2 files changed, 16 insertions(+), 9 deletions(-)

diff --git 
a/streampipes-model/src/main/java/org/apache/streampipes/model/datalake/RetentionExportConfig.java
 
b/streampipes-model/src/main/java/org/apache/streampipes/model/datalake/RetentionExportConfig.java
index 3e71ccc3f6..03db2add25 100644
--- 
a/streampipes-model/src/main/java/org/apache/streampipes/model/datalake/RetentionExportConfig.java
+++ 
b/streampipes-model/src/main/java/org/apache/streampipes/model/datalake/RetentionExportConfig.java
@@ -31,6 +31,10 @@ public class RetentionExportConfig {
     private String lastExport;
     private List<RetentionLog> retentionLog = new ArrayList<>();
 
+    public RetentionExportConfig() {
+
+    }
+
     public RetentionExportConfig(ExportConfig exportConfig, String 
exportProviderId, String lastExport,
             List<RetentionLog> retentionLog) {
         this.exportConfig = exportConfig;
@@ -92,4 +96,4 @@ public class RetentionExportConfig {
         }
     }
 
-}
\ No newline at end of file
+}
diff --git 
a/ui/src/app/pipelines/dialog/start-all-pipelines/start-all-pipelines-dialog.component.ts
 
b/ui/src/app/pipelines/dialog/start-all-pipelines/start-all-pipelines-dialog.component.ts
index 87f931e397..12674fb576 100644
--- 
a/ui/src/app/pipelines/dialog/start-all-pipelines/start-all-pipelines-dialog.component.ts
+++ 
b/ui/src/app/pipelines/dialog/start-all-pipelines/start-all-pipelines-dialog.component.ts
@@ -18,7 +18,10 @@
 
 import { Component, inject, Input, OnInit } from '@angular/core';
 import { DialogRef } from '@streampipes/shared-ui';
-import { Pipeline, PipelineService } from '@streampipes/platform-services';
+import {
+    PipelineService,
+    PipelineSummaryDto,
+} from '@streampipes/platform-services';
 import { TranslatePipe, TranslateService } from '@ngx-translate/core';
 import { FlexDirective } from '@ngbracket/ngx-layout/flex';
 import { MatDivider } from '@angular/material/divider';
@@ -31,12 +34,12 @@ import { MatButton } from '@angular/material/button';
 })
 export class StartAllPipelinesDialogComponent implements OnInit {
     @Input()
-    pipelines: Pipeline[];
+    pipelines: PipelineSummaryDto[];
 
     @Input()
     forceStop = false;
 
-    pipelinesToModify: Pipeline[];
+    pipelinesToModify: PipelineSummaryDto[];
     installationStatus: any;
     installationFinished: boolean;
     page: string;
@@ -93,7 +96,7 @@ export class StartAllPipelinesDialogComponent implements 
OnInit {
         });
     }
 
-    initiateInstallation(pipeline, index) {
+    initiateInstallation(pipeline: PipelineSummaryDto, index) {
         this.installationRunning = true;
         this.installationStatus.push({
             name: pipeline.name,
@@ -107,9 +110,9 @@ export class StartAllPipelinesDialogComponent implements 
OnInit {
         }
     }
 
-    startPipeline(pipeline, index) {
+    startPipeline(pipeline: PipelineSummaryDto, index) {
         this.pipelineService
-            .startPipeline(pipeline._id)
+            .startPipeline(pipeline.elementId)
             .subscribe(
                 data => {
                     this.installationStatus[index].status = data.success
@@ -134,9 +137,9 @@ export class StartAllPipelinesDialogComponent implements 
OnInit {
             });
     }
 
-    stopPipeline(pipeline, index) {
+    stopPipeline(pipeline: PipelineSummaryDto, index) {
         this.pipelineService
-            .stopPipeline(pipeline._id, this.forceStop)
+            .stopPipeline(pipeline.elementId, this.forceStop)
             .subscribe(
                 data => {
                     this.installationStatus[index].status = data.success