From 8471e5bee8aa7e1003212d479e1a721126e91985 Mon Sep 17 00:00:00 2001 From: LIU ZHE YOU Date: Wed, 27 May 2026 10:25:46 +0800 Subject: [PATCH] Make session parameter in dag_clear CLI keyword only --- 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 3a28e4f1b20f9..267fcad6a22e5 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])