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 <[email protected]> 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
