dag 圖
如上圖所示,有很多上游任務與oneTaskFailed.
我設定了只要一項任務失敗,就會觸發電子郵件警報。
但是當我發送郵件時,如何確定觸發警報的任務 ID 并同時發送任務的日志鏈接?
uj5u.com熱心網友回復:
在 onTaskFailed 中,您可以從背景關系中獲取 dag_run。
然后你可以找到當前 dag 中運行的 TaskInstances 并找到錯誤狀態的那個。
def on_failed_task(**context):
dagrun: DAG = context["dag_run"]
failed_ti = [ti for ti in dagrun.get_task_instances() if ti.state == State.FAILED]
print(failed_ti)
轉載請註明出處,本文鏈接:https://www.uj5u.com/net/487341.html
