From 54a9aa63383d6f1c7dfe9561ff28c6b111e3fb65 Mon Sep 17 00:00:00 2001 From: Tomer Nosrati Date: Sun, 17 Mar 2024 19:36:24 +0200 Subject: [PATCH] Bugfix: node.config() didn't allow overriding --- src/pytest_celery/api/base.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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],