根据DAG是否被手动触发而有不同的行为。

Question

我知道Airflow会区分DAG的手动触发和计划触发--它们的ID的模式是不同的，而且在Tree View中的UI会为其中一个显示一个轮廓圆圈，但不会显示另一个。

我有一个DAG，它使用Python可调用作为 on_failure_callback 以发出失败警报。现在，我想修改这个DAG，使它能在出现一个 人工触发 运行失败，而当调度器触发运行时，却发出不同的警报。

我可以通过简单地解析字符串中的 {{ execution_date }}. 然而，这似乎是黑客。是否有一个标志，我可以检查？

Answer 1

似乎和这个问题非常相关。我可以通过编程来确定气流DAG是预定的还是手动触发的？

看起来你可以查找run_id，然后解析它，这可能会稍微好一点。