airflow.triggers.testing¶

类¶

`SuccessTrigger`	一个会立即成功触发的触发器。
`FailureTrigger`	一个会立即报错的触发器。

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

一个会立即成功触发的触发器。

仅应用于测试。

serialize()[source]¶

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

async run()[source]¶

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

触发器在需要触发事件时应 yield 一个 Event，并在完成后返回 None。因此，单事件触发器应该 yield 一次然后立即返回。

如果它进行了 yield，则很可能会很快被恢复，但也不一定（例如，如果工作负载正在迁移到另一个 triggerer 进程，或者多事件触发器被用于单事件任务的 defer）。

无论哪种情况，Trigger 类都应假定它们会被持久化，并在不再需要时依赖于 cleanup() 方法的调用。

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

一个会立即报错的触发器。