Skip to content

support dag level db cleanup on airflow cli #24828

Open
@davidkl97

Description

Description

While full db cleanup is useful to run in rare occasions, deleting data regarding to specific dag ids provides modular maintenance method to clean specific "intensive" dags and provide clear context and responsivness in the web ui and interfaces in cluster.

an initial idea was gathered to add optional dag_id key in _TableConfig at db_cleanup.py and append condition in _build_query(after adding the argument of course). Those changes could be provided also in the helm chart as list of cleanup jobs.

would love to hear you inputs about the use case and the implementation relating to the current effort(e.g #24590).
Thanks.

Use case/motivation

  • cleanup of specific "intensive" dags.
  • modular and configurable context and metadata in the web server and the different interfaces.

Related issues

No response

Are you willing to submit a PR?

  • Yes I am willing to submit a PR!

Code of Conduct

Metadata

Assignees

Type

No type

Projects

No projects

Milestone

No milestone

Relationships

None yet

Development

No branches or pull requests

Issue actions