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]

在异步上下文中运行触发器。

每当触发器想要触发事件时，它应该产生一个事件，如果它完成，则返回 None。 因此，单事件触发器应该先 yield，然后立即返回。

如果它 yield，它很可能会很快恢复，但可能不会（例如，如果工作负载正在被移动到另一个触发器进程，或者一个多事件触发器被用于单事件任务延迟）。

在任何一种情况下，触发器类都应假设它们将被持久化，然后依赖于在不再需要它们时调用 cleanup()。

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

基类: airflow.triggers.base.BaseTrigger

一个总是立即出错的触发器。

仅应在测试中使用。

serialize()[source]

返回重建此触发器所需的信息。

返回

（类路径，重新实例化所需的关键字参数）的元组。

返回类型

tuple[str, dict[str, Any]]

async run()[source]

在异步上下文中运行触发器。

每当触发器想要触发事件时，它应该产生一个事件，如果它完成，则返回 None。 因此，单事件触发器应该先 yield，然后立即返回。

如果它 yield，它很可能会很快恢复，但可能不会（例如，如果工作负载正在被移动到另一个触发器进程，或者一个多事件触发器被用于单事件任务延迟）。

在任何一种情况下，触发器类都应假设它们将被持久化，然后依赖于在不再需要它们时调用 cleanup()。

此条目是否有帮助？