芹菜開始時其他任務都已完成，

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!