CELERY_RESULT_BACKEND fix (->amqp)

df89c7aa · Szeberényi Imre · abfd214b · df89c7aa
Commit df89c7aa authored Oct 01, 2021 by Szeberényi Imre
Hide whitespace changes
Inline Side-by-side

Showing with 4 additions and 3 deletions

fw.py
+4 -3

No files found.
--- a/fw.py
+++ b/fw.py
@@ -17,11 +17,12 @@ AMQP_URI = getenv('AMQP_URI')
 celery = Celery('tasks',)
 celery.conf.update(CELERY_TASK_RESULT_EXPIRES=300,
                   BROKER_URL=AMQP_URI,
+                   CELERY_CACHE_BACKEND=CACHE_URI,
+                   CELERY_RESULT_EXCHANGE_TYPE='direct',
+                   CELERY_RESULT_PERSISTENT=True,
+                   CELERY_RESULT_BACKEND='amqp',
                   CELERY_CREATE_MISSING_QUEUES=True)

-celery.conf.update(CELERY_CACHE_BACKEND=CACHE_URI,
-                   CELERY_RESULT_BACKEND='cache')
-
 logger = logging.getLogger(__name__)