(airflow) branch main updated: Enable PT006 rule to celery Provider test (#57938)

[shahar]

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

shahar 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 884cbeb3a0f Enable PT006 rule to celery Provider test (#57938)
884cbeb3a0f is described below

commit 884cbeb3a0f154c84d5bef66d2fc1b12a6a77514
Author: ChenChen Lai <72776271+0l...@users.noreply.github.com>
AuthorDate: Sat Nov 8 02:37:42 2025 +0800

    Enable PT006 rule to celery Provider test (#57938)
---
 providers/celery/tests/unit/celery/executors/test_celery_executor.py  | 2 +-
 .../tests/unit/celery/executors/test_celery_kubernetes_executor.py    | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/providers/celery/tests/unit/celery/executors/test_celery_executor.py 
b/providers/celery/tests/unit/celery/executors/test_celery_executor.py
index b43aefacfbd..c45090a0a44 100644
--- a/providers/celery/tests/unit/celery/executors/test_celery_executor.py
+++ b/providers/celery/tests/unit/celery/executors/test_celery_executor.py
@@ -178,7 +178,7 @@ class TestCeleryExecutor:
 
     @pytest.mark.skipif(AIRFLOW_V_3_0_PLUS, reason="Airflow 3 doesn't have 
execute_command anymore")
     @pytest.mark.parametrize(
-        "command, raise_exception",
+        ("command", "raise_exception"),
         [
             pytest.param(["true"], True, id="wrong-command"),
             pytest.param(["airflow", "tasks"], True, id="incomplete-command"),
diff --git 
a/providers/celery/tests/unit/celery/executors/test_celery_kubernetes_executor.py
 
b/providers/celery/tests/unit/celery/executors/test_celery_kubernetes_executor.py
index 8073cae4d8b..f6a3333ac7d 100644
--- 
a/providers/celery/tests/unit/celery/executors/test_celery_kubernetes_executor.py
+++ 
b/providers/celery/tests/unit/celery/executors/test_celery_kubernetes_executor.py
@@ -143,7 +143,7 @@ class TestCeleryKubernetesExecutor:
             k8s_executor_mock.queue_task_instance.assert_not_called()
 
     @pytest.mark.parametrize(
-        "celery_has, k8s_has, cke_has",
+        ("celery_has", "k8s_has", "cke_has"),
         [
             (True, True, True),
             (False, True, True),
@@ -164,7 +164,7 @@ class TestCeleryKubernetesExecutor:
         if not celery_has:
             k8s_executor_mock.has_task.assert_called_once_with(ti)
 
-    @pytest.mark.parametrize("num_k8s, num_celery", [(1, 0), (0, 1), (2, 1)])
+    @pytest.mark.parametrize(("num_k8s", "num_celery"), [(1, 0), (0, 1), (2, 
1)])
     def test_adopt_tasks(self, num_k8s, num_celery):
         celery_executor_mock = mock.MagicMock()
         k8s_executor_mock = mock.MagicMock()