`airflow.providers.standard.sensors.time`¶

模組內容¶

類別¶

`StartTriggerArgs`	從觸發器啟動任務執行所需的引數。
`TimeSensor`	等待直到一天中的指定時間。
`TimeSensorAsync`	等待直到一天中的指定時間。

class airflow.providers.standard.sensors.time.StartTriggerArgs[原始碼]¶

從觸發器啟動任務執行所需的引數。

trigger_cls: str[原始碼]¶

next_method: str[原始碼]¶

trigger_kwargs: dict[str, Any] | None[原始碼]¶

next_kwargs: dict[str, Any] | None[原始碼]¶

timeout: datetime.timedelta | None[原始碼]¶

class airflow.providers.standard.sensors.time.TimeSensor(*, target_time, **kwargs)[原始碼]¶

基底類別： airflow.sensors.base.BaseSensorOperator

等待直到一天中的指定時間。

參數: target_time (datetime.time) – 作業成功的時間

參見

有關如何使用此感測器的更多資訊，請參閱指南： TimeSensor

poke(context)[原始碼]¶

衍生此類別時覆寫。

class airflow.providers.standard.sensors.time.TimeSensorAsync(*, target_time, start_from_trigger=False, trigger_kwargs=None, end_from_trigger=False, **kwargs)[原始碼]¶

基底類別： airflow.sensors.base.BaseSensorOperator

等待直到一天中的指定時間。

這會在等待時釋放 worker 插槽。

參數

target_time (datetime.time) – 作業成功的時間
start_from_trigger (bool) – 直接從觸發器啟動任務，而無需進入 worker。
end_from_trigger (bool) – 直接從觸發器結束任務，而無需進入 worker。
trigger_kwargs (dict[str, Any] | None) – 當 start_from_trigger 設定為 True 以進行動態任務映射時，傳遞給觸發器的關鍵字引數。此引數在標準用法中未使用。

參見

有關如何使用此感測器的更多資訊，請參閱指南： TimeSensorAsync

start_trigger_args[原始碼]¶

start_from_trigger = False[原始碼]¶

execute(context)[原始碼]¶

在建立運算子時衍生。

Context 是與呈現 Jinja 模板時使用的相同字典。

請參閱 get_template_context 以取得更多上下文。

execute_complete(context, event=None)[原始碼]¶

在觸發器觸發時處理事件並立即返回。

airflow.providers.standard.sensors.time¶

模組內容¶

類別¶

`airflow.providers.standard.sensors.time`¶