diff --git a/catalog/dags/elasticsearch_cluster/create_new_es_index/create_new_es_index_dag.py b/catalog/dags/elasticsearch_cluster/create_new_es_index/create_new_es_index_dag.py
index 2c1ee6117f5..5a04eb4f198 100644
--- a/catalog/dags/elasticsearch_cluster/create_new_es_index/create_new_es_index_dag.py
+++ b/catalog/dags/elasticsearch_cluster/create_new_es_index/create_new_es_index_dag.py
@@ -290,7 +290,6 @@ def create_new_es_index_dag(dag_config: CreateNewIndex):
                 f"New index { index_name } was successfully created with alias"
                 "{{ params.target_alias }}."
             ),
-            dag_id=dag.dag_id,
             username="Create New ES Index",
             icon_emoji=":elasticsearch:",
         )
diff --git a/catalog/dags/elasticsearch_cluster/create_proportional_by_source_staging_index/create_proportional_by_source_staging_index_dag.py b/catalog/dags/elasticsearch_cluster/create_proportional_by_source_staging_index/create_proportional_by_source_staging_index_dag.py
index 243903b6eca..ed8589f6649 100644
--- a/catalog/dags/elasticsearch_cluster/create_proportional_by_source_staging_index/create_proportional_by_source_staging_index_dag.py
+++ b/catalog/dags/elasticsearch_cluster/create_proportional_by_source_staging_index/create_proportional_by_source_staging_index_dag.py
@@ -177,7 +177,6 @@ def create_proportional_by_source_staging_index():
         trigger_rule=TriggerRule.NONE_FAILED
     )(
         text=f"Reindexing complete for {destination_index_name}.",
-        dag_id=DAG_ID,
         username="Proportional by Source Staging Index Creation",
         icon_emoji=":elasticsearch:",
     )
diff --git a/catalog/dags/elasticsearch_cluster/point_es_alias/point_es_alias_dag.py b/catalog/dags/elasticsearch_cluster/point_es_alias/point_es_alias_dag.py
index cccbf890a16..0da87cbea91 100644
--- a/catalog/dags/elasticsearch_cluster/point_es_alias/point_es_alias_dag.py
+++ b/catalog/dags/elasticsearch_cluster/point_es_alias/point_es_alias_dag.py
@@ -95,7 +95,6 @@ def point_es_alias_dag(environment: str):
             trigger_rule=TriggerRule.NONE_FAILED
         )(
             text="Alias {{ params.target_alias }} applied to index {{ params.target_index }}.",
-            dag_id=dag.dag_id,
             username="Point Alias",
             icon_emoji=":elasticsearch:",
         )
diff --git a/catalog/dags/elasticsearch_cluster/recreate_staging_index/recreate_full_staging_index_dag.py b/catalog/dags/elasticsearch_cluster/recreate_staging_index/recreate_full_staging_index_dag.py
index 3b16056941e..b3467366301 100644
--- a/catalog/dags/elasticsearch_cluster/recreate_staging_index/recreate_full_staging_index_dag.py
+++ b/catalog/dags/elasticsearch_cluster/recreate_staging_index/recreate_full_staging_index_dag.py
@@ -182,7 +182,6 @@ def recreate_full_staging_index():
             f"{new_index_suffix}` aliased to `{target_alias}`."
         ),
         username="Full Staging Index Creation",
-        dag_id=DAG_ID,
     )
 
     # Set up dependencies
diff --git a/catalog/dags/popularity/popularity_refresh_dag_factory.py b/catalog/dags/popularity/popularity_refresh_dag_factory.py
index bd364e5d7f7..d069e3ad97c 100644
--- a/catalog/dags/popularity/popularity_refresh_dag_factory.py
+++ b/catalog/dags/popularity/popularity_refresh_dag_factory.py
@@ -110,7 +110,6 @@ def create_popularity_refresh_dag(popularity_refresh: PopularityRefresh):
             " constants update_",
             username=SLACK_USERNAME,
             icon_emoji=SLACK_EMOJI,
-            dag_id=popularity_refresh.dag_id,
         )
 
         update_constants = (
@@ -139,7 +138,6 @@ def create_popularity_refresh_dag(popularity_refresh: PopularityRefresh):
             " popularity scores_",
             username=SLACK_USERNAME,
             icon_emoji=SLACK_EMOJI,
-            dag_id=popularity_refresh.dag_id,
         )
 
         # Once popularity constants have been calculated, establish the cutoff time
@@ -173,7 +171,6 @@ def create_popularity_refresh_dag(popularity_refresh: PopularityRefresh):
             ),
             username=SLACK_USERNAME,
             icon_emoji=SLACK_EMOJI,
-            dag_id=popularity_refresh.dag_id,
         )
 
         # Set up task dependencies