You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2021/12/10 15:45:18 UTC

[incubator-streampipes] branch dev updated: [hotfix] Fix single selection in third party tests

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

zehnder 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 0161e08  [hotfix] Fix single selection in third party tests
0161e08 is described below

commit 0161e0822f0c11e2243cca599e00d3d3623dab06
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Fri Dec 10 16:45:07 2021 +0100

    [hotfix] Fix single selection in third party tests
---
 ui/cypress/tests/thirdparty/Kafka.smoke.spec.ts | 4 ++--
 ui/cypress/tests/thirdparty/Mqtt.smoke.spec.ts  | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/ui/cypress/tests/thirdparty/Kafka.smoke.spec.ts b/ui/cypress/tests/thirdparty/Kafka.smoke.spec.ts
index 3a673bd..8db6f1a 100644
--- a/ui/cypress/tests/thirdparty/Kafka.smoke.spec.ts
+++ b/ui/cypress/tests/thirdparty/Kafka.smoke.spec.ts
@@ -33,7 +33,7 @@ describe('Test Kafka Integration', () => {
     const port: string = ParameterUtils.get('9094', '9092');
 
     const sink: PipelineElementInput = PipelineElementBuilder.create('kafka_publisher')
-      .addInput('select', 'Unauthenticated', 'check')
+      .addInput('select', 'access-mode-unauthenticated', 'check')
         .addInput('input', 'host', host)
       .addInput('input', 'port', '{backspace}{backspace}{backspace}{backspace}' + port)
       .addInput('input', 'topic', topicName)
@@ -43,7 +43,7 @@ describe('Test Kafka Integration', () => {
       .create('Apache_Kafka')
       .setName('Kafka4')
       .setTimestampProperty('timestamp')
-      .addProtocolInput('select', 'Unauthenticated', 'check')
+      .addProtocolInput('select', 'access-mode-unauthenticated', 'check')
         .addProtocolInput('input', 'host', host)
         .addProtocolInput('input', 'port', port)
       .addProtocolInput('click', 'sp-reload', '')
diff --git a/ui/cypress/tests/thirdparty/Mqtt.smoke.spec.ts b/ui/cypress/tests/thirdparty/Mqtt.smoke.spec.ts
index 0de5a1c..0dc2ac2 100644
--- a/ui/cypress/tests/thirdparty/Mqtt.smoke.spec.ts
+++ b/ui/cypress/tests/thirdparty/Mqtt.smoke.spec.ts
@@ -41,7 +41,7 @@ describe('Test MQTT Integration', () => {
       .create('MQTT')
       .setName('Adapter Mqtt')
       .setTimestampProperty('timestamp')
-      .addProtocolInput('select', 'Unauthenticated', 'check')
+      .addProtocolInput('select', 'access-mode-unauthenticated', 'check')
       .addProtocolInput('input', 'broker_url', 'tcp://' + host + ':1883')
       .addProtocolInput('input', 'topic', topicName)
       .setFormat('json_object')