2017-01-25 36 views
1

我使用芹菜來執行我的異步任務和我想要做到的,是我後執行得到它的名字,並在工作流程的每個任務的ID的任務名稱。得到芹菜AsyncResult

 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沒有name屬性一些奇怪的原因。任何想法是什麼將是適當的方式來做到這一點?

一種不同的方法來解決這也許,迫使每個任務的ID之前,我執行apply_async,這將解決我的問題,因爲我將能夠匹配ID,以任務名稱。但我不確定它是否可能。

謝謝。

回答

0

好了,所以我已經解決了我的問題。我最終做的是隻設置每個任務的id屬性。

+0

你能提供一個這樣的例子? – Nitred