Skip to content

Commit

Permalink
Cleanup (#163)
Browse files Browse the repository at this point in the history
  • Loading branch information
Nusnus authored Jan 11, 2024
1 parent be39fa0 commit 2cc4989
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 17 deletions.
13 changes: 0 additions & 13 deletions src/pytest_celery/api/setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -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."""

Expand Down
4 changes: 0 additions & 4 deletions tests/smoke/test_canvas.py
Original file line number Diff line number Diff line change
@@ -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
Expand Down Expand Up @@ -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

Expand Down

0 comments on commit 2cc4989

Please sign in to comment.