This is an automated email from the ASF dual-hosted git repository.
jason810496 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 cd431eedcd0 Make session parameter in dag_clear CLI keyword only
(#67582)
cd431eedcd0 is described below
commit cd431eedcd062671c2aef9fa30422b9316fc8178
Author: Jason(Zhe-You) Liu <[email protected]>
AuthorDate: Wed May 27 22:00:39 2026 +0800
Make session parameter in dag_clear CLI keyword only (#67582)
---
airflow-core/src/airflow/cli/commands/dag_command.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/airflow-core/src/airflow/cli/commands/dag_command.py
b/airflow-core/src/airflow/cli/commands/dag_command.py
index 3a28e4f1b20..267fcad6a22 100644
--- a/airflow-core/src/airflow/cli/commands/dag_command.py
+++ b/airflow-core/src/airflow/cli/commands/dag_command.py
@@ -125,7 +125,7 @@ def dag_delete(args) -> None:
@cli_utils.action_cli
@providers_configuration_loaded
@provide_session
-def dag_clear(args, session: Session = NEW_SESSION) -> None:
+def dag_clear(args, *, session: Session = NEW_SESSION) -> None:
"""Clear Dag runs selected by run_id, partition_key, or a partition_date
window."""
has_range = args.partition_date_start is not None or
args.partition_date_end is not None
selectors_used = sum([args.run_id is not None, args.partition_key is not
None, has_range])
