https://prefect.io
Join Slack
Hi, I would like to send a slack notification with some information about the result of a flow run t...
# ask-community
l
Hi, I would like to send a slack notification with some information about the result of a flow run together with a link to that flow run in the prefect server so that I can inspect the flow run if I want to. In prefect 1.0 I would do something like this within a task or a flow to get the url:
Copy code
from prefect.client import Client
import prefect

flow_run_id = prefect.context.flow_run_id
url = Client().get_cloud_url("flow-run", flow_run_id)
I have not found anything similar in prefect 2.0. How can I do that in prefect 2.0?
f
You should either be able to create a Slack Webhook notification in the UI (Notifications -> Create Notification -> Slack Webhook), or you can create a Slack Webhook Block and use that programmatically.
I'm currently using the block approach for a MS Teams webhook which looks like follows:
Copy code
def _notify(status: PipelineStatus, pipeline: str = None, params: dict = None):
    pipeline = pipeline if pipeline else '<unnamed pipeline>'
    params = params if params else {}
    teams_webhook_block = MicrosoftTeamsWebhook.load("block-name")
    teams_webhook_block.notify(f'[{pipeline}] {status.name} with parameters: {params}')
Using the Slack block for notifying should be fairly similar.
Oh, I misread. You're asking something completely different facepalm
l
The problem is not sending the slack notification. The problem is sending the url of the flow run that just run in that notification.
f
Perhaps
Copy code
prefect.context.get_run_context().task_run.dict()
prefect.context.get_run_context().flow_run.dict()
might have the information you require. Specifically, 
flow_run
should contain a 
flow_id
. Have you tried looking at that?
l
Yes, I can get the flow_run_id from that, but there is nothing about the url.
j
We are also using the 
on_completion
and 
on_failure
callbacks outlined here: https://discourse.prefect.io/t/prefect-2-8-3-is-here-with-completion-and-failure-hooks-for-flows-and-tasks/2437
l
Thanks a lot @jack That thread and discourse post were very helpful. I got notifications working.
👍 1
5 Views
Open in Slack
PreviousNext
Powered by

Prefect Community

Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.

Powered by