Nick Hoffmann
01/20/2023, 7:19 PMAnna Geller
Anna Geller
Anna Geller
from prefect import flow, task
from prefect.blocks.notifications import SlackWebhook
@task
def send_alert():
slack_webhook_block = SlackWebhook.load("yourblock")
slack_webhook_block.notify("Hello from Prefect!")
@flow(name="Important-2.0-Flow")
def notification_flow():
send_alert()
Anna Geller
from dotenv import load_dotenv
import os
from prefect.blocks.notifications import SlackWebhook
load_dotenv()
slack = SlackWebhook(url=os.environ.get("SLACK_WEBHOOK_URL"))
slack.save("default", overwrite=True)
Nick Hoffmann
01/20/2023, 7:45 PM