From 47efec8ad962bb5710bc7141107b8f82af3fe1bf Mon Sep 17 00:00:00 2001 From: Staci Cooper Date: Wed, 28 Feb 2024 09:32:08 -0800 Subject: [PATCH] Clarify arguments to get_staging_source_counts --- .../create_proportional_by_source_staging_index.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/catalog/dags/elasticsearch_cluster/create_proportional_by_source_staging_index/create_proportional_by_source_staging_index.py b/catalog/dags/elasticsearch_cluster/create_proportional_by_source_staging_index/create_proportional_by_source_staging_index.py index 322ae43aa98..14e840c27ac 100644 --- a/catalog/dags/elasticsearch_cluster/create_proportional_by_source_staging_index/create_proportional_by_source_staging_index.py +++ b/catalog/dags/elasticsearch_cluster/create_proportional_by_source_staging_index/create_proportional_by_source_staging_index.py @@ -65,6 +65,8 @@ def get_staging_source_counts(source_index: str, es_host: str): response = es_conn.search( index=source_index, + # Return 0 records from the search query; we only care about the + # aggregations size=0, aggregations={ "unique_sources": {