airflow.decorators.condition

模块内容

函数

run_if(condition[, skip_message])

装饰一个任务，使其仅在满足条件时运行。

skip_if(condition[, skip_message])

装饰一个任务，使其在满足条件时跳过。
airflow.decorators.condition.run_if(condition, skip_message=None)[源代码]

装饰一个任务，使其仅在满足条件时运行。

参数

  • condition (AnyConditionFunc) – 一个接受上下文并返回布尔值的函数。

  • skip_message (str | None) – 如果任务被跳过，要记录的消息。如果为 None，则使用默认消息。

airflow.decorators.condition.skip_if(condition, skip_message=None)[源代码]

装饰一个任务，使其在满足条件时跳过。

参数

  • condition (AnyConditionFunc) – 一个接受上下文并返回布尔值的函数。

  • skip_message (str | None) – 如果任务被跳过，要记录的消息。如果为 None，则使用默认消息。

此条目是否有帮助？