This is an automated email from the ASF dual-hosted git repository.
henry3260 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 5628e8360dc Mark dags state and next-execution CLI commands as
migrated to airflowctl (#69305)
5628e8360dc is described below
commit 5628e8360dc3f0f77c90e96cea82b65b623ae7b3
Author: Yash jain <[email protected]>
AuthorDate: Thu Jul 23 22:44:16 2026 +0530
Mark dags state and next-execution CLI commands as migrated to airflowctl
(#69305)
---
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 d2d303b498c..e37580d7619 100644
--- a/airflow-core/src/airflow/cli/commands/dag_command.py
+++ b/airflow-core/src/airflow/cli/commands/dag_command.py
@@ -408,6 +408,7 @@ def _get_dagbag_dag_details(dag: DAG) -> dict:
}
+@deprecated_for_airflowctl("airflowctl dags state")
@cli_utils.action_cli
@providers_configuration_loaded
@provide_session
@@ -437,6 +438,7 @@ def dag_state(args, *, session: Session = NEW_SESSION) ->
None:
print(dr.state)
+@deprecated_for_airflowctl("airflowctl dags next-execution")
@cli_utils.action_cli
@providers_configuration_loaded
def dag_next_execution(args) -> None:
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 59d26a12864..5e9d0613acd 100644
--- a/airflow-core/tests/unit/cli/commands/test_command_deprecations.py
+++ b/airflow-core/tests/unit/cli/commands/test_command_deprecations.py
@@ -57,6 +57,8 @@ MIGRATED_CLI_COMMANDS = [
(dag_command.dag_pause, "airflowctl dags pause"),
(dag_command.dag_unpause, "airflowctl dags unpause"),
(dag_command.dag_list_dag_runs, "airflowctl dagrun list"),
+ (dag_command.dag_state, "airflowctl dags state"),
+ (dag_command.dag_next_execution, "airflowctl dags next-execution"),
(pool_command.pool_list, "airflowctl pools list"),
(pool_command.pool_get, "airflowctl pools get"),
(pool_command.pool_set, "airflowctl pools create"),
