This is an automated email from the ASF dual-hosted git repository.
bbovenzi pushed a commit to branch v3-0-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-0-test by this push:
new a0a13f4f6d1 [v3-0-test] Move map index column (#50302) (#50347)
a0a13f4f6d1 is described below
commit a0a13f4f6d1cb554b3792a9ebd9cbba61bfa508c
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Thu May 8 08:23:34 2025 -0400
[v3-0-test] Move map index column (#50302) (#50347)
* Move map_index column
* Add rendered map index to breadcrumb
(cherry picked from commit e1a5b63e2557df902ac30cc5e1be02f9aa793c8c)
Co-authored-by: Brent Bovenzi <[email protected]>
---
.../src/airflow/ui/src/layouts/Details/DagBreadcrumb.tsx | 9 ++++++++-
.../src/airflow/ui/src/pages/TaskInstances/TaskInstances.tsx | 8 ++++----
2 files changed, 12 insertions(+), 5 deletions(-)
diff --git a/airflow-core/src/airflow/ui/src/layouts/Details/DagBreadcrumb.tsx
b/airflow-core/src/airflow/ui/src/layouts/Details/DagBreadcrumb.tsx
index 7c2839e6da6..7afa19f9a6f 100644
--- a/airflow-core/src/airflow/ui/src/layouts/Details/DagBreadcrumb.tsx
+++ b/airflow-core/src/airflow/ui/src/layouts/Details/DagBreadcrumb.tsx
@@ -22,6 +22,7 @@ import { useParams } from "react-router-dom";
import {
useDagRunServiceGetDagRun,
useDagServiceGetDagDetails,
+ useTaskInstanceServiceGetMappedTaskInstance,
useTaskServiceGetTask,
} from "openapi/queries";
import { BreadcrumbStats } from "src/components/BreadcrumbStats";
@@ -52,6 +53,12 @@ export const DagBreadcrumb = () => {
const { data: task } = useTaskServiceGetTask({ dagId, taskId }, undefined, {
enabled: Boolean(taskId) });
+ const { data: mappedTaskInstance } =
useTaskInstanceServiceGetMappedTaskInstance(
+ { dagId, dagRunId: runId ?? "", mapIndex: parseInt(mapIndex, 10), taskId:
taskId ?? "" },
+ undefined,
+ { enabled: Boolean(runId) && Boolean(taskId) && mapIndex !== "-1" },
+ );
+
const links: Array<{ label: ReactNode | string; labelExtra?: ReactNode;
title?: string; value?: string }> =
[
{
@@ -101,7 +108,7 @@ export const DagBreadcrumb = () => {
}
if (mapIndex !== "-1") {
- links.push({ label: mapIndex, title: "Map Index" });
+ links.push({ label: mappedTaskInstance?.rendered_map_index ?? mapIndex,
title: "Map Index" });
}
return <BreadcrumbStats links={links} />;
diff --git
a/airflow-core/src/airflow/ui/src/pages/TaskInstances/TaskInstances.tsx
b/airflow-core/src/airflow/ui/src/pages/TaskInstances/TaskInstances.tsx
index 54e3139c573..c299e8d01ed 100644
--- a/airflow-core/src/airflow/ui/src/pages/TaskInstances/TaskInstances.tsx
+++ b/airflow-core/src/airflow/ui/src/pages/TaskInstances/TaskInstances.tsx
@@ -96,6 +96,10 @@ const taskInstanceColumns = (
header: "Task ID",
},
]),
+ {
+ accessorKey: "rendered_map_index",
+ header: "Map Index",
+ },
{
accessorKey: "state",
cell: ({
@@ -124,10 +128,6 @@ const taskInstanceColumns = (
cell: ({ row: { original } }) => <Time datetime={original.end_date} />,
header: "End Date",
},
- {
- accessorKey: "rendered_map_index",
- header: "Map Index",
- },
{
accessorKey: "try_number",
enableSorting: false,
