等待列表中第一个完成/失败的芹菜任务

Question

我有一个芹菜任务列表：

tasks = []
tasks.append(f.delay(...))

如何完成第一个任务(失败和成功状态(？

result = get_first_waiting(tasks)

类似于 Javascript 中的Promise.race

Answer 1

你可以做这样的事情

for task in tasks:
    if task.ready() and task.status == "SUCCESS" and task.result:
        #do something

要检查第一个任务状态，只需执行此操作

first_task = tasks[0]
status = first_task.status