【发布时间】:2018-02-12 14:18:12
【问题描述】:
我有一个并发为10 的队列,当我同时运行 11 个任务时,Celery 不会向第 11 个任务的结果后端发送任何内容,因此无法获取那 1 个额外的任务。
我已经用 Redis 和 MySQL 作为结果后端测试了这种情况。
我是否遗漏了什么,或者是否有为这些待处理任务设置自定义状态?
【问题讨论】:
我有一个并发为10 的队列,当我同时运行 11 个任务时,Celery 不会向第 11 个任务的结果后端发送任何内容,因此无法获取那 1 个额外的任务。
我已经用 Redis 和 MySQL 作为结果后端测试了这种情况。
我是否遗漏了什么,或者是否有为这些待处理任务设置自定义状态?
【问题讨论】:
就我而言,我可以使用 Celery 信号 before-task-publish:
http://docs.celeryproject.org/en/latest/userguide/signals.html#before-task-publish
【讨论】: