【发布时间】:2021-06-03 17:02:29
【问题描述】:
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)
是否有一个字段可以从“上下文”中提取回溯堆栈以定位触发的异常并发送电子邮件或松弛消息?
【问题讨论】:
标签: python-3.x dagster