From bd572148ec6e00dcdf800260ae26ea711ac7fc71 Mon Sep 17 00:00:00 2001 From: Staci Cooper Date: Thu, 5 Sep 2024 15:34:37 -0700 Subject: [PATCH] Correctly report record count of the promoted index, not the old one --- catalog/dags/data_refresh/dag_factory.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/catalog/dags/data_refresh/dag_factory.py b/catalog/dags/data_refresh/dag_factory.py index d7829528994..7c1e975a58f 100644 --- 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