セロリキャンバスで単一のグループのエラー伝搬を無効にするにはどうすればよいですか？

Question

考えると2つのタスク、ないいくつかの作業を行い1と別のクリーンアップ：

@app.task 
def work(): 
    ... 

@app.task 
def cleanup(): 
    ... 

作業タスクのグループに関係なく、かどうかのうちの1つまたは複数の、完了した後、私はクリーンアップタスクの実行を持っているしたいのですが作業タスクが失敗します。それが動作するようには思えない、

work_group = group([work.s() for i in range(0, 10)], propagate=False) 
work_and_cleanup = chain(work_group, cleanup) 

しかし：私はcanvas.apply_async(propagate=False)を実行することによって動作するようにこれを得ているが、私は実際には単一のグループのための伝搬をオフにします。 work_groupの伝播を拒否するにはどうすればよいですか？

Answer 1

タスクが成功した場合にのみチェーン、クリーンアップタスクをコールするためのリンクエラーコールバックを追加します。

work_and_cleanup.apply_async(link_error=cleanup.si())