V 币急等感谢---关于 djcelery 配置 queue 不生效 [也谈 workflow 子任务锁死问题]

我 celery 版本为 v3.1.25 ，django 和 celery 的启动项如下：

celery -A proj-test worker -n workerA.%h --concurrency=2
celery -A proj-test worker -n workerB.%h --concurrency=2
python manage.py celeryd -B
python manage.py celery beat
python manage.py runserver 0.0.0.0:8000

这样是可以运行的，不过好像由于我在 celery 的 task 里面，使用了 workflow 的 chord/group 进行 subtask 分发，导致 subtask 过多时，因为 concurrency 有限，beat 任务（ beat_function ）会因此堵塞结束不掉。

大概代码如下，下面至少有两个 chord：

@task
def beat_function():
	xxfunc1.delay()
    xxfunc2.delay()
	time.sleep(5)
    chord((test1.s(x) for x in xs) , test2.s())
    chord((test3.s(y) for y in ys) , test4.s())

所以我有个问题，想问问大家能否指定 beat 的 queue。

让它不会占用其他 subtask 运行的 worker 容量，这样就算 beat 所在的 queue 在阻塞，等到 subtask 运行完毕，这边 queue 也会结束相应的 beat 任务。

我是这样弄得，queue 配置如下：

CELERY_QUEUES = {
    "celery_beat": { 
        "exchange": "celery_beat",
        "exchange_type": "direct",
        "routing_key": "celery_beat"
    },
}

尝试过的 beat 运行方式如下两种

python manage.py celeryd -B -Q celery_beat

也尝试了下面的运行法子：

python manage.py celery worker  -B -Q celery_beat

不过始终不能把 beat 任务运行起来，每次一加 queue 似乎 beat 就失效了。

尝试过同时单独运行，也失败：

python manage.py celery worker --beat
python manage.py celery worker -Q celery_beat

希望大佬们，帮忙解答下面两个问题：

单独 queue 运行 beat 任务能否解决我那个死锁问题？

我不能每次手动结束 beat 任务，确实结束了能解决某一次死锁，那些 subtask 能运行完。我曾尝试设置任务超时，单个 chord 的时可用，该 chord 可以运行完结，不过后面还有 chord 分发其他子任务就 gg 了，也就是说只能运行完第一个 chord，比如我上面举的例子。

我的上面的运行 beat 的方法是否有误，加了 queue 配置是否有误或者不完整，导致我 beat 任务运行不起来？

我想要实现的是，单个 queue 指定的那些 worker，运行所有的 beat 任务，现在的情况是所有的 worker 都会去抢 beat 任务，结果可能导致了部分 beat 任务阻塞。