diff --git a/src/pds/registrysweepers/ancestry/queries.py b/src/pds/registrysweepers/ancestry/queries.py
index 5c98dd1..2cd17a2 100644
--- a/src/pds/registrysweepers/ancestry/queries.py
+++ b/src/pds/registrysweepers/ancestry/queries.py
@@ -77,9 +77,9 @@ def get_collections_containing_products_query(
 ):
     # Query the registry-refs index for all collections containing any of the given non-aggregate products
     nonaggregate_member_lidvid_strs = list(nonaggregate_member_lidvid_strs)
-    query: Dict = {"terms": {"product_lidvid": nonaggregate_member_lidvid_strs}}
-    _source = {"includes": ["collection_lidvid"]}
+    query: Dict = {"query": {"terms": {"product_lidvid": nonaggregate_member_lidvid_strs}}}
+    _source = {"includes": ["collection_lidvid", "product_lidvid"]}
     query_f = query_registry_db_or_mock(registry_db_mock, "get_collections_with_shared_products_query")
-    docs = query_f(client, query, _source, index_name="registry_refs")
+    docs = query_f(client, query, _source, index_name="registry-refs")
 
     return docs