diff --git a/dags/stellar_etl_airflow/build_del_ins_operator.py b/dags/stellar_etl_airflow/build_del_ins_operator.py
index 2e1b7156..0322f04b 100644
--- a/dags/stellar_etl_airflow/build_del_ins_operator.py
+++ b/dags/stellar_etl_airflow/build_del_ins_operator.py
@@ -1,4 +1,5 @@
 from airflow.operators.python import PythonOperator
+from stellar_etl_airflow.default import alert_after_max_retries
 
 
 def initialize_task_vars(
@@ -70,5 +71,6 @@ def create_del_ins_task(dag, task_vars, del_ins_callable):
         python_callable=del_ins_callable,
         op_kwargs=task_vars,
         provide_context=True,
+        on_failure_callback=alert_after_max_retries,
         dag=dag,
     )