小编Ale*_*Dow的帖子

# get a list of stuff
@celery.task
def getList():
    listOfStuff = getStuff()
    for thing in listOfStuff:
        processThing.apply_async(args=(thing))


# another attempt at list of stuff
@celery.task
def getList():
    listOfStuff = getStuff()
    for thing in listOfStuff:
        processThing.s((thing))

@celery.task
def processThing(thing):
    pass

因此 getList() 实现都不会触发 processThing 任务。我不明白为什么。我猜想有一种更好的方法来完成我想要完成的任务，但我不知道那是什么。

如何从另一个任务中启动任务？