python - 如何停止从任务运行的 Airflow DAG

Question

所以我有一个 Airflow DAG 任务，它对文件执行多项检查(例如，如果它过去已经处理过)，如果其中一项检查失败，我希望整个 DAG 运行完全停止。我怎样才能做到这一点？

基本上检查是在 python 脚本中完成的。

谢谢 :

Answer 1

假设您没有忽略先前任务失败的下游任务，从任务内部引发异常将导致 DAG 停止处理并被标记为失败。

因此，在您的情况下，当您发现文件已被处理时，您可以引发异常。