We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2a7d599 commit a9ffe43Copy full SHA for a9ffe43
1 file changed
rootfs/helmbroker/celery.py
@@ -2,6 +2,8 @@
2
from celery import Celery
3
4
5
+# The queue and exchange names cannot be the same
6
+# otherwise an error will occur when enabling the sharding plugin
7
class Config:
8
# Celery Configuration Options
9
timezone = "Asia/Shanghai"
@@ -18,7 +20,9 @@ class Config:
18
20
worker_max_tasks_per_child = 200
19
21
result_expires = 24 * 60 * 60
22
broker_connection_retry_on_startup = True
- task_default_queue = 'helmbroker.priority.low'
23
+ task_default_queue = 'low'
24
+ task_default_exchange = 'helmbroker.priority'
25
+ task_default_routing_key = 'helmbroker.priority.low'
26
worker_cancel_long_running_tasks_on_connection_loss = True
27
28
0 commit comments