From da9f2358c1fc9101e79d1ed32cfeb04c67488241 Mon Sep 17 00:00:00 2001 From: Tomer Nosrati Date: Thu, 11 Jan 2024 19:37:16 +0200 Subject: [PATCH] Cleanup --- src/pytest_celery/api/setup.py | 13 ------------- tests/smoke/test_canvas.py | 4 ---- 2 files changed, 17 deletions(-) diff --git a/src/pytest_celery/api/setup.py b/src/pytest_celery/api/setup.py index 1807eef2..cd98956c 100644 --- a/src/pytest_celery/api/setup.py +++ b/src/pytest_celery/api/setup.py @@ -145,19 +145,6 @@ def create_setup_app(cls, celery_setup_config: dict, celery_setup_app_name: str) return app - def chords_allowed(self) -> bool: - # TODO: Possibly a not relevant - try: - self.app.backend.ensure_chords_allowed() - except NotImplementedError: - return False - - # TODO: Possibly a bug - if any([v.startswith("4.") for v in self.worker_cluster.versions]): - return False - - return True - def teardown(self) -> None: """Teardown the setup.""" diff --git a/tests/smoke/test_canvas.py b/tests/smoke/test_canvas.py index 83d45466..ad41099a 100644 --- a/tests/smoke/test_canvas.py +++ b/tests/smoke/test_canvas.py @@ -1,6 +1,5 @@ from __future__ import annotations -import pytest from celery.canvas import chain from celery.canvas import chord from celery.canvas import group @@ -69,9 +68,6 @@ def test_chain(self, celery_setup: CeleryTestSetup): def test_chord(self, celery_setup: CeleryTestSetup): worker: CeleryTestWorker - if not celery_setup.chords_allowed(): - pytest.skip("Chords are not supported") - for worker in celery_setup.worker_cluster: queue = worker.worker_queue