如何解决如何获取Airflow Task实例错误详细信息
我需要获取上游任务失败的异常详细信息(使用databricks运算符执行databricks作业的任务),如果任务基于错误消息失败,则需要更新数据库。
我在on_failure_callback中尝试了context.get('exception')和context。['exception']。它返回了空值。
是否仍然有获取任务的日志错误详细信息并用于下一个任务的信息。您能否分享一些示例代码。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。