如何在没有emailOperator或自定义PythonOperator的情况下为气流任务运行触发电子邮件

我们有一个特别气流DAG,任何人都可以触发它,从50+团队手动运行。

我们可以通过DAG id查看触发DAG的气流审计日志,我们还可以在失败时收到电子邮件。

有几种方法可以使用emailOperator或自定义Python Operator来触发电子邮件,但挑战是用户可能会将此任务标记为“成功”,并继续执行adhoc DAG的核心操作。

但我们更好奇的是,我们是否能在DAG启动时或在每个任务运行开始时收到电子邮件,这将帮助我们理解和跟踪从adhoc DAG执行的活动和使用/命令。