Correctly report record count of the promoted index, not the old one

WordPress · Sep 5, 2024 · bd57214 · bd57214
1 parent 8f429ab
commit bd57214
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/catalog/dags/data_refresh/dag_factory.py b/catalog/dags/data_refresh/dag_factory.py
@@ -261,8 +261,8 @@ def create_data_refresh_dag(
         # Note filtered_index must be directly upstream of promote_table to
         # ensure that table promotion does not run if there was an error during reindexing
         filtered_index >> [enable_alarms, promote_table]
-        promote_table >> [promote_index, promote_filtered_index, after_record_count]
-        after_record_count >> report_counts
+        promote_table >> [promote_index, promote_filtered_index]
+        promote_index >> after_record_count >> report_counts
 
     return dag