This is an automated email from the ASF dual-hosted git repository.

potiuk 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 f0d50bdb178 [AIP-94] Mark tasks CLI commands as migrated to airflowctl 
(#69274)
f0d50bdb178 is described below

commit f0d50bdb17868b52c733e16b40a7af2f4276fc0d
Author: Yash jain <[email protected]>
AuthorDate: Thu Jul 30 18:41:35 2026 +0530

    [AIP-94] Mark tasks CLI commands as migrated to airflowctl (#69274)
---
 airflow-core/src/airflow/cli/commands/task_command.py             | 2 ++
 airflow-core/tests/unit/cli/commands/test_command_deprecations.py | 3 +++
 2 files changed, 5 insertions(+)

diff --git a/airflow-core/src/airflow/cli/commands/task_command.py 
b/airflow-core/src/airflow/cli/commands/task_command.py
index 5c37710e046..8d27e58a885 100644
--- a/airflow-core/src/airflow/cli/commands/task_command.py
+++ b/airflow-core/src/airflow/cli/commands/task_command.py
@@ -291,6 +291,7 @@ def task_failed_deps(args) -> None:
         print("Task instance dependencies are all met.")
 
 
+@deprecated_for_airflowctl("airflowctl tasks state")
 @cli_utils.action_cli(check_db=False)
 @suppress_logs_and_warning
 @providers_configuration_loaded
@@ -308,6 +309,7 @@ def task_state(args) -> None:
     print(ti.state)
 
 
+@deprecated_for_airflowctl("airflowctl tasks list")
 @cli_utils.action_cli(check_db=False)
 @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 f6f28c5e85f..667a2dc7ff5 100644
--- a/airflow-core/tests/unit/cli/commands/test_command_deprecations.py
+++ b/airflow-core/tests/unit/cli/commands/test_command_deprecations.py
@@ -80,6 +80,9 @@ MIGRATED_CLI_COMMANDS = [
     (provider_command.providers_list, "airflowctl providers list"),
     (config_command.get_value, "airflowctl config get"),
     (config_command.show_config, "airflowctl config list"),
+    (task_command.task_failed_deps, "airflowctl tasks failed-deps"),
+    (task_command.task_state, "airflowctl tasks state"),
+    (task_command.task_list, "airflowctl tasks list"),
     (task_command.task_states_for_dag_run, "airflowctl tasks 
states-for-dag-run"),
     (task_command.task_clear, "airflowctl tasks clear"),
     (task_command.task_failed_deps, "airflowctl tasks failed-deps"),

Reply via email to