App: Backend argument must also set CELERY_RESULT_BACKEND config

wjt · Jul 4, 2014 · 9a21a06 · 9a21a06
1 parent 854379d
commit 9a21a06
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/celery/app/base.py b/celery/app/base.py
@@ -127,7 +127,6 @@ def __init__(self, main=None, loader=None, backend=None,
         self.clock = LamportClock()
         self.main = main
         self.amqp_cls = amqp or self.amqp_cls
-        self.backend_cls = backend or self.backend_cls
         self.events_cls = events or self.events_cls
         self.loader_cls = loader or self.loader_cls
         self.log_cls = log or self.log_cls
@@ -161,6 +160,8 @@ def __init__(self, main=None, loader=None, backend=None,
         self._preconf = changes or {}
         if broker:
             self._preconf['BROKER_URL'] = broker
+        if backend:
+            self._preconf['CELERY_RESULT_BACKEND'] = backend
         if include:
             self._preconf['CELERY_IMPORTS'] = include