diff --git a/catalog/dags/data_refresh/data_refresh_task_factory.py b/catalog/dags/data_refresh/data_refresh_task_factory.py
index a2ef9259443..bedb79e5d2c 100644
--- a/catalog/dags/data_refresh/data_refresh_task_factory.py
+++ b/catalog/dags/data_refresh/data_refresh_task_factory.py
@@ -149,7 +149,10 @@ def create_data_refresh_task_group(
         # completion. This task copies the media table for the given model from the
         # Catalog into the API DB and builds the elasticsearch index. The new table
         # and index are not promoted until a later step.
-        with TaskGroup(group_id="ingest_upstream") as ingest_upstream_tasks:
+        with TaskGroup(
+            group_id="ingest_upstream",
+            default_args={"trigger_rule": TriggerRule.NONE_FAILED},
+        ) as ingest_upstream_tasks:
             ingestion_server.trigger_and_wait_for_task(
                 action="ingest_upstream",
                 model=data_refresh.media_type,