[STREAMPIPES-529] Filter pipelines for availability of measurement sc…

…hema
HelenParr · Apr 11, 2022 · 2070ad5 · 2070ad5
1 parent d26d88e
commit 2070ad5
Showing 1 changed file with 6 additions and 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
@@ -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);
       });
   }