This is an automated email from the ASF dual-hosted git repository.
henry3260 pushed a commit to branch v3-3-test
in repository https://gitbox.apache.org/repos/asf/airflow.git
The following commit(s) were added to refs/heads/v3-3-test by this push:
new b228addc776 [AIP-94] Mark dags pause/unpause as migrated to airflowctl
(#68650) (#69412)
b228addc776 is described below
commit b228addc776a97133da04e3d4d9e77930759ef8a
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"),
