Skip to main content

Dagster & PagerDuty

This library provides an integration between Dagster and PagerDuty to support creating alerts from your Dagster code.

Installation

pip install dagster_pagerduty

Example

from dagster_pagerduty import PagerDutyService

import dagster as dg


@dg.asset
def pagerduty_alert(pagerduty: PagerDutyService):
pagerduty.EventV2_create(
summary="alert from dagster",
source="localhost",
severity="error",
event_action="trigger",
)


defs = dg.Definitions(
assets=[pagerduty_alert],
resources={
"pagerduty": PagerDutyService(routing_key="0123456789abcdef0123456789abcdef")
},
)

About PagerDuty

PagerDuty is a popular SaaS incident response platform. It integrates machine data & human intelligence to improve visibility & agility for Real-Time Operations.