fix: missing global queue (#539)

Author: iziang

config/celery.py

@@ -9,6 +9,7 @@
 app = Celery("kubechat")
 app.conf.task_queues = (
     Queue(LOCAL_QUEUE_NAME, Exchange(LOCAL_QUEUE_NAME), routing_key=LOCAL_QUEUE_NAME,priority=10),
+    Queue("celery", Exchange("celery")),
 )
 
 # Using a string here means the worker doesn't have to serialize
@@ -22,7 +23,6 @@
 app.autodiscover_tasks()
 
 
-
 if LOCAL_QUEUE_NAME != "":
     app.conf.task_routes = {
         "kubechat.tasks.index.add_index_for_local_document": {"queue": f"{LOCAL_QUEUE_NAME}"},