0
from dagster import HookContext, failure_hook, success_hook


@success_hook(required_resource_keys={"slack"})  
def slack_message_on_success(context: HookContext):  
    message = f"Solid {context.solid.name} finished successfully"
    context.resources.slack.chat.post_message(channel="#foo", text=message)


@failure_hook(required_resource_keys={"slack"})
def slack_message_on_failure(context: HookContext):
    message = f"Solid {context.solid.name} failed"
    context.resources.slack.chat.post_message(channel="#foo", text=message)

是否有一个字段可以从“上下文”中提取回溯堆栈以定位触发的异常并发送电子邮件或松弛消息?

4

1 回答 1

0

不幸的是,Dagster 目前不支持此功能,这里是跟踪此请求的GH 问题。

于 2021-03-05T19:22:57.503 回答