From 9ac7721f75acb0315c9728651cc3d6b383b0729d Mon Sep 17 00:00:00 2001
From: Bruno Antonellini <antonellinibruno@gmail.com>
Date: Mon, 5 Aug 2024 16:18:35 -0300
Subject: [PATCH] Fix: Airflow Slack webhook notifications

---
 docs/how-tos/airflow/send-slack-notifications.md | 16 ++++++++++------
 1 file changed, 10 insertions(+), 6 deletions(-)

diff --git a/docs/how-tos/airflow/send-slack-notifications.md b/docs/how-tos/airflow/send-slack-notifications.md
index 597bfd1..b8022c9 100644
--- a/docs/how-tos/airflow/send-slack-notifications.md
+++ b/docs/how-tos/airflow/send-slack-notifications.md
@@ -117,6 +117,14 @@ TRANSFORM_CONFIG = {
     ),
 }
 
+run_inform_success = send_slack_webhook_notification(
+    slack_webhook_conn_id="SLACK_NOTIFICATIONS",  # Slack integration name slug -- double check in Datacoves integrations' admin
+    text="The dag {{ dag.dag_id }} succeeded",
+)
+
+run_inform_failure = send_slack_webhook_notification(
+    slack_webhook_conn_id="SLACK_NOTIFICATIONS", text="The dag {{ dag.dag_id }} failed"
+)
 
 @dag(
     default_args={
@@ -129,12 +137,8 @@ TRANSFORM_CONFIG = {
     schedule_interval="0 0 1 */12 *",
     tags=["version_2", "slack_notification", "blue_green"],
     catchup=False,
-    on_success_callback=send_slack_webhook_notification(
-        slack_webhook_conn_id="SLACK_NOTIFICATIONS", text="The dag {{ dag.dag_id }} succeeded"
-    ),
-    on_failure_callback=send_slack_webhook_notification(
-        slack_webhook_conn_id="SLACK_NOTIFICATIONS", text="The dag {{ dag.dag_id }} failed"
-    ),
+    on_success_callback=[run_inform_success],
+    on_failure_callback=[run_inform_failure],
 )
 def yaml_slack_dag():
     transform = DatacovesDbtOperator(