django celery 只调用 2 个 apply_async 任务中的 1 个

Question

我需要调用以下 2 个 apply_async 任务：

escalate.apply_async((e.id), countdown=3)
escalate.apply_async((e.id), countdown=3)

我的任务实现如下：

@app.task
def escalate(id, group):

      escalation_email, created = EscalationEmail.objects.get_or_create()
      escalation_email.send()

    return 'sup email sent'

我运行使用以下命令工作：

celery -A proj worker -l info --concurrency=10

问题是，当我查看 worker 时，只收到 1 个任务，然后只有 1 个成功。此外，仅发送 1 封电子邮件。

好像大部分时间都是第二次升级任务运行s.

如何确保这些任务都在 100% 的时间内可靠地触发？

Answer 1

问题是我没有选择一个队列来关联任务。

django celery 只调用 2 个 apply_async 任务中的 1 个

django celery only calls 1 of 2 apply_async task

python

django

celery

django-celery