airflow_pagerduty_events_operator_dag_example.py

1from datetime import datetime
2
3from airflow import DAG
4from airflow.providers.pagerduty.operators.pagerduty import PagerdutyEventsOperator
5
6with DAG(
7    dag_id="example_pagerduty_operator",
8    start_date=datetime(2021, 1, 1),
9    schedule=None,
10    catchup=False,
11) as dag:
12
13    # [START howto_operator_pagerduty_events]
14    send_event = PagerdutyEventsOperator(
15        task_id="send_event_task",
16        pagerduty_conn_id="pagerduty_default",
17        summary="Example alert from Airflow",
18        severity="critical",
19        source="airflow-server",
20        action="trigger",
21        component="airflow",
22        group="data-pipeline",
23        class_type="integration",
24        payload={
25            "custom_details": "Job failed on execution date {{ ds }}",
26        },
27    )
28    # [END howto_operator_pagerduty_events]