airflow.triggers.temporal

模組內容

類別

DateTimeTrigger

基於日期時間的觸發器。

TimeDeltaTrigger

根據延遲建立 DateTimeTriggers。
class airflow.triggers.temporal.DateTimeTrigger(moment, *, end_from_trigger=False)[原始碼]

基底類別： airflow.triggers.base.BaseTrigger

基於日期時間的觸發器。

一種觸發器，在給定的日期時間精確觸發一次，容許幾秒的誤差。

提供的日期時間必須為 UTC 時間。

參數

  • moment (datetime.datetime) – 何時產生事件

  • end_from_trigger (bool) – 觸發器應在達到時間條件後標記任務成功，還是在達到時間條件後恢復任務。

serialize()[原始碼]

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

傳回

（類別路徑，重新實例化所需的關鍵字引數）的元組。

傳回類型

tuple[str, dict[str, Any]]

async run()[原始碼]

迴圈直到達到相關時間。

我們確實有一個兩階段的延遲來節省一些週期，但無論如何睡眠都很便宜，所以它非常寬鬆。我們也不只是睡眠「直到時間的秒數」，以防系統時鐘意外更改，或處理 DST 更改不佳。

class airflow.triggers.temporal.TimeDeltaTrigger(delta, *, end_from_trigger=False)[原始碼]

基底類別： DateTimeTrigger

根據延遲建立 DateTimeTriggers。

子類別，用於根據時間延遲而非確切時刻建立 DateTimeTriggers。

雖然這是它自己在此處的獨特類別，但它將序列化為 DateTimeTrigger 類別，因為它們在操作上是相同的。

參數

  • delta (datetime.timedelta) – 要等待多久

  • end_from_trigger (bool) – 觸發器應在達到時間條件後標記任務成功，還是在達到時間條件後恢復任務。

此條目是否有幫助？