Python Celery:更新AsyncResu的状态

Question

在父任务成功后，根据其某些子任务的结果，我希望更新任务状态。在

但是： 1/I找不到基于其id检索实际任务实例的方法，只能根据其AsyncResult

def level5_success(task_id):
  result = app.AsyncResult(task_id)
  # Set the parent task state (do not work)
  app.AsyncResult(task_id).update_state(state='HOWAREYOUDOING') 

2/I无法找到更新AsyncResult状态的方法，只能使用update_state更新任务本身的状态：

^{pr2}$

有什么想法吗？在

Answer 1

感觉你的操作超出了芹菜的设计范围。工作状态和过程的协调应该通过worker canvas来完成，而不是通过摆弄芹菜的内部结构。即使你能让它正常工作，我也怀疑celery打算与其API保持一致的合同中是否存在国家黑客攻击；你的工作完全有可能因celery的未来更改而中断。在

你想做什么你不能做的团体，和弦和锁链？在