Fixed bug where default env were overriding custom env vars

celery · Jan 8, 2024 · 73692e6 · 73692e6
1 parent 5e863ab
commit 73692e6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/pytest_celery/vendors/worker/container.py b/src/pytest_celery/vendors/worker/container.py
@@ -71,7 +71,7 @@ def buildargs(cls) -> dict:
     @classmethod
     def env(cls, celery_worker_cluster_config: dict, initial: dict | None = None) -> dict:
         env = initial or {}
-        env = {**env, **DEFAULT_WORKER_ENV.copy()}
+        env = {**DEFAULT_WORKER_ENV.copy(), **env}
 
         config_mappings = [
             ("celery_broker_cluster_config", "CELERY_BROKER_URL"),