diff --git a/airflow/www/static/js/dag/details/taskInstance/Details.tsx b/airflow/www/static/js/dag/details/taskInstance/Details.tsx index e8905d659357f5..7d9dfa1a1c20b7 100644 --- a/airflow/www/static/js/dag/details/taskInstance/Details.tsx +++ b/airflow/www/static/js/dag/details/taskInstance/Details.tsx @@ -25,7 +25,7 @@ import { Tbody, Tr, Td, - Heading, + Divider, } from '@chakra-ui/react'; import { finalStatesMap } from 'src/utils'; @@ -34,8 +34,8 @@ import { SimpleStatus } from 'src/dag/StatusBox'; import Time from 'src/components/Time'; import { ClipboardText } from 'src/components/Clipboard'; import type { Task, TaskInstance, TaskState } from 'src/types'; +import useTaskInstance from 'src/api/useTaskInstance'; import DatasetUpdateEvents from './DatasetUpdateEvents'; -import useTaskInstance from '../../../api/useTaskInstance'; interface Props { instance: TaskInstance; @@ -57,9 +57,6 @@ const Details = ({ instance, group, dagId }: Props) => { mapIndex, } = instance; - const { data: apiTI } = useTaskInstance({ - dagId, dagRunId: runId, taskId, mapIndex, enabled: true, - }); const { isMapped, tooltip, @@ -67,6 +64,14 @@ const Details = ({ instance, group, dagId }: Props) => { hasOutletDatasets, } = group; + const { data: apiTI } = useTaskInstance({ + dagId, + dagRunId: runId, + taskId, + mapIndex, + enabled: !isGroup && !isMapped, + }); + const numMap = finalStatesMap(); let numMapped = 0; if (isGroup) { @@ -109,21 +114,12 @@ const Details = ({ instance, group, dagId }: Props) => { const isOverall = (isMapped || isGroup) && 'Overall '; return ( - - - {tooltip && ( - - - - )} - {state === 'deferred' && ( - <> - - - + {state === 'deferred' && ( + <> + Triggerer info + +
{tooltip}
- Triggerer info - -
+ @@ -140,17 +136,20 @@ const Details = ({ instance, group, dagId }: Props) => { - + +
Trigger class {`${apiTI?.trigger?.classpath}`}Latest triggerer heartbeat {`${apiTI?.triggererJob?.latestHeartbeat}`}
+ + )} + + Task Instance Details + + + + {tooltip && ( + + + )} - - - )} - {summary.length > 0 && ( - summary - )} + {summary.length > 0 && summary} - + - + {mapIndex !== undefined && ( @@ -206,13 +209,17 @@ const Details = ({ instance, group, dagId }: Props) => { {startDate && ( - + )} {endDate && isStateFinal && ( - + )} diff --git a/airflow/www/static/js/dag/details/taskInstance/index.tsx b/airflow/www/static/js/dag/details/taskInstance/index.tsx index 1e1b5356bc142e..91d70f246181f1 100644 --- a/airflow/www/static/js/dag/details/taskInstance/index.tsx +++ b/airflow/www/static/js/dag/details/taskInstance/index.tsx @@ -190,14 +190,14 @@ const TaskInstance = ({ {/* Mapped Task Instances Tab */} { isMappedTaskSummary && ( - - onSelect({ runId, taskId, mapIndex: row.values.mapIndex })} - /> - + + onSelect({ runId, taskId, mapIndex: row.values.mapIndex })} + /> + ) }
{tooltip}
- Task Instance Details - -
{isOverall} @@ -173,16 +172,20 @@ const Details = ({ instance, group, dagId }: Props) => {
{taskIdTitle} + +
Run ID + + + +
Started +
Ended +