有人知道如何实现下一个功能吗?当您将气流中的任务标记为失败时,这会停止气流进程,但这不会停止Yarn中运行的应用程序。类似于
except KeyboardInterrupt:
当应用程序在终端中运行时。
gpfsuwkq1#
通过使用回调概念https://airflow.apache.org/docs/apache-airflow/2.2.2/logging-monitoring/callbacks.html,可以在成功或失败时调用函数
1条答案
按热度按时间gpfsuwkq1#
通过使用回调概念https://airflow.apache.org/docs/apache-airflow/2.2.2/logging-monitoring/callbacks.html,可以在成功或失败时调用函数