diff --git a/openmetadata-ui/src/main/resources/ui/playwright/support/entity/ingestion/MySqlIngestionClass.ts b/openmetadata-ui/src/main/resources/ui/playwright/support/entity/ingestion/MySqlIngestionClass.ts index a5198ec0071..1a222ae717e 100644 --- a/openmetadata-ui/src/main/resources/ui/playwright/support/entity/ingestion/MySqlIngestionClass.ts +++ b/openmetadata-ui/src/main/resources/ui/playwright/support/entity/ingestion/MySqlIngestionClass.ts @@ -125,14 +125,8 @@ class MysqlIngestionClass extends ServiceBaseClass { ) .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 - await page.waitForTimeout(2000); + await page.waitForTimeout(3000); await page.click( `[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!`); + // need manual wait to make sure we are awaiting on latest run results + await page.waitForTimeout(2000); + await this.handleIngestionRetry('profiler', page); }); diff --git a/openmetadata-ui/src/main/resources/ui/playwright/support/entity/ingestion/PostgresIngestionClass.ts b/openmetadata-ui/src/main/resources/ui/playwright/support/entity/ingestion/PostgresIngestionClass.ts index 1027ea78eac..fcd54f59cff 100644 --- a/openmetadata-ui/src/main/resources/ui/playwright/support/entity/ingestion/PostgresIngestionClass.ts +++ b/openmetadata-ui/src/main/resources/ui/playwright/support/entity/ingestion/PostgresIngestionClass.ts @@ -131,14 +131,8 @@ class PostgresIngestionClass extends ServiceBaseClass { ) .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 - await page.waitForTimeout(2000); + await page.waitForTimeout(3000); await page.click( `[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!`); + // need manual wait to make sure we are awaiting on latest run results + await page.waitForTimeout(2000); + await this.handleIngestionRetry('usage', page); }); diff --git a/openmetadata-ui/src/main/resources/ui/playwright/support/entity/ingestion/RedshiftWithDBTIngestionClass.ts b/openmetadata-ui/src/main/resources/ui/playwright/support/entity/ingestion/RedshiftWithDBTIngestionClass.ts index d4d906de7d9..959a9cdc0de 100644 --- a/openmetadata-ui/src/main/resources/ui/playwright/support/entity/ingestion/RedshiftWithDBTIngestionClass.ts +++ b/openmetadata-ui/src/main/resources/ui/playwright/support/entity/ingestion/RedshiftWithDBTIngestionClass.ts @@ -153,14 +153,8 @@ class RedshiftWithDBTIngestionClass extends ServiceBaseClass { ) .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 - await page.waitForTimeout(2000); + await page.waitForTimeout(3000); await page.click( `[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!`); + // need manual wait to make sure we are awaiting on latest run results + await page.waitForTimeout(2000); + await this.handleIngestionRetry('dbt', page); }); diff --git a/openmetadata-ui/src/main/resources/ui/playwright/support/entity/ingestion/ServiceBaseClass.ts b/openmetadata-ui/src/main/resources/ui/playwright/support/entity/ingestion/ServiceBaseClass.ts index f6d9e8e0f36..2962c525ebf 100644 --- a/openmetadata-ui/src/main/resources/ui/playwright/support/entity/ingestion/ServiceBaseClass.ts +++ b/openmetadata-ui/src/main/resources/ui/playwright/support/entity/ingestion/ServiceBaseClass.ts @@ -177,18 +177,17 @@ class ServiceBaseClass { .getByTestId('loader') .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 - await page.waitForTimeout(2000); + await page.waitForTimeout(3000); await page.getByTestId('more-actions').first().click(); await page.getByTestId('run-button').click(); 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); } @@ -444,18 +443,17 @@ class ServiceBaseClass { .getByRole('cell', { name: 'Pause Logs' }) .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 - await page.waitForTimeout(2000); + await page.waitForTimeout(3000); await page.getByTestId('more-actions').first().click(); await page.getByTestId('run-button').click(); 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 await this.handleIngestionRetry('metadata', page);