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 <[email protected]>
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")
