Airflow Summit 2025 將於 10 月 07 日至 09 日舉行。立即註冊享早鳥票!

airflow.triggers.testing

SuccessTrigger

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

FailureTrigger

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

模組內容

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

基類: airflow.triggers.base.BaseTrigger

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

僅應用於測試。

serialize()[source]

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

返回:

一個元組,包含 (類路徑, 用於重新例項化的關鍵字引數)。

返回型別:

tuple[str, dict[str, Any]]

async run()[source]

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

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

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

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

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

基類: airflow.triggers.base.BaseTrigger

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

僅應用於測試。

serialize()[source]

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

返回:

一個元組,包含 (類路徑, 用於重新例項化的關鍵字引數)。

返回型別:

tuple[str, dict[str, Any]]

async run()[source]

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

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

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

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

此條目是否有幫助?