python - 在 dagster 的失败钩子中访问回溯

Question

我有一个失败钩子，我想在其中发送一封邮件，但已引发异常。有什么方法可以访问它吗？

# PIPELINE
@failure_hook
def email_message_on_failure(context: HookContext):
    logging.exception(e)
    mail_errors = Mail(
        body=str(e)
    )
    mail_errors.send()

Answer 1

HookContext作为失败钩子的参数接受的对象具有op_exception允许您引用发生的异常的属性。

您可以编写如下内容：

@failure_hook
def email_message_on_failure(context: HookContext):
    e = context.op_exception
    ...