airflow.triggers.testing¶

類¶

`SuccessTrigger`	一個會立即成功觸發的觸發器。
`FailureTrigger`	一個會立即報錯的觸發器。

class airflow.triggers.testing.SuccessTrigger(**kwargs)[source]¶

一個會立即成功觸發的觸發器。

僅應用於測試。

serialize()[source]¶

返回重建此觸發器所需的資訊。

async run()[source]¶

在非同步上下文中執行觸發器。

觸發器在需要觸發事件時應 yield 一個 Event，並在完成後返回 None。因此，單事件觸發器應該 yield 一次然後立即返回。

如果它進行了 yield，則很可能會很快被恢復，但也不一定（例如，如果工作負載正在遷移到另一個 triggerer 程序，或者多事件觸發器被用於單事件任務的 defer）。

無論哪種情況，Trigger 類都應假定它們會被持久化，並在不再需要時依賴於 cleanup() 方法的呼叫。

class airflow.triggers.testing.FailureTrigger(**kwargs)[source]¶

一個會立即報錯的觸發器。