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,以任務名稱。但我不確定它是否可能。
謝謝。
你能提供一個這樣的例子? – Nitred