[incubator-streampipes] branch STREAMPIPES-545 updated: [hotfix] Mark pipeline elements without configuration as complete

[ri...@apache.org]

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

riemer pushed a commit to branch STREAMPIPES-545
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git


The following commit(s) were added to refs/heads/STREAMPIPES-545 by this push:
     new e3e27f03b [hotfix] Mark pipeline elements without configuration as complete
e3e27f03b is described below

commit e3e27f03bcb4308372e12f919d75821776d461fe
Author: Dominik Riemer <do...@gmail.com>
AuthorDate: Mon Aug 1 22:38:14 2022 +0200

    [hotfix] Mark pipeline elements without configuration as complete
---
 .../app/editor/components/pipeline/pipeline.component.ts  | 15 +++++++++------
 1 file changed, 9 insertions(+), 6 deletions(-)

diff --git a/ui/src/app/editor/components/pipeline/pipeline.component.ts b/ui/src/app/editor/components/pipeline/pipeline.component.ts
index bcc269025..719eefa4f 100644
--- a/ui/src/app/editor/components/pipeline/pipeline.component.ts
+++ b/ui/src/app/editor/components/pipeline/pipeline.component.ts
@@ -338,8 +338,9 @@ export class PipelineComponent implements OnInit, OnDestroy {
                   this.showCustomizeDialog(pe);
                 } else {
                   (pe.payload as InvocablePipelineElementUnion).configured = true;
-                  this.pipelineStyleService.updatePeConfigurationStatus(pe, PipelineElementConfigurationStatus.INCOMPLETE);
+                  this.pipelineStyleService.updatePeConfigurationStatus(pe, PipelineElementConfigurationStatus.OK);
                   this.announceConfiguredElement(pe);
+                  this.triggerPipelineCacheUpdate();
                 }
               }
             } else {
@@ -408,11 +409,13 @@ export class PipelineComponent implements OnInit, OnDestroy {
 
   isCustomOutput(pe) {
     let custom = false;
-    pe.payload.outputStrategies.forEach(strategy => {
-      if (strategy instanceof CustomOutputStrategy) {
-        custom = true;
-      }
-    });
+    if (pe.payload instanceof DataProcessorInvocation) {
+      pe.payload.outputStrategies.forEach(strategy => {
+        if (strategy instanceof CustomOutputStrategy) {
+          custom = true;
+        }
+      });
+    }
     return custom;
   }