add bulk delete for dagruns by Pei-Cheng-Yu · Pull Request #60718 · apache/airflow

Pei-Cheng-Yu · 2026-01-17T16:48:20Z

Why

related #52439

How

add BulkDeleteRunsButton and useBulkDeleteDagRuns for collectively delete runs

video

Clipchamp.7.mp4

Was generative AI tooling used to co-author this PR?

Yes (please specify the tool below)

Read the Pull Request Guidelines for more information. Note: commit author/co-author name and email in commits become permanently public when merged.
For fundamental code changes, an Airflow Improvement Proposal (AIP) is needed.
When adding dependency, check compliance with the ASF 3rd Party License Policy.
For significant user-facing changes create newsfragment: {pr_number}.significant.rst or {issue_number}.significant.rst, in airflow-core/newsfragments.

pierrejeambrun

Nice 🎉 thanks for the pull request.

Can you take a look at the DeleteVariablesButton and DeleteConnectionsButton and implement the same for TI.

Pei-Cheng-Yu · 2026-01-24T22:36:13Z

Can you take a look at the DeleteVariablesButton and DeleteConnectionsButton and implement the same for TI.

Thanks for reviewing, I just updated it!

guan404ming

Thanks for the contribution! Left some comments.

airflow-core/src/airflow/ui/src/pages/DagRuns.tsx

airflow-core/src/airflow/ui/src/queries/useBulkDeleteDagRuns.ts

guan404ming · 2026-01-27T14:52:33Z

Can you take a look at the DeleteVariablesButton and DeleteConnectionsButton and implement the same for TI.

I think maybe we could handle that in another separated pr since I think that one is more complicated.

pierrejeambrun

I agree that we need another PR to update the backend to add the bulk delete feature similarly to variables and connections before we can merge this.

This PR is looking good to me, but we probably don't want to make N calls. (if someone tries to delete 500 dagruns this way, it's probably going to be a problem)

@Pei-Cheng-Yu Would you be interested in contributing that backend feature to enable this PR first?

Pei-Cheng-Yu · 2026-02-02T09:59:16Z

Thanks for the reviews !
Sure! I just make the hook's return value align with the pattern in useBulkDeleteVariables.ts, and now i can investigate into the backend part!

guan404ming · 2026-02-02T15:13:49Z

Nice! Feel free to open a new pr to handle the backend part~

guan404ming · 2026-02-20T14:31:51Z

Hi @Pei-Cheng-Yu, I think this would be a great feature to include in 3.2. Just wanted to check if you're still working on this? If you're tied up at the moment, I’m happy to take it over and help handle it. Thanks!

Pei-Cheng-Yu · 2026-02-21T00:04:50Z

Hi @guan404ming , thanks for checking and apologies for the delay.

The past few weeks have been quite busy on my end, so I’ve been working on this incrementally. The backend implementation is now completed, and only the unit tests remain. I expect to have them finished within the next two days.

Really appreciate the offer to help!

guan404ming · 2026-02-21T02:23:37Z

No need to apologize at all! I completely understand how busy things can get. It’s great to hear that the backend implementation is finished. If you run into any blockers or have questions while wrapping things up, feel free to reach out anytime. Looking forward to the update!

Pei-Cheng-Yu · 2026-02-21T06:32:10Z

Thanks a lot for the understanding and support!

jscheffl

For me this is looking good. Yes, at the moment this makes N calls to the backend but it is not possible to make more batch calls than the list has elements, so 500 is not possible. I think it is more important to have the feature then making it pretty.

Therefore I think we can also merge this PR and have a follow-up to improve with a batch backend. But leaving final merge to an UI expert.

Tested manaully besides code check and works well.

pierrejeambrun

I agree that we can deliver value incrementally. Having the feature 'non optimal' is still better than not having the feature at all.

We've done this in the past for other parts of the UI.

I'm happy to move forward with this and refactor it later when scalability becomes a problem.

A few suggestions though before we can move forward.

pierrejeambrun · 2026-04-08T13:22:55Z

airflow-core/src/airflow/ui/src/pages/BulkDeleteRunsButton.tsx

nit: Rename file + component to DeleteRunsButton to be consistant with other DeleteVariablesButton and `

pierrejeambrun · 2026-04-08T13:30:25Z

airflow-core/src/airflow/ui/src/pages/BulkDeleteRunsButton.tsx

+              >
+                <FiTrash2 />{" "}
+                <Text as="span" fontWeight="bold">
+                  {translate("common:delete")}


The confirmation modal isn't consistent with other confirmation modal:

pierrejeambrun · 2026-04-08T13:31:09Z

airflow-core/src/airflow/ui/src/pages/BulkDeleteRunsButton.tsx

+        <FiTrash2 />
+        {translate("dags:runAndTaskActions.delete.button", { type: translate("dagRun_other") })}
+      </Button>


Not consistent. Here it's just delete:

pierrejeambrun · 2026-04-08T13:35:08Z

airflow-core/src/airflow/ui/src/pages/DagRuns.tsx

+type SelectionConfig = {
+  allRowsSelected: boolean;
+  onRowSelect: (key: string, selected: boolean) => void;
+  onSelectAll: (selected: boolean) => void;
+  selectedRows: Map<string, boolean>;
+};


This is alreaady defined in useRowSelection.ts we should reuse it.

pierrejeambrun · 2026-04-08T13:38:02Z

airflow-core/src/airflow/ui/src/pages/DagRuns.tsx

+const parseRunKey = (key: string): SelectedRun => {
+  const [dagId = "", ...rest] = key.split("__");
+
+  return { dagId, dagRunId: rest.join("__") };
+};


What if the dag_id / dag_run_id holds a __ ?

pierrejeambrun · 2026-04-08T13:39:28Z

airflow-core/src/airflow/ui/src/pages/DagRuns.tsx

+      getKey: (run) => runKey({ dagId: run.dag_id, dagRunId: run.dag_run_id }),
+    });
+
+  const selectedRuns = useMemo<Array<SelectedRun>>(


React compiler is taking care of useMemo I belive. This isn't needed anymore.

pierrejeambrun · 2026-04-08T13:40:21Z

airflow-core/src/airflow/ui/src/queries/useBulkDeleteDagRuns.ts

+    if (failed.length > 0) {
+      const [first] = failed;
+
+      if (first) {
+        setError(first.reason);
+      }
+      toaster.create({
+        description: `${failed.length}/${runs.length} failed`,
+        title: translate("dags:runAndTaskActions.delete.error", { type: translate("dagRun_one") }),
+        type: "error",
+      });


When multiple deletions fail, only failed[0].reason is stored in error state. The toast says ${failed.length}/${runs.length} failed but doesn't say which ones or why. Consider showing all failed run IDs in the error alert.

Copilot

Pull request overview

Adds a bulk-delete workflow to the DAG Runs listing, enabling users to select multiple runs and delete them in one action (addressing the “select many runs and collectively remove…” workflow referenced in #52439).

Changes:

Introduces a BulkDeleteRunsButton confirmation dialog for deleting selected DAG runs.
Adds useBulkDeleteDagRuns to perform multi-run deletion and invalidate relevant React Query caches.
Updates DagRuns page to support row selection via checkboxes and show an action bar when rows are selected.

Reviewed changes

Copilot reviewed 3 out of 3 changed files in this pull request and generated 5 comments.

File	Description
`airflow-core/src/airflow/ui/src/queries/useBulkDeleteDagRuns.ts`	New hook implementing multi-run deletion and cache invalidation with success/error toasts.
`airflow-core/src/airflow/ui/src/pages/DagRuns.tsx`	Adds checkbox-based row selection and an `ActionBar` entry point for bulk deletion.
`airflow-core/src/airflow/ui/src/pages/BulkDeleteRunsButton.tsx`	New UI button + dialog to confirm and execute bulk deletion.

Copilot · 2026-04-10T20:04:26Z

airflow-core/src/airflow/ui/src/pages/BulkDeleteRunsButton.tsx

+              {translate("dags:runAndTaskActions.delete.dialog.warning", {
+                type: translate("dagRun_other"),
+              })}{" "}
+              ({count} {translate("dagRun", { count })})


The translation call translate("dagRun", { count }) is likely incorrect: in public/i18n/locales/*/common.json, dagRun is a nested object (e.g. for column labels), not a pluralizable string key. This will render as the key name (or [object Object]) instead of “Dag Run(s)”. Use the existing plural keys like dagRun_one / dagRun_other (or an existing pluralized resourceName pattern) for the count label.

Suggested change

({count} {translate("dagRun", { count })})

({count} {count === 1 ? translate("dagRun_one") : translate("dagRun_other")})

Copilot · 2026-04-10T20:04:26Z

airflow-core/src/airflow/ui/src/pages/DagRuns.tsx

+        {
+          cell: ({ row: { original } }: DagRunRow) => {
+            const key = runKey({ dagId: original.dag_id, dagRunId: original.dag_run_id });
+
+            return (
+              <Checkbox
+                borderWidth={1}
+                checked={selection.selectedRows.get(key)}
+                colorPalette="brand"
+                onCheckedChange={(event) => selection.onRowSelect(key, Boolean(event.checked))}
+              />
+            );
+          },
+          enableSorting: false,
+          header: () => (
+            <Checkbox
+              borderWidth={1}
+              checked={selection.allRowsSelected}
+              colorPalette="brand"
+              onCheckedChange={(event) => selection.onSelectAll(Boolean(event.checked))}
+            />
+          ),
+          id: "select",
+          meta: { skeletonWidth: 2 },
+        } satisfies ColumnDef<DAGRunResponse>,
+      ]


The selection checkbox column is missing enableHiding: false (and uses id instead of the established accessorKey: "select" pattern). Since DataTable enables column hiding globally, users can hide this column and lose the ability to change selections. Consider matching the existing selection-column pattern used in e.g. pages/Connections/Connections.tsx and pages/Variables/Variables.tsx by setting accessorKey: "select", enableHiding: false, and enableSorting: false.

Copilot · 2026-04-10T20:04:27Z

airflow-core/src/airflow/ui/src/pages/DagRuns.tsx

+const runKey = (run: SelectedRun) => `${run.dagId}__${run.dagRunId}`;
+const parseRunKey = (key: string): SelectedRun => {
+  const [dagId = "", ...rest] = key.split("__");
+
+  return { dagId, dagRunId: rest.join("__") };


runKey/parseRunKey rely on a "__" delimiter to round-trip { dagId, dagRunId }. This breaks if dagId itself contains "__" (DAG IDs are user-defined strings), leading to deletes being issued against the wrong DAG. Prefer an encoding that can’t collide (e.g. JSON.stringify/JSON.parse, or base64/URL-encoding of each part with an unambiguous separator).

Suggested change

const runKey = (run: SelectedRun) => `${run.dagId}__${run.dagRunId}`;

const parseRunKey = (key: string): SelectedRun => {

const [dagId = "", ...rest] = key.split("__");

return { dagId, dagRunId: rest.join("__") };

const runKey = (run: SelectedRun) => JSON.stringify({ dagId: run.dagId, dagRunId: run.dagRunId });

const parseRunKey = (key: string): SelectedRun => {

try {

const parsed = JSON.parse(key) as Partial<SelectedRun>;

return {

dagId: typeof parsed.dagId === "string" ? parsed.dagId : "",

dagRunId: typeof parsed.dagRunId === "string" ? parsed.dagRunId : "",

};

} catch {

return { dagId: "", dagRunId: "" };

}

Copilot · 2026-04-10T20:04:27Z

airflow-core/src/airflow/ui/src/queries/useBulkDeleteDagRuns.ts

+
+  const mutate = async (runs: Array<SelectedRun>): Promise<void> => {
+    if (runs.length === 0) {
+      return;
+    }
+    setError(undefined);
+
+    const results = await Promise.allSettled(
+      runs.map(({ dagId, dagRunId }) => deleteMutation.mutateAsync({ dagId, dagRunId })),
+    );
+
+    const failed = results.filter((result): result is PromiseRejectedResult => result.status === "rejected");
+    const queryKeys = [
+      [useDagRunServiceGetDagRunsKey],
+      [useTaskInstanceServiceGetTaskInstancesKey],
+      [useTaskInstanceServiceGetHitlDetailsKey],
+      ...runs.map(({ dagId, dagRunId }) => UseDagRunServiceGetDagRunKeyFn({ dagId, dagRunId })),
+    ];
+
+    await Promise.all(queryKeys.map((key) => queryClient.invalidateQueries({ queryKey: key })));
+
+    if (failed.length > 0) {
+      const [first] = failed;
+
+      if (first) {
+        setError(first.reason);
+      }
+      toaster.create({
+        description: `${failed.length}/${runs.length} failed`,
+        title: translate("dags:runAndTaskActions.delete.error", { type: translate("dagRun_one") }),
+        type: "error",
+      });
+
+      return;
+    }
+
+    toaster.create({
+      description: translate("dags:runAndTaskActions.delete.success.description", {
+        type: translate("dagRun_one"),
+      }),
+      title: translate("dags:runAndTaskActions.delete.success.title", { type: translate("dagRun_one") }),
+      type: "success",
+    });
+
+    clearSelections?.();
+    onSuccessConfirm?.();
+  };
+
+  return {
+    error,
+    isPending: deleteMutation.isPending,


useDagRunServiceDeleteDagRun() returns a single React Query mutation instance, but mutateAsync is invoked concurrently for every selected run. Mutation state (notably isPending) only tracks the most recently started mutation, so the UI loading state can flip to false while earlier deletions are still in flight. Consider implementing this as one mutation that accepts the array of runs (and internally runs deletes with a concurrency limit or sequentially), and manage a dedicated isPending state for the bulk operation.

Suggested change

const mutate = async (runs: Array<SelectedRun>): Promise<void> => {

if (runs.length === 0) {

return;

}

setError(undefined);

const results = await Promise.allSettled(

runs.map(({ dagId, dagRunId }) => deleteMutation.mutateAsync({ dagId, dagRunId })),

);

const failed = results.filter((result): result is PromiseRejectedResult => result.status === "rejected");

const queryKeys = [

[useDagRunServiceGetDagRunsKey],

[useTaskInstanceServiceGetTaskInstancesKey],

[useTaskInstanceServiceGetHitlDetailsKey],

...runs.map(({ dagId, dagRunId }) => UseDagRunServiceGetDagRunKeyFn({ dagId, dagRunId })),

];

await Promise.all(queryKeys.map((key) => queryClient.invalidateQueries({ queryKey: key })));

if (failed.length > 0) {

const [first] = failed;

if (first) {

setError(first.reason);

}

toaster.create({

description: `${failed.length}/${runs.length} failed`,

title: translate("dags:runAndTaskActions.delete.error", { type: translate("dagRun_one") }),

type: "error",

});

return;

}

toaster.create({

description: translate("dags:runAndTaskActions.delete.success.description", {

type: translate("dagRun_one"),

}),

title: translate("dags:runAndTaskActions.delete.success.title", { type: translate("dagRun_one") }),

type: "success",

});

clearSelections?.();

onSuccessConfirm?.();

};

return {

error,

isPending: deleteMutation.isPending,

const [isPending, setIsPending] = useState(false);

const mutate = async (runs: Array<SelectedRun>): Promise<void> => {

if (runs.length === 0) {

return;

}

setError(undefined);

setIsPending(true);

try {

const failed: Array<PromiseRejectedResult> = [];

for (const { dagId, dagRunId } of runs) {

try {

await deleteMutation.mutateAsync({ dagId, dagRunId });

} catch (reason) {

failed.push({ reason, status: "rejected" });

}

}

const queryKeys = [

[useDagRunServiceGetDagRunsKey],

[useTaskInstanceServiceGetTaskInstancesKey],

[useTaskInstanceServiceGetHitlDetailsKey],

...runs.map(({ dagId, dagRunId }) => UseDagRunServiceGetDagRunKeyFn({ dagId, dagRunId })),

];

await Promise.all(queryKeys.map((key) => queryClient.invalidateQueries({ queryKey: key })));

if (failed.length > 0) {

const [first] = failed;

if (first) {

setError(first.reason);

}

toaster.create({

description: `${failed.length}/${runs.length} failed`,

title: translate("dags:runAndTaskActions.delete.error", { type: translate("dagRun_one") }),

type: "error",

});

return;

}

toaster.create({

description: translate("dags:runAndTaskActions.delete.success.description", {

type: translate("dagRun_one"),

}),

title: translate("dags:runAndTaskActions.delete.success.title", { type: translate("dagRun_one") }),

type: "success",

});

clearSelections?.();

onSuccessConfirm?.();

} finally {

setIsPending(false);

}

};

return {

error,

isPending,

Copilot · 2026-04-10T20:04:27Z

airflow-core/src/airflow/ui/src/queries/useBulkDeleteDagRuns.ts

+      toaster.create({
+        description: `${failed.length}/${runs.length} failed`,
+        title: translate("dags:runAndTaskActions.delete.error", { type: translate("dagRun_one") }),
+        type: "error",
+      });
+
+      return;
+    }
+
+    toaster.create({
+      description: translate("dags:runAndTaskActions.delete.success.description", {
+        type: translate("dagRun_one"),
+      }),
+      title: translate("dags:runAndTaskActions.delete.success.title", { type: translate("dagRun_one") }),
+      type: "success",


The bulk-failure toast text is not localized ("${failed.length}/${runs.length} failed") and the toast titles/descriptions use dagRun_one even though multiple runs may be deleted. Please switch to existing i18n keys (e.g. common:toaster.bulkDelete.* or a new dags:* bulk-delete key) and use the plural resource name (dagRun_other) and/or include the counts so the message is accurate.

Pei-Cheng-Yu requested review from bbovenzi, choo121600, guan404ming, pierrejeambrun, ryanahamilton, shubhamraj-git and vatsrahul1001 as code owners January 17, 2026 16:48

boring-cyborg bot added the area:UI Related to UI/UX. For Frontend Developers. label Jan 17, 2026

Pei-Cheng-Yu changed the title ~~add bulk delete for dagruns~~ draft: add bulk delete for dagruns Jan 17, 2026

Pei-Cheng-Yu changed the title ~~draft: add bulk delete for dagruns~~ add bulk delete for dagruns Jan 17, 2026

Pei-Cheng-Yu marked this pull request as draft January 17, 2026 16:49

Pei-Cheng-Yu marked this pull request as ready for review January 17, 2026 16:52

guan404ming mentioned this pull request Jan 18, 2026

Add multi-selection to task instance and dag run tables #50396

Open

2 tasks

pierrejeambrun added this to the Airflow 3.2.0 milestone Jan 19, 2026

pierrejeambrun reviewed Jan 19, 2026

View reviewed changes

Pei-Cheng-Yu added 4 commits January 24, 2026 00:05

add bulk delete for dagruns

88c0540

rename file

429f394

revert rename file

660b51f

modify ui to use action bar

5d2e210

Pei-Cheng-Yu force-pushed the delete-failed-tasks-on-runs-page branch from 238658d to 5d2e210 Compare January 23, 2026 22:34

guan404ming reviewed Jan 27, 2026

View reviewed changes

airflow-core/src/airflow/ui/src/pages/DagRuns.tsx Outdated Show resolved Hide resolved

airflow-core/src/airflow/ui/src/queries/useBulkDeleteDagRuns.ts Outdated Show resolved Hide resolved

airflow-core/src/airflow/ui/src/queries/useBulkDeleteDagRuns.ts Outdated Show resolved Hide resolved

pierrejeambrun reviewed Feb 2, 2026

View reviewed changes

make hook consist to the pattern like others

2c4b39b

Pei-Cheng-Yu mentioned this pull request Feb 24, 2026

Bulkdelete dagrun backend #62399

Draft

1 task

vatsrahul1001 modified the milestones: Airflow 3.2.0, Airflow 3.2.1 Mar 27, 2026

shivaam mentioned this pull request Mar 31, 2026

Auto-triage: flag area:UI PRs missing screenshots/demo from new contributors #64516

Merged

1 task

potiuk added the ready for maintainer review Set after triaging when all criteria pass. label Apr 2, 2026

jscheffl approved these changes Apr 3, 2026

View reviewed changes

pierrejeambrun reviewed Apr 8, 2026

View reviewed changes

kaxil requested a review from Copilot April 10, 2026 19:55

Copilot AI reviewed Apr 10, 2026

View reviewed changes

	({count} {translate("dagRun", { count })})
	({count} {count === 1 ? translate("dagRun_one") : translate("dagRun_other")})

Conversation

Pei-Cheng-Yu commented Jan 17, 2026 • edited by pierrejeambrun Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Why

How

video

Was generative AI tooling used to co-author this PR?

Uh oh!

pierrejeambrun left a comment

Choose a reason for hiding this comment

Uh oh!

Pei-Cheng-Yu commented Jan 24, 2026

Uh oh!

guan404ming left a comment • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Uh oh!

Uh oh!

Uh oh!

guan404ming commented Jan 27, 2026 • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Uh oh!

pierrejeambrun left a comment • edited Loading Uh oh! There was an error while loading. Please reload this page.

Uh oh!

Choose a reason for hiding this comment

Uh oh!

Pei-Cheng-Yu commented Feb 2, 2026

Uh oh!

guan404ming commented Feb 2, 2026

Uh oh!

guan404ming commented Feb 20, 2026

Uh oh!

Pei-Cheng-Yu commented Feb 21, 2026

Uh oh!

guan404ming commented Feb 21, 2026

Uh oh!

Pei-Cheng-Yu commented Feb 21, 2026

Uh oh!

jscheffl left a comment

Choose a reason for hiding this comment

Uh oh!

pierrejeambrun left a comment

Choose a reason for hiding this comment

Uh oh!

pierrejeambrun Apr 8, 2026

Choose a reason for hiding this comment

Uh oh!

pierrejeambrun Apr 8, 2026

Choose a reason for hiding this comment

Uh oh!

pierrejeambrun Apr 8, 2026

Choose a reason for hiding this comment

Uh oh!

pierrejeambrun Apr 8, 2026

Choose a reason for hiding this comment

Uh oh!

pierrejeambrun Apr 8, 2026

Choose a reason for hiding this comment

Uh oh!

pierrejeambrun Apr 8, 2026

Choose a reason for hiding this comment

Uh oh!

pierrejeambrun Apr 8, 2026

Choose a reason for hiding this comment

Uh oh!

Copilot AI left a comment

Choose a reason for hiding this comment

Pull request overview

Reviewed changes

Uh oh!

Copilot AI Apr 10, 2026

Choose a reason for hiding this comment

Uh oh!

Copilot AI Apr 10, 2026

Choose a reason for hiding this comment

Uh oh!

Copilot AI Apr 10, 2026

Choose a reason for hiding this comment

Uh oh!

Pei-Cheng-Yu commented Jan 17, 2026 •

edited by pierrejeambrun

Loading

guan404ming left a comment •

edited

Loading

guan404ming commented Jan 27, 2026 •

edited

Loading

pierrejeambrun left a comment •

edited

Loading