diff --git a/catalog/dags/data_refresh/create_filtered_index_dag.py b/catalog/dags/data_refresh/create_filtered_index_dag.py index 18553ed6140..19c6905c8e0 100644 --- a/catalog/dags/data_refresh/create_filtered_index_dag.py +++ b/catalog/dags/data_refresh/create_filtered_index_dag.py @@ -213,7 +213,7 @@ def point_alias(destination_index_suffix: str) -> TaskGroup: # Await healthy results from the newly created elasticsearch index. index_readiness_check = ingestion_server.index_readiness_check( media_type=media_type, - index_suffix=destination_index_suffix, + index_suffix=f"{destination_index_suffix}-filtered", ) do_point_alias = point_alias(destination_index_suffix=destination_index_suffix)