0
我在一個DAG中有三個任務。不管下游發生什麼，氣流任務都會運行
任務A先運行。如果任務A成功，則任務B運行。
我有任務C在任務B後運行，但它不依賴任務B或任務A成功或失敗。
任務C需要不管發生在任務A和B上的情況如何。但是，它需要在任務A和B完成之後運行。
有什麼想法？
A
回答
1
爲了有一個任務運行其他任務完成後，但無論其執行的結果，像trigger_rule參數設置爲all_done這樣：
my_task = MyOperator(task_id='my_task',
trigger_rule='all_done'
更多選項
見 trigger rule documentation相關問題
- 1. 氣流任務陷入「排隊」狀態，永遠不會運行
- 2. 氣流 - 運行任務，無論上游成功/失敗
- 3. 窗戶關閉時運行任務會發生什麼？
- 4. 取消任務時會發生什麼？
- 5. 如果標記成功，即使下游清除了上游任務，氣流強制重新運行
- 6. 當ContinueWhenAny被調用時，剩下的任務會發生什麼？
- 7. 氣流返回「回填完成」而不運行任務
- 8. 氣流任務沒有被觸發
- 9. Android Java：在運行多個任務的AsyncTask中會發生什麼？
- 10. 當我運行下面的命令時會發生什麼？
- 11. 爲什麼Swift中的任務不會發生？
- 12. Python每次運行時都不會運行，爲什麼？
- 13. 爲什麼我的氣流不按schedule_interval運行？
- 14. 氣流不會觸發與`LocalExecutor`同時發生的DAG
- 15. 當發生javascript運行時錯誤時會發生什麼？
- 16. 當程序運行時發生事件時會發生什麼
- 17. 當發生器運行的值不足以產生時會發生什麼？
- 18. 流程結束後會發生什麼？
- 19. 中斷HTTP流時會發生什麼？
- 20. 氣流任務在所有節點上運行
- 21. 在氣流主節點上運行一個特定的任務
- 22. 氣流：已排隊但未運行的任務
- 23. 在UNIX shell中運行exec csh會發生什麼？爲什麼？
- 24. 遊標不會返回一行，不管是什麼
- 25. 氣流失敗的任務不會返回數據？
- 26. PyGame：什麼都沒發生
- 27. 爲什麼當我使用嵌套for循環運行我的代碼時，什麼都不會發生？
- 28. 運行代碼時什麼都沒發生
- 29. 插入行上的遊標會在ResultSet＃next中發生什麼？
- 30. 如果我等待已經運行或正在運行的任務，會發生什麼情況？