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")