André Lynum
08/12/2026, 6:04 AMMarvin
08/12/2026, 6:04 AMMarvin
08/12/2026, 6:05 AMprefect.flow-run.Failed
- Send an HTTP request to a third-party endpoint
- Customize the payload with templating
2. Custom webhook notification blocks
- Useful if the third-party system expects a specific JSON body or headers
3. Programmatic subscription/querying
- If you want a custom exporter, you can also consume/query events yourself via Prefect’s event tooling/API and forward them externally
If you want, I can help you build a concrete example for:
- Slack / Teams
- Datadog
- PagerDuty
- Splunk / SIEM
- a generic REST webhook
If you share the destination platform, I can show the exact setup.André Lynum
08/12/2026, 6:06 AMMarvin
08/12/2026, 6:06 AMMarvin
08/12/2026, 6:09 AMcall-webhook action to send selected event payloads to:
- an API Gateway + Lambda / Cloud Function
- a small service you host
- a Snowflake-facing ingestion endpoint
That service can then:
- INSERT into Snowflake
- write JSON to stage storage for Snowpipe
- batch/enrich events before loading
2. Sigma
Sigma is usually the consumer of the data once it lands in Snowflake.
So the common design is:
- Prefect emits events
- events land in Snowflake
- Sigma dashboards/query models read those event tables
3. If you need no middleware
You still generally need some HTTP-receiving endpoint unless Snowflake already exposes an endpoint in your environment that can accept the webhook and persist it. Prefect’s webhook action sends HTTP; it does not natively write rows into Snowflake tables.
Important limitation
There does not appear to be a built-in “send Prefect Cloud events directly to Snowflake/Sigma” integration.
A simple recommended design
- Create a Prefect automation for events like prefect.flow-run.Completed / prefect.flow-run.Failed
- Use call-webhook
- Send JSON payload to your ingestion service
- Load to Snowflake table like prefect_events
- Use Sigma on top of that table
If helpful, I can draft either of these next:
1. a reference Snowflake schema + webhook payload for Prefect events, or
2. a minimal ingestion service example that receives Prefect webhooks and writes to Snowflake.