Phillip Kelly
05/02/2023, 2:17 PM@success_hook(required_resource_keys={"slack_webhook_url"})
def slack_message_on_success(context: HookContext):
send_slack_message(context, True)
@failure_hook(required_resource_keys={"slack_webhook_url"})
def slack_message_on_failure(context: HookContext):
send_slack_message(context, False)
and then I have my job decorator set with
@job(
resource_defs={"slack_webhook_url": slack_webhook_url_resource},
hooks={slack_message_on_success, slack_message_on_failure},
)
Phillip Kelly
05/02/2023, 2:27 PM