airflow.decorators.condition

模組內容

函數

run_if(condition[, skip_message])

裝飾一個任務，使其僅在滿足條件時執行。

skip_if(condition[, skip_message])

裝飾一個任務，使其在滿足條件時跳過。
airflow.decorators.condition.run_if(condition, skip_message=None)[source]

裝飾一個任務，使其僅在滿足條件時執行。

參數

  • condition (AnyConditionFunc) – 一個接受上下文並返回布林值的函數。

  • skip_message (str | None) – 如果任務被跳過，要記錄的訊息。如果為 None，則使用預設訊息。

airflow.decorators.condition.skip_if(condition, skip_message=None)[source]

裝飾一個任務，使其在滿足條件時跳過。

參數

  • condition (AnyConditionFunc) – 一個接受上下文並返回布林值的函數。

  • skip_message (str | None) – 如果任務被跳過，要記錄的訊息。如果為 None，則使用預設訊息。

此條目是否有幫助？