Updated celery config usage to new lowercase settings (#1185)

* Updated celery config usage to new lowercase settings

Ref: https://docs.celeryproject.org/en/v5.2.3/userguide/configuration.html#new-lowercase-settings

* Update tasks.py

* Update broker.py

Author: vinayinvicible

examples/tasks.py

@@ -8,8 +8,8 @@
 app = Celery("tasks",
              broker=os.environ.get('CELERY_BROKER_URL', 'redis://'),
              backend=os.environ.get('CELERY_RESULT_BACKEND', 'redis'))
-app.conf.CELERY_ACCEPT_CONTENT = ['pickle', 'json', 'msgpack', 'yaml']
-app.conf.CELERY_WORKER_SEND_TASK_EVENTS = True
+app.conf.accept_content = ['pickle', 'json', 'msgpack', 'yaml']
+app.conf.worker_send_task_events = True
 
 
 @app.task

flower/api/tasks.py

@@ -396,24 +396,24 @@ async def get(self):
 :statuscode 503: result backend is not configured
         """
         app = self.application
-        broker_options = self.capp.conf.BROKER_TRANSPORT_OPTIONS
+        broker_options = self.capp.conf.broker_transport_options
 
         http_api = None
         if app.transport == 'amqp' and app.options.broker_api:
             http_api = app.options.broker_api
 
         broker_use_ssl = None
-        if self.capp.conf.BROKER_USE_SSL:
-            broker_use_ssl = self.capp.conf.BROKER_USE_SSL
+        if self.capp.conf.broker_use_ssl:
+            broker_use_ssl = self.capp.conf.broker_use_ssl
 
         broker = Broker(app.capp.connection().as_uri(include_password=True),
                         http_api=http_api, broker_options=broker_options, broker_use_ssl=broker_use_ssl)
 
         queue_names = self.get_active_queue_names()
 
         if not queue_names:
-            queue_names = set([self.capp.conf.CELERY_DEFAULT_QUEUE]) |\
-                set([q.name for q in self.capp.conf.CELERY_QUEUES or [] if q.name])
+            queue_names = set([self.capp.conf.task_default_queue]) |\
+                set([q.name for q in self.capp.conf.task_queues or [] if q.name])
 
         queues = await broker.queues(sorted(queue_names))
         self.write({'active_queues': queues})

flower/views/broker.py

@@ -15,15 +15,15 @@ class BrokerView(BaseHandler):
     @web.authenticated
     async def get(self):
         app = self.application
-        broker_options = self.capp.conf.BROKER_TRANSPORT_OPTIONS
+        broker_options = self.capp.conf.broker_transport_options
 
         http_api = None
         if app.transport == 'amqp' and app.options.broker_api:
             http_api = app.options.broker_api
 
         broker_use_ssl = None
-        if self.capp.conf.BROKER_USE_SSL:
-            broker_use_ssl = self.capp.conf.BROKER_USE_SSL
+        if self.capp.conf.broker_use_ssl:
+            broker_use_ssl = self.capp.conf.broker_use_ssl
 
         try:
             broker = Broker(app.capp.connection(connect_timeout=1.0).as_uri(include_password=True),
@@ -36,8 +36,8 @@ async def get(self):
         try:
             queue_names = self.get_active_queue_names()
             if not queue_names:
-                queue_names = set([self.capp.conf.CELERY_DEFAULT_QUEUE]) |\
-                        set([q.name for q in self.capp.conf.CELERY_QUEUES or [] if q.name])
+                queue_names = set([self.capp.conf.task_default_queue]) |\
+                        set([q.name for q in self.capp.conf.task_queues or [] if q.name])
 
             queues = await broker.queues(sorted(queue_names))
         except Exception as e:

flower/views/tasks.py

@@ -114,8 +114,8 @@ def get(self):
         capp = self.application.capp
 
         time = 'natural-time' if app.options.natural_time else 'time'
-        if capp.conf.CELERY_TIMEZONE:
-            time += '-' + str(capp.conf.CELERY_TIMEZONE)
+        if capp.conf.timezone:
+            time += '-' + str(capp.conf.timezone)
 
         self.render(
             "tasks.html",