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

taragolis 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 7ac90b738c Fix PT012 checks for celery provider (#38357)
7ac90b738c is described below

commit 7ac90b738c0044bd86d201907ef5a57b1b4e53d9
Author: mahdi alizade <79321261+alizadem...@users.noreply.github.com>
AuthorDate: Thu Mar 21 13:01:23 2024 +0330

    Fix PT012 checks for celery provider (#38357)
    
    * Fix PT012 checks for celery provider
    
    * Remove extra whitespaces
---
 pyproject.toml                                      | 1 -
 tests/providers/celery/sensors/test_celery_queue.py | 2 +-
 2 files changed, 1 insertion(+), 2 deletions(-)

diff --git a/pyproject.toml b/pyproject.toml
index 277a212634..04b5b7d197 100644
--- a/pyproject.toml
+++ b/pyproject.toml
@@ -1514,7 +1514,6 @@ combine-as-imports = true
 "tests/providers/amazon/aws/waiters/test_neptune.py" = ["PT012"]
 "tests/providers/apache/hive/hooks/test_hive.py" = ["PT012"]
 "tests/providers/apache/hive/sensors/test_named_hive_partition.py" = ["PT012"]
-"tests/providers/celery/sensors/test_celery_queue.py" = ["PT012"]
 "tests/providers/cncf/kubernetes/executors/test_kubernetes_executor.py" = 
["PT012"]
 "tests/providers/cncf/kubernetes/hooks/test_kubernetes.py" = ["PT012"]
 "tests/providers/cncf/kubernetes/operators/test_pod.py" = ["PT012"]
diff --git a/tests/providers/celery/sensors/test_celery_queue.py 
b/tests/providers/celery/sensors/test_celery_queue.py
index f2d619e50c..e1b3d97c97 100644
--- a/tests/providers/celery/sensors/test_celery_queue.py
+++ b/tests/providers/celery/sensors/test_celery_queue.py
@@ -66,9 +66,9 @@ class TestCeleryQueueSensor:
         mock_inspect_result.reserved.return_value = {}
         mock_inspect_result.scheduled.return_value = {}
         mock_inspect_result.active.return_value = {}
+        test_sensor = self.sensor(celery_queue="test_queue", 
task_id="test-task", soft_fail=soft_fail)
 
         with pytest.raises(expected_exception):
-            test_sensor = self.sensor(celery_queue="test_queue", 
task_id="test-task", soft_fail=soft_fail)
             test_sensor.poke(None)
 
     @patch("celery.app.control.Inspect")

Reply via email to