This is an automated email from the ASF dual-hosted git repository. vatsrahul1001 pushed a commit to branch v3-3-test in repository https://gitbox.apache.org/repos/asf/airflow.git
commit 2a2dd10ce188fdcde46af6e97d8263793685ef61 Author: Henry Chen <[email protected]> AuthorDate: Sun Jul 5 23:00:57 2026 +0800 [AIP-94] Mark dags pause/unpause as migrated to airflowctl (#68650) (#69412) (cherry picked from commit 638c63523a2f07c6391dcadbca2deafe43b0e3ee) Co-authored-by: Yuseok Jo <[email protected]> --- airflow-core/src/airflow/cli/commands/dag_command.py | 2 ++ airflow-core/tests/unit/cli/commands/test_command_deprecations.py | 2 ++ 2 files changed, 4 insertions(+) diff --git a/airflow-core/src/airflow/cli/commands/dag_command.py b/airflow-core/src/airflow/cli/commands/dag_command.py index 41d1c8c6669..ec5b62ca1d3 100644 --- a/airflow-core/src/airflow/cli/commands/dag_command.py +++ b/airflow-core/src/airflow/cli/commands/dag_command.py @@ -241,6 +241,7 @@ def _bulk_clear_runs( @cli_utils.action_cli +@deprecated_for_airflowctl("airflowctl dags pause") @providers_configuration_loaded def dag_pause(args) -> None: """Pauses a DAG.""" @@ -248,6 +249,7 @@ def dag_pause(args) -> None: @cli_utils.action_cli +@deprecated_for_airflowctl("airflowctl dags unpause") @providers_configuration_loaded def dag_unpause(args) -> None: """Unpauses a DAG.""" 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 287b230ea34..0308e5f7230 100644 --- a/airflow-core/tests/unit/cli/commands/test_command_deprecations.py +++ b/airflow-core/tests/unit/cli/commands/test_command_deprecations.py @@ -51,6 +51,8 @@ MIGRATED_CLI_COMMANDS = [ (dag_command.dag_trigger, "airflowctl dags trigger"), (dag_command.dag_delete, "airflowctl dags delete"), (dag_command.dag_details, "airflowctl dags get-details"), + (dag_command.dag_pause, "airflowctl dags pause"), + (dag_command.dag_unpause, "airflowctl dags unpause"), (dag_command.dag_list_import_errors, "airflowctl dags list-import-errors"), (pool_command.pool_list, "airflowctl pools list"), (pool_command.pool_get, "airflowctl pools get"),
