diff --git a/src/pytest_celery/api/base.py b/src/pytest_celery/api/base.py index a18efa70..bfed5e03 100644 --- a/src/pytest_celery/api/base.py +++ b/src/pytest_celery/api/base.py @@ -262,7 +262,7 @@ def ready(self) -> bool: def config(self, *args: tuple, **kwargs: dict) -> dict: """Compile the configurations required for Celery from this cluster.""" - config = [node.container.celeryconfig for node in self] + config = [node.config() for node in self] return { "urls": [c["url"] for c in config], "host_urls": [c["host_url"] for c in config],