`airflow.triggers.testing`¶

模組內容¶

`SuccessTrigger`	一個總是立即成功的觸發器。
`FailureTrigger`	一個總是立即錯誤的觸發器。

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

一個總是立即成功的觸發器。

僅應用於測試。

serialize()[source]¶

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

async run()[source]¶

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

每當觸發器想要觸發事件時，都應該產生一個事件，如果完成，則返回 None。因此，單事件觸發器應先產生，然後立即返回。

如果它產生，則很可能很快就會恢復，但也可能不會（例如，如果工作負載正在移動到另一個觸發器進程，或者多事件觸發器用於單事件任務延遲）。

在任何一種情況下，觸發器類別都應假定它們將被持久化，然後依賴於在不再需要它們時調用 cleanup()。

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

一個總是立即錯誤的觸發器。