rabbitmq - 带有广播队列的 Celery 定期任务

Question

我用 celery 和 celery beat 和 rabbit mq，一切都很好。

但是现在，我在广播队列上创建了一个定期任务，这不起作用。

芹菜配置文件

from kombu.common import Broadcast

CELERY_QUEUES=(
  Broadcast('for_all_webhosts')
)

任务.py

class PeriodicScript(PeriodicTask):
  run_every = crontab(minute='*/2', hour='*')
  time_limit = 300
  soft_time_limit = 600

  queue = 'for_all_webhosts'

  def run(self, *args, **kwargs):
    logger.error("START")

在日志文件中我可以看到任务被触发，但任务没有运行

Scheduler: Sending due task tasks.periodic_xxx.PeriodicScript (tasks.periodic_xxx.PeriodicScript)

如何在广播队列中启动周期性脚本？

谢谢

马塞尔