yujunjun/OpenMetadata
1
0
Fork 0
mirror of https://github.com/open-metadata/OpenMetadata.git synced 2025-09-01 05:03:10 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore(test): ingestion playwright flakiness (#18051)

Browse Source
This commit is contained in:
Chirag Madlani 2024-10-01 16:06:21 +05:30 committed by GitHub
parent 2260857f10
commit 2a06f602e8
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
4 changed files with 20 additions and 31 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
openmetadata-ui/src/main/resources/ui/playwright/support/entity/ingestion/MySqlIngestionClass.ts
View File

@ -125,14 +125,8 @@ class MysqlIngestionClass extends ServiceBaseClass {
) )
.then((res) => res.json()); .then((res) => res.json());
// Re-deploy before running the ingestion
await page.click(
`[data-row-key*="${response.data[0].name}"] [data-testid="more-actions"]`
);
await page.getByTestId('re-deploy-button').click();
// need manual wait to settle down the deployed pipeline, before triggering the pipeline // need manual wait to settle down the deployed pipeline, before triggering the pipeline
await page.waitForTimeout(2000); await page.waitForTimeout(3000);
await page.click( await page.click(
`[data-row-key*="${response.data[0].name}"] [data-testid="more-actions"]` `[data-row-key*="${response.data[0].name}"] [data-testid="more-actions"]`
@ -141,6 +135,9 @@ class MysqlIngestionClass extends ServiceBaseClass {
await toastNotification(page, `Pipeline triggered successfully!`); await toastNotification(page, `Pipeline triggered successfully!`);
// need manual wait to make sure we are awaiting on latest run results
await page.waitForTimeout(2000);
await this.handleIngestionRetry('profiler', page); await this.handleIngestionRetry('profiler', page);
}); });

11
openmetadata-ui/src/main/resources/ui/playwright/support/entity/ingestion/PostgresIngestionClass.ts
View File

@ -131,14 +131,8 @@ class PostgresIngestionClass extends ServiceBaseClass {
) )
.then((res) => res.json()); .then((res) => res.json());
// Re-deploy before running the ingestion
await page.click(
`[data-row-key*="${response.data[0].name}"] [data-testid="more-actions"]`
);
await page.getByTestId('re-deploy-button').click();
// need manual wait to settle down the deployed pipeline, before triggering the pipeline // need manual wait to settle down the deployed pipeline, before triggering the pipeline
await page.waitForTimeout(2000); await page.waitForTimeout(3000);
await page.click( await page.click(
`[data-row-key*="${response.data[0].name}"] [data-testid="more-actions"]` `[data-row-key*="${response.data[0].name}"] [data-testid="more-actions"]`
); );
@ -147,6 +141,9 @@ class PostgresIngestionClass extends ServiceBaseClass {
await toastNotification(page, `Pipeline triggered successfully!`); await toastNotification(page, `Pipeline triggered successfully!`);
// need manual wait to make sure we are awaiting on latest run results
await page.waitForTimeout(2000);
await this.handleIngestionRetry('usage', page); await this.handleIngestionRetry('usage', page);
}); });

11
openmetadata-ui/src/main/resources/ui/playwright/support/entity/ingestion/RedshiftWithDBTIngestionClass.ts
View File

@ -153,14 +153,8 @@ class RedshiftWithDBTIngestionClass extends ServiceBaseClass {
) )
.then((res) => res.json()); .then((res) => res.json());
// Re-deploy before running the ingestion
await page.click(
`[data-row-key*="${response.data[0].name}"] [data-testid="more-actions"]`
);
await page.getByTestId('re-deploy-button').click();
// need manual wait to settle down the deployed pipeline, before triggering the pipeline // need manual wait to settle down the deployed pipeline, before triggering the pipeline
await page.waitForTimeout(2000); await page.waitForTimeout(3000);
await page.click( await page.click(
`[data-row-key*="${response.data[0].name}"] [data-testid="more-actions"]` `[data-row-key*="${response.data[0].name}"] [data-testid="more-actions"]`
); );
@ -168,6 +162,9 @@ class RedshiftWithDBTIngestionClass extends ServiceBaseClass {
await toastNotification(page, `Pipeline triggered successfully!`); await toastNotification(page, `Pipeline triggered successfully!`);
// need manual wait to make sure we are awaiting on latest run results
await page.waitForTimeout(2000);
await this.handleIngestionRetry('dbt', page); await this.handleIngestionRetry('dbt', page);
}); });

18
openmetadata-ui/src/main/resources/ui/playwright/support/entity/ingestion/ServiceBaseClass.ts
View File

@ -177,18 +177,17 @@ class ServiceBaseClass {
.getByTestId('loader') .getByTestId('loader')
.waitFor({ state: 'detached' }); .waitFor({ state: 'detached' });
// Re-deploy before running the ingestion
await page.getByTestId('more-actions').first().click();
await page.getByTestId('re-deploy-button').click();
// need manual wait to settle down the deployed pipeline, before triggering the pipeline // need manual wait to settle down the deployed pipeline, before triggering the pipeline
await page.waitForTimeout(2000); await page.waitForTimeout(3000);
await page.getByTestId('more-actions').first().click(); await page.getByTestId('more-actions').first().click();
await page.getByTestId('run-button').click(); await page.getByTestId('run-button').click();
await toastNotification(page, `Pipeline triggered successfully!`); await toastNotification(page, `Pipeline triggered successfully!`);
// need manual wait to make sure we are awaiting on latest run results
await page.waitForTimeout(2000);
await this.handleIngestionRetry('metadata', page); await this.handleIngestionRetry('metadata', page);
} }
@ -444,18 +443,17 @@ class ServiceBaseClass {
.getByRole('cell', { name: 'Pause Logs' }) .getByRole('cell', { name: 'Pause Logs' })
.waitFor({ state: 'visible' }); .waitFor({ state: 'visible' });
// Re-deploy before running the ingestion
await page.getByTestId('more-actions').first().click();
await page.getByTestId('re-deploy-button').click();
// need manual wait to settle down the deployed pipeline, before triggering the pipeline // need manual wait to settle down the deployed pipeline, before triggering the pipeline
await page.waitForTimeout(2000); await page.waitForTimeout(3000);
await page.getByTestId('more-actions').first().click(); await page.getByTestId('more-actions').first().click();
await page.getByTestId('run-button').click(); await page.getByTestId('run-button').click();
await toastNotification(page, `Pipeline triggered successfully!`); await toastNotification(page, `Pipeline triggered successfully!`);
// need manual wait to make sure we are awaiting on latest run results
await page.waitForTimeout(2000);
// Wait for success // Wait for success
await this.handleIngestionRetry('metadata', page); await this.handleIngestionRetry('metadata', page);