Skip to content

Add bulk delete Dag Runs #67095

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
pierrejeambrun merged 8 commits into from
May 21, 2026
Merged

Add bulk delete Dag Runs #67095

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
9dfb1bb
Add bulk delete endpoint for Dag Runs
pierrejeambrun May 18, 2026
c8c14e2
Address self-review on bulk delete Dag Runs
pierrejeambrun May 19, 2026
4f6a3d9
Apply Brent's review feedback from the closed twin PR
pierrejeambrun May 19, 2026
daed13e
Address inline review: mirror task-instance bulk delete patterns
pierrejeambrun May 20, 2026
0bbb6b7
Move bulk Dag Run authorization to a dedicated route dependency
pierrejeambrun May 20, 2026
327c922
Mirror single-run DELETE state restriction on bulk delete
pierrejeambrun May 20, 2026
406992d
Invalidate dependent queries after bulk delete Dag Run
pierrejeambrun May 21, 2026
ce74d44
Restore resolve_run_on_latest_version import dropped during rebase
pierrejeambrun May 21, 2026
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
13 changes: 10 additions & 3 deletions airflow-core/src/airflow/api_fastapi/core_api/datamodels/dag_run.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -35,8 +35,8 @@
from airflow.serialization.definitions.dag import SerializedDAG


class DAGRunPatchStates(str, Enum):
"""Enum for Dag Run states when updating a Dag Run."""
class DagRunMutableStates(str, Enum):
"""Dag Run states from which the run may be mutated (patched, deleted)."""

QUEUED = DagRunState.QUEUED
SUCCESS = DagRunState.SUCCESS
Expand All @@ -46,10 +46,17 @@ class DAGRunPatchStates(str, Enum):
class DAGRunPatchBody(StrictBaseModel):
"""Dag Run Serializer for PATCH requests."""

state: DAGRunPatchStates | None = None
state: DagRunMutableStates | None = None
note: str | None = Field(None, max_length=1000)


class BulkDAGRunBody(StrictBaseModel):
"""Request body for bulk delete operations on Dag Runs."""

dag_run_id: str
dag_id: str | None = None


class DAGRunClearBody(StrictBaseModel):
"""Dag Run serializer for clear endpoint body."""

Expand Down
Loading
Loading