diff --git a/src/pytest_celery/api/setup.py b/src/pytest_celery/api/setup.py index 1807eef24..cd98956cb 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 83d454664..bf74df450 100644 --- a/tests/smoke/test_canvas.py +++ b/tests/smoke/test_canvas.py @@ -69,9 +69,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