diff --git a/airflow-core/src/airflow/ui/src/pages/TaskInstance/BlockingDeps.tsx b/airflow-core/src/airflow/ui/src/pages/TaskInstance/BlockingDeps.tsx index 2ed76613df7ce..fed7908b6abd6 100644 --- a/airflow-core/src/airflow/ui/src/pages/TaskInstance/BlockingDeps.tsx +++ b/airflow-core/src/airflow/ui/src/pages/TaskInstance/BlockingDeps.tsx @@ -22,14 +22,25 @@ import { useTranslation } from "react-i18next"; import { useTaskInstanceServiceGetTaskInstanceDependencies } from "openapi/queries"; import type { TaskInstanceResponse } from "openapi/requests/types.gen"; -export const BlockingDeps = ({ taskInstance }: { readonly taskInstance: TaskInstanceResponse }) => { +type BlockingDepsProps = { + readonly refetchInterval: number | false; + readonly taskInstance: TaskInstanceResponse; +}; + +export const BlockingDeps = ({ refetchInterval, taskInstance }: BlockingDepsProps) => { const { t: translate } = useTranslation(); - const { data } = useTaskInstanceServiceGetTaskInstanceDependencies({ - dagId: taskInstance.dag_id, - dagRunId: taskInstance.dag_run_id, - mapIndex: taskInstance.map_index, - taskId: taskInstance.task_id, - }); + const { data } = useTaskInstanceServiceGetTaskInstanceDependencies( + { + dagId: taskInstance.dag_id, + dagRunId: taskInstance.dag_run_id, + mapIndex: taskInstance.map_index, + taskId: taskInstance.task_id, + }, + undefined, + { + refetchInterval, + }, + ); if (data === undefined || data.dependencies.length < 1) { return undefined; diff --git a/airflow-core/src/airflow/ui/src/pages/TaskInstance/Details.tsx b/airflow-core/src/airflow/ui/src/pages/TaskInstance/Details.tsx index a769498f6d05e..5e7b66c7a5eed 100644 --- a/airflow-core/src/airflow/ui/src/pages/TaskInstance/Details.tsx +++ b/airflow-core/src/airflow/ui/src/pages/TaskInstance/Details.tsx @@ -95,11 +95,14 @@ export const Details = () => { taskInstance={taskInstance} /> )} - + {taskInstance === undefined || // eslint-disable-next-line unicorn/no-null ![null, "queued", "scheduled"].includes(taskInstance.state) ? undefined : ( - + )} {taskInstance !== undefined && (taskInstance.trigger ?? taskInstance.triggerer_job) ? ( diff --git a/airflow-core/src/airflow/ui/src/pages/TaskInstance/ExtraLinks.tsx b/airflow-core/src/airflow/ui/src/pages/TaskInstance/ExtraLinks.tsx index 3559d48065bcc..2ff7876dfc0fa 100644 --- a/airflow-core/src/airflow/ui/src/pages/TaskInstance/ExtraLinks.tsx +++ b/airflow-core/src/airflow/ui/src/pages/TaskInstance/ExtraLinks.tsx @@ -22,16 +22,26 @@ import { useParams } from "react-router-dom"; import { useTaskInstanceServiceGetExtraLinks } from "openapi/queries"; -export const ExtraLinks = () => { +type ExtraLinksProps = { + readonly refetchInterval: number | false; +}; + +export const ExtraLinks = ({ refetchInterval }: ExtraLinksProps) => { const { t: translate } = useTranslation("dag"); const { dagId = "", mapIndex = "-1", runId = "", taskId = "" } = useParams(); - const { data } = useTaskInstanceServiceGetExtraLinks({ - dagId, - dagRunId: runId, - mapIndex: parseInt(mapIndex, 10), - taskId, - }); + const { data } = useTaskInstanceServiceGetExtraLinks( + { + dagId, + dagRunId: runId, + mapIndex: parseInt(mapIndex, 10), + taskId, + }, + undefined, + { + refetchInterval, + }, + ); return data && Object.keys(data.extra_links).length > 0 ? (