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 2022/02/25 11:36:53 UTC
[incubator-streampipes] branch dev updated: [hotfix] Fix experimental e2e 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 d712c88 [hotfix] Fix experimental e2e tests
d712c88 is described below
commit d712c88ecc21b6538a9be44b85ac646a7cfa8be0
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Fri Feb 25 12:36:43 2022 +0100
[hotfix] Fix experimental e2e tests
---
.../experimental/restartStreamPipes/restartStreamPipes1.ts | 4 ++--
.../experimental/restartStreamPipes/restartStreamPipes2.ts | 12 ++++++++++++
.../tests/experimental/testJvmArchetype/testJvmArchetype.ts | 4 ++--
3 files changed, 16 insertions(+), 4 deletions(-)
diff --git a/ui/cypress/tests/experimental/restartStreamPipes/restartStreamPipes1.ts b/ui/cypress/tests/experimental/restartStreamPipes/restartStreamPipes1.ts
index a3a53f1..b051ef4 100644
--- a/ui/cypress/tests/experimental/restartStreamPipes/restartStreamPipes1.ts
+++ b/ui/cypress/tests/experimental/restartStreamPipes/restartStreamPipes1.ts
@@ -36,8 +36,8 @@ describe('Prepare StreamPipes for restart test', () => {
const pipelineInput = PipelineBuilder.create(pipelineName)
.addSource(adapterName)
.addSink(
- PipelineElementBuilder.create('dashboard_sink')
- .addInput('input', 'visualization-name', 'Demo')
+ PipelineElementBuilder.create('data_lake')
+ .addInput('input', 'db_measurement', 'demo')
.build())
.build();
diff --git a/ui/cypress/tests/experimental/restartStreamPipes/restartStreamPipes2.ts b/ui/cypress/tests/experimental/restartStreamPipes/restartStreamPipes2.ts
index 0afacaf..253870e 100644
--- a/ui/cypress/tests/experimental/restartStreamPipes/restartStreamPipes2.ts
+++ b/ui/cypress/tests/experimental/restartStreamPipes/restartStreamPipes2.ts
@@ -17,6 +17,7 @@
*/
import { DashboardUtils } from '../../../support/utils/DashboardUtils';
+import { DataLakeUtils } from '../../../support/utils/DataLakeUtils';
describe('Validate StreamPipes after restart', () => {
beforeEach('Setup Test', () => {
@@ -24,11 +25,22 @@ describe('Validate StreamPipes after restart', () => {
});
it('Perform Test', () => {
+ // Truncate data in db
+ DataLakeUtils.goToDatalakeConfiguration();
+ cy.dataCy('datalake-truncate-btn')
+ .should('be.visible')
+ .click();
+ cy.dataCy('confirm-truncate-data-btn', { timeout: 10000 })
+ .should('be.visible')
+ .click();
+
// open dashboard
DashboardUtils.goToDashboard();
DashboardUtils.showDashboard('testDashboard');
+ cy.wait(6000);
+
// validate that data is coming
DashboardUtils.validateRawWidgetEvents(3);
});
diff --git a/ui/cypress/tests/experimental/testJvmArchetype/testJvmArchetype.ts b/ui/cypress/tests/experimental/testJvmArchetype/testJvmArchetype.ts
index 8f0c6d6..12533b8 100644
--- a/ui/cypress/tests/experimental/testJvmArchetype/testJvmArchetype.ts
+++ b/ui/cypress/tests/experimental/testJvmArchetype/testJvmArchetype.ts
@@ -41,8 +41,8 @@ describe('Prepare StreamPipes for archetype test', () => {
.addInput('input', 'example-key', 'newField')
.build())
.addSink(
- PipelineElementBuilder.create('dashboard_sink')
- .addInput('input', 'visualization-name', 'Demo')
+ PipelineElementBuilder.create('data_lake')
+ .addInput('input', 'db_measurement', 'demo')
.build())
.build();