Celery 在其他任务完成后启动任务

Question

我在 Celery 中有 3 个任务..

celery_app.send_task('tasks.read_cake_recipes')
celery_app.send_task('tasks.buy_ingredients')

celery_app.send_task('tasks.make_cake')

read_cake_recipes 和 buy_ingredients 都没有任何依赖关系，但是在任务 make_cake 可以运行之前，read_cake_recipes 和 buy_ingredients 都需要完成。

make_cake 可以在前两个启动后的任何时间运行。但是make_cake 不知道其他任务是否已经完成。所以如果read_cake_recipes 或buy_ingredients 花费的时间太长，那么make_cake 就会惨遭失败。

链接任务似乎在这里不起作用，因为make_cake 有多个依赖项。

我怎样才能仍然开始任务make_cake，但让它等待/挂起等，直到其他两个任务首先完成？

我的优点是 read_cake_recipes 和 buy_ingredients 将结果保存到数据库中，如果 make_cake 知道要查找哪些成分或食谱，也许可以检查一下？

Answer 1

完全猜测您的底层架构，但这里是..

class Cake(models.Model):
    recipes_read = models.BooleanField(default=False)
    ingredients_purchased = models.BooleanField(default=False)
    batter_prepared = models.BooleanField(default=False)

    def save(self, *args, **kwargs):
        if self.recipes_read and self.ingredients_purchased:
            self.batter_prepared = True
        super(Cake, self).save(*args, **kwargs)


@task
read_cake_recipes():
    for cake in Cake.objects.all():
        # Read some shit!
        cake.recipes_read = True
        cake.save()

@task
buy_cake_ingredients():
    for cake in Cake.objects.all():
        # Buy some shit!
        cake.ingredients_purchased = True
        cake.save()

@task
make_cake():
    for cake in Cake.objects.filter(batter_prepared=True):
        # Make that shit!