This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/main by this push:
new 1d805cc12b2 Add batch_size parameter description to run_cleanup
docstring (#54300)
1d805cc12b2 is described below
commit 1d805cc12b28c18b2ef614bb30f706b3c13c57ae
Author: Stephan <[email protected]>
AuthorDate: Mon Aug 11 21:55:28 2025 +0200
Add batch_size parameter description to run_cleanup docstring (#54300)
---
airflow-core/src/airflow/utils/db_cleanup.py | 1 +
1 file changed, 1 insertion(+)
diff --git a/airflow-core/src/airflow/utils/db_cleanup.py
b/airflow-core/src/airflow/utils/db_cleanup.py
index 7b0ee0487dd..5dae8dbe847 100644
--- a/airflow-core/src/airflow/utils/db_cleanup.py
+++ b/airflow-core/src/airflow/utils/db_cleanup.py
@@ -521,6 +521,7 @@ def run_cleanup(
:param confirm: Require user input to confirm before processing deletions.
:param skip_archive: Set to True if you don't want the purged rows
preservied in an archive table.
:param session: Session representing connection to the metadata database.
+ :param batch_size: Maximum number of rows to delete or archive in a single
transaction.
"""
clean_before_timestamp = timezone.coerce_datetime(clean_before_timestamp)
