Debugging test failures

astronomer · Oct 24, 2024 · 16cd4b8 · 16cd4b8
1 parent 81ec1a5
commit 16cd4b8
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 0 deletions.
diff --git a/dev/dags/example_callbacks.yml b/dev/dags/example_callbacks.yml
@@ -5,6 +5,15 @@ example_callbacks:
     on_failure_callback_name: output_message
   schedule_interval: "@daily"
   catchup: False
+  on_failure_callback:
+    callback: airflow.providers.slack.notifications.slack.send_slack_notification
+    slack_conn_id: example_slack_conn
+    text: |
+      :red_circle: Task Failed.
+      This task has failed and needs to be addressed.
+      Please remediate this issue ASAP.
+    channel: cse-callback-demo
+    username: Airflow
   tasks:
     start:
       operator: airflow.operators.python.PythonOperator

diff --git a/tests/test_example_dags.py b/tests/test_example_dags.py
@@ -53,6 +53,7 @@ def get_dag_bag() -> DagBag:
             print(f"Adding {dagfile} to .airflowignore")
             file.writelines([f"{dagfile}\n"])
 
+    print(EXAMPLE_DAGS_DIR)
     print(".airflowignore contents: ")
     print(AIRFLOW_IGNORE_FILE.read_text())
     db = DagBag(EXAMPLE_DAGS_DIR, include_examples=False)