芹菜开始时其他任务都已完成，

Question

我有芹菜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!