[incubator-streampipes] branch dev updated: [STREAMPIPES-529] Filter pipelines for availability of measurement schema

[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/incubator-streampipes.git


The following commit(s) were added to refs/heads/dev by this push:
     new 2070ad5c2 [STREAMPIPES-529] Filter pipelines for availability of measurement schema
2070ad5c2 is described below

commit 2070ad5c2f06140933de4ca302199ac5f6bb2d2d
Author: Dominik Riemer <do...@gmail.com>
AuthorDate: Mon Apr 11 21:27:28 2022 +0200

    [STREAMPIPES-529] Filter pipelines for availability of measurement schema
---
 .../dialogs/add-widget/add-visualization-dialog.component.ts      | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/ui/src/app/dashboard/dialogs/add-widget/add-visualization-dialog.component.ts b/ui/src/app/dashboard/dialogs/add-widget/add-visualization-dialog.component.ts
index 9ec6155af..2f6b97726 100644
--- a/ui/src/app/dashboard/dialogs/add-widget/add-visualization-dialog.component.ts
+++ b/ui/src/app/dashboard/dialogs/add-widget/add-visualization-dialog.component.ts
@@ -127,14 +127,18 @@ export class AddVisualizationDialogComponent implements OnInit, AfterViewInit {
   loadVisualizablePipelines() {
     zip(this.dataExplorerService.getAllPersistedDataStreams(), this.dataLakeRestService.getAllMeasurementSeries())
       .subscribe(res => {
+        const availableVisualizablePipelines = [];
         const visualizablePipelines = res[0];
         visualizablePipelines.forEach(p => {
           const measurement = res[1].find(m => {
             return m.measureName === p.measureName;
           });
-          p.eventSchema = measurement.eventSchema;
+          if (measurement) {
+            p.eventSchema = measurement.eventSchema;
+            availableVisualizablePipelines.push(p);
+          }
         });
-        this.visualizablePipelines = this.sortPipeline(visualizablePipelines);
+        this.visualizablePipelines = this.sortPipeline(availableVisualizablePipelines);
       });
   }