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 eae995056fd..ea6ffe65f1d 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 @@ -351,6 +351,21 @@ class ServiceBaseClass { await page.waitForLoadState('networkidle'); await page.waitForSelector(`td:has-text("${ingestionType}")`); + const pipelineStatus = await page + .locator(`[data-row-key*="${workflowData.name}"]`) + .getByTestId('pipeline-status') + .last() + .textContent(); + // add logs to console for failed pipelines + if (pipelineStatus?.toLowerCase() === 'failed') { + const logsResponse = await apiContext + .get(`/api/v1/services/ingestionPipelines/logs/${workflowData.id}/last`) + .then((res) => res.json()); + + // eslint-disable-next-line no-console + console.log(logsResponse); + } + await expect( page .locator(`[data-row-key*="${workflowData.name}"]`)