From b73940aed438c4350c1e14af87de50163bb29d59 Mon Sep 17 00:00:00 2001 From: Yuseok Jo Date: Sun, 5 Jul 2026 17:56:16 +0900 Subject: [PATCH 1/2] [AIP-94] Mark dags list-runs/list-jobs/report/clear as migrated to airflowctl --- airflow-core/src/airflow/cli/commands/dag_command.py | 4 ++++ .../tests/unit/cli/commands/test_command_deprecations.py | 4 ++++ 2 files changed, 8 insertions(+) diff --git a/airflow-core/src/airflow/cli/commands/dag_command.py b/airflow-core/src/airflow/cli/commands/dag_command.py index ec5b62ca1d3f4..8dda9d8215e12 100644 --- a/airflow-core/src/airflow/cli/commands/dag_command.py +++ b/airflow-core/src/airflow/cli/commands/dag_command.py @@ -128,6 +128,7 @@ def dag_delete(args) -> None: print("Cancelled") +@deprecated_for_airflowctl("airflowctl dags clear") @cli_utils.action_cli @providers_configuration_loaded @provide_session @@ -694,6 +695,7 @@ def dag_list_import_errors(args, *, session: Session = NEW_SESSION) -> None: sys.exit(1) +@deprecated_for_airflowctl("airflowctl dags report") @cli_utils.action_cli @suppress_logs_and_warning @providers_configuration_loaded @@ -729,6 +731,7 @@ def dag_report(args) -> None: ) +@deprecated_for_airflowctl("airflowctl dags list-jobs") @cli_utils.action_cli @suppress_logs_and_warning @providers_configuration_loaded @@ -760,6 +763,7 @@ def dag_list_jobs(args, dag: DAG | None = None, *, session: Session = NEW_SESSIO ) +@deprecated_for_airflowctl("airflowctl dags list-runs") @cli_utils.action_cli @suppress_logs_and_warning @providers_configuration_loaded diff --git a/airflow-core/tests/unit/cli/commands/test_command_deprecations.py b/airflow-core/tests/unit/cli/commands/test_command_deprecations.py index c06605c80ae13..8ab47afbfa3bd 100644 --- a/airflow-core/tests/unit/cli/commands/test_command_deprecations.py +++ b/airflow-core/tests/unit/cli/commands/test_command_deprecations.py @@ -54,6 +54,10 @@ (dag_command.dag_list_import_errors, "airflowctl dags list-import-errors"), (dag_command.dag_pause, "airflowctl dags pause"), (dag_command.dag_unpause, "airflowctl dags unpause"), + (dag_command.dag_list_dag_runs, "airflowctl dags list-runs"), + (dag_command.dag_list_jobs, "airflowctl dags list-jobs"), + (dag_command.dag_report, "airflowctl dags report"), + (dag_command.dag_clear, "airflowctl dags clear"), (pool_command.pool_list, "airflowctl pools list"), (pool_command.pool_get, "airflowctl pools get"), (pool_command.pool_set, "airflowctl pools create"), From 4c4d2054e2045e7b0825efee7c57bf5f9e98ae6a Mon Sep 17 00:00:00 2001 From: Yuseok Jo Date: Mon, 6 Jul 2026 01:30:54 +0900 Subject: [PATCH 2/2] [AIP-94] Mark dags list-runs as migrated to airflowctl --- airflow-core/src/airflow/cli/commands/dag_command.py | 5 +---- .../tests/unit/cli/commands/test_command_deprecations.py | 5 +---- 2 files changed, 2 insertions(+), 8 deletions(-) diff --git a/airflow-core/src/airflow/cli/commands/dag_command.py b/airflow-core/src/airflow/cli/commands/dag_command.py index 8dda9d8215e12..78ceba514ec7e 100644 --- a/airflow-core/src/airflow/cli/commands/dag_command.py +++ b/airflow-core/src/airflow/cli/commands/dag_command.py @@ -128,7 +128,6 @@ def dag_delete(args) -> None: print("Cancelled") -@deprecated_for_airflowctl("airflowctl dags clear") @cli_utils.action_cli @providers_configuration_loaded @provide_session @@ -695,7 +694,6 @@ def dag_list_import_errors(args, *, session: Session = NEW_SESSION) -> None: sys.exit(1) -@deprecated_for_airflowctl("airflowctl dags report") @cli_utils.action_cli @suppress_logs_and_warning @providers_configuration_loaded @@ -731,7 +729,6 @@ def dag_report(args) -> None: ) -@deprecated_for_airflowctl("airflowctl dags list-jobs") @cli_utils.action_cli @suppress_logs_and_warning @providers_configuration_loaded @@ -763,7 +760,7 @@ def dag_list_jobs(args, dag: DAG | None = None, *, session: Session = NEW_SESSIO ) -@deprecated_for_airflowctl("airflowctl dags list-runs") +@deprecated_for_airflowctl("airflowctl dagrun list") @cli_utils.action_cli @suppress_logs_and_warning @providers_configuration_loaded diff --git a/airflow-core/tests/unit/cli/commands/test_command_deprecations.py b/airflow-core/tests/unit/cli/commands/test_command_deprecations.py index 8ab47afbfa3bd..e2e02be9f49e9 100644 --- a/airflow-core/tests/unit/cli/commands/test_command_deprecations.py +++ b/airflow-core/tests/unit/cli/commands/test_command_deprecations.py @@ -54,10 +54,7 @@ (dag_command.dag_list_import_errors, "airflowctl dags list-import-errors"), (dag_command.dag_pause, "airflowctl dags pause"), (dag_command.dag_unpause, "airflowctl dags unpause"), - (dag_command.dag_list_dag_runs, "airflowctl dags list-runs"), - (dag_command.dag_list_jobs, "airflowctl dags list-jobs"), - (dag_command.dag_report, "airflowctl dags report"), - (dag_command.dag_clear, "airflowctl dags clear"), + (dag_command.dag_list_dag_runs, "airflowctl dagrun list"), (pool_command.pool_list, "airflowctl pools list"), (pool_command.pool_get, "airflowctl pools get"), (pool_command.pool_set, "airflowctl pools create"),