From 38e561e0066adfa5fbdf536d60ef85641ed8c388 Mon Sep 17 00:00:00 2001 From: Aseem Bansal Date: Sun, 10 Aug 2025 18:52:41 +0530 Subject: [PATCH] fix(ui/ingest): status update properly (#14395) --- .../src/app/ingestV2/executions/constants.ts | 8 ++++++++ datahub-web-react/src/app/ingestV2/executions/utils.ts | 6 ++---- .../src/app/ingestV2/source/IngestionSourceList.tsx | 1 + 3 files changed, 11 insertions(+), 4 deletions(-) diff --git a/datahub-web-react/src/app/ingestV2/executions/constants.ts b/datahub-web-react/src/app/ingestV2/executions/constants.ts index d9862f5f06..264c831419 100644 --- a/datahub-web-react/src/app/ingestV2/executions/constants.ts +++ b/datahub-web-react/src/app/ingestV2/executions/constants.ts @@ -13,3 +13,11 @@ export const EXECUTION_REQUEST_STATUS_ROLLBACK_FAILED = 'ROLLBACK_FAILED'; export const EXECUTION_REQUEST_STATUS_DUPLICATE = 'DUPLICATE'; export const EXECUTION_REQUEST_STATUS_PENDING = 'PENDING'; export const EXECUTION_REQUEST_STATUS_LOADING = 'LOADING'; + +export const EXECUTION_REQUEST_STATUS_ACTIVE = [ + EXECUTION_REQUEST_STATUS_RUNNING, + EXECUTION_REQUEST_STATUS_ROLLING_BACK, + EXECUTION_REQUEST_STATUS_PENDING, + EXECUTION_REQUEST_STATUS_UP_FOR_RETRY, + EXECUTION_REQUEST_STATUS_LOADING, +]; diff --git a/datahub-web-react/src/app/ingestV2/executions/utils.ts b/datahub-web-react/src/app/ingestV2/executions/utils.ts index ce6a503600..b0d8fe35c0 100644 --- a/datahub-web-react/src/app/ingestV2/executions/utils.ts +++ b/datahub-web-react/src/app/ingestV2/executions/utils.ts @@ -1,5 +1,6 @@ import { EXECUTION_REQUEST_STATUS_ABORTED, + EXECUTION_REQUEST_STATUS_ACTIVE, EXECUTION_REQUEST_STATUS_CANCELLED, EXECUTION_REQUEST_STATUS_DUPLICATE, EXECUTION_REQUEST_STATUS_FAILURE, @@ -17,10 +18,7 @@ import { import { ExecutionRequest } from '@types'; export function isExecutionRequestActive(executionRequest: ExecutionRequest) { - return ( - executionRequest.result?.status === EXECUTION_REQUEST_STATUS_RUNNING || - executionRequest.result?.status === EXECUTION_REQUEST_STATUS_ROLLING_BACK - ); + return EXECUTION_REQUEST_STATUS_ACTIVE.includes(executionRequest?.result?.status ?? ''); } export const getExecutionRequestStatusIcon = (status: string) => { diff --git a/datahub-web-react/src/app/ingestV2/source/IngestionSourceList.tsx b/datahub-web-react/src/app/ingestV2/source/IngestionSourceList.tsx index c8c2d3e3b7..7ffe41b944 100644 --- a/datahub-web-react/src/app/ingestV2/source/IngestionSourceList.tsx +++ b/datahub-web-react/src/app/ingestV2/source/IngestionSourceList.tsx @@ -306,6 +306,7 @@ export const IngestionSourceList = ({ variables: { input: { ingestionSourceUrn: urn }, }, + refetchQueries: ['listIngestionExecutionRequests'], }) .then(() => { setSourcesToRefetch((prev) => new Set(prev).add(urn));