Merge pull request #1432 from uwcirg/bug/celery-backend

Configure redis backend from existing values
uwcirg · Sep 28, 2017 · 7b452a5 · 7b452a5
2 parents 1cc9b3b + 1ec01e0
commit 7b452a5
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/portal/config.py b/portal/config.py
@@ -34,6 +34,10 @@ class BaseConfig(object):
         'CELERY_BROKER_URL',
         REDIS_URL
     )
+    CELERY_RESULT_BACKEND = os.environ.get(
+        'CELERY_RESULT_BACKEND',
+        REDIS_URL
+    )
     REQUEST_CACHE_URL = os.environ.get(
         'REQUEST_CACHE_URL',
         REDIS_URL

diff --git a/portal/factories/celery.py b/portal/factories/celery.py
@@ -11,13 +11,15 @@ def create_celery(app):
     global __celery
     if __celery:
         return __celery
+
     celery = Celery(
         app.import_name,
-        broker=app.config['CELERY_BROKER_URL']
+        backend=app.config['CELERY_RESULT_BACKEND'],
+        broker=app.config['CELERY_BROKER_URL'],
     )
     celery.conf.update(app.config)
-    TaskBase = celery.Task
 
+    TaskBase = celery.Task
     class ContextTask(TaskBase):
         abstract = True