(streampipes) 01/01: Fix pipeline id in start all pipelines, retention serialization

[ri...@apache.org]

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

dominikriemer pushed a commit to branch fix-retention-serialization
in repository https://gitbox.apache.org/repos/asf/streampipes.git

commit a7a35857dfd7d9d0bc2039a03f98ff977a0c72a6
Author: Dominik Riemer <do...@gmail.com>
AuthorDate: Mon Jun 15 09:22:34 2026 +0200

    Fix pipeline id in start all pipelines, retention serialization
---
 .../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