From e945013b392f8081bed95290974f281be41898d6 Mon Sep 17 00:00:00 2001
From: Soban Javed <iamsobanjaved@gmail.com>
Date: Thu, 27 Aug 2020 18:42:49 +0500
Subject: [PATCH] Make redis broker compatible with celery 4.0
---
cms/envs/production.py | 5 +++++
lms/envs/production.py | 5 +++++
2 files changed, 10 insertions(+)
diff --git a/cms/envs/production.py b/cms/envs/production.py
index cde0bbc9770..263d4284bf1 100644
--- a/cms/envs/production.py
+++ b/cms/envs/production.py
@@ -406,6 +406,11 @@ BROKER_URL = "{0}://{1}:{2}@{3}/{4}".format(CELERY_BROKER_TRANSPORT,
CELERY_BROKER_VHOST)
BROKER_USE_SSL = ENV_TOKENS.get('CELERY_BROKER_USE_SSL', False)
+BROKER_TRANSPORT_OPTIONS = {
+ 'fanout_patterns': True,
+ 'fanout_prefix': True,
+}
+
# Message expiry time in seconds
CELERY_EVENT_QUEUE_TTL = ENV_TOKENS.get('CELERY_EVENT_QUEUE_TTL', None)
diff --git a/lms/envs/production.py b/lms/envs/production.py
index d0b3e299d42..a50e72ead06 100644
--- a/lms/envs/production.py
+++ b/lms/envs/production.py
@@ -542,6 +542,11 @@ BROKER_URL = "{0}://{1}:{2}@{3}/{4}".format(CELERY_BROKER_TRANSPORT,
CELERY_BROKER_VHOST)
BROKER_USE_SSL = ENV_TOKENS.get('CELERY_BROKER_USE_SSL', False)
+BROKER_TRANSPORT_OPTIONS = {
+ 'fanout_patterns': True,
+ 'fanout_prefix': True,
+}
+
# Block Structures
# upload limits
--
GitLab