セールスAsyncResultのタスク名を取得

Question

私は非同期タスクを実行するためにセロリを使用していますが、私が達成しようとしているのは、実行した後にワークフロー内の各タスクの名前とIDを取得することです。

 exec_workflow = chain(
      task1.si(), 
      task2.si(), 
      task3.si() 
    ) 

    result = exec_workflow.apply_async() 

    tasks = [] 
    for t in result._parents(): 
     tasks.append({"id": t.id, "name": t.name}) 

しかし、AsyncResultにはいくつかの奇妙な理由で名前プロパティがないようです。これを行うための適切な方法は何であろうか？

私はapply_asyncを実行する前にidを各タスクに強制して、これが私の問題を解決するため、別のアプローチではidをタスク名に一致させることができます。しかし、私は可能かどうかは分かりません。

ありがとうございました。

Answer 1

申し訳ありませんので、問題を解決しました。私は最終的に各タスクのidプロパティを設定するだけでした。