Skip to content

Commit e164f3c

Browse files
bshea5Brandon Shea
andauthored
(bugfix): replace create_event with send_event in PagerdutyNotifier (#45630)
* (bugfix): replace `create_event` with `send_event` in `PagerdutyNotifier` --------- Co-authored-by: Brandon Shea <[email protected]>
1 parent 8648366 commit e164f3c

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

providers/src/airflow/providers/pagerduty/notifications/pagerduty.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,7 @@ def hook(self) -> PagerdutyEventsHook:
111111

112112
def notify(self, context):
113113
"""Send a alert to a pagerduty event v2 API."""
114-
self.hook.create_event(
114+
self.hook.send_event(
115115
summary=self.summary,
116116
severity=self.severity,
117117
source=self.source,

providers/tests/pagerduty/notifications/test_pagerduty.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -41,7 +41,7 @@ def test_notifier(self, mock_pagerduty_event_hook, dag_maker):
4141
EmptyOperator(task_id="task1")
4242
notifier = send_pagerduty_notification(summary="DISK at 99%", severity="critical", action="trigger")
4343
notifier({"dag": dag})
44-
mock_pagerduty_event_hook.return_value.create_event.assert_called_once_with(
44+
mock_pagerduty_event_hook.return_value.send_event.assert_called_once_with(
4545
summary="DISK at 99%",
4646
severity="critical",
4747
action="trigger",
@@ -61,7 +61,7 @@ def test_notifier_with_notifier_class(self, mock_pagerduty_event_hook, dag_maker
6161
EmptyOperator(task_id="task1")
6262
notifier = PagerdutyNotifier(summary="DISK at 99%", severity="critical", action="trigger")
6363
notifier({"dag": dag})
64-
mock_pagerduty_event_hook.return_value.create_event.assert_called_once_with(
64+
mock_pagerduty_event_hook.return_value.send_event.assert_called_once_with(
6565
summary="DISK at 99%",
6666
severity="critical",
6767
action="trigger",
@@ -97,7 +97,7 @@ def test_notifier_templated(self, mock_pagerduty_event_hook, dag_maker):
9797
)
9898
context = {"dag": dag}
9999
notifier(context)
100-
mock_pagerduty_event_hook.return_value.create_event.assert_called_once_with(
100+
mock_pagerduty_event_hook.return_value.send_event.assert_called_once_with(
101101
action="trigger",
102102
summary="DISK at 99% test_notifier",
103103
severity="critical test_notifier",

0 commit comments

Comments
 (0)