如何在 Celery 中将任务添加到组中？

Question

我想在我的代码中逐步构建 group 的 Celery 任务，因为我将基于循环中的逻辑创建任务。

例如：

my_group = group()
for item in items:
    if item.is_special():
        # This doesn't work...
        my_group.add(special_processing.s(item.id))
    else:
        my_group.add(regular_processing.s(item.id))

 res = my_group()

我听说组是局部的，这很好，但是如何组合局部以使它们形成一个组？

Answer 1

到目前为止，我发现的一种简单方法是创建一个任务列表，然后将其转换为一个组。

所以：

tasks = []
for item in items:
    if item.is_special():
        tasks.append(special_processing.s(item.id))
    else:
        tasks.append(regular_processing.s(item.id))
res = group(*tasks)

我还没有对此进行测试，但如果这不起作用，我会更新这个答案。