Fix a search pipeline

mhdzumair · Nov 2, 2024 · 291c51b · 291c51b
1 parent 4d96ae8
commit 291c51b
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/db/crud.py b/db/crud.py
@@ -860,7 +860,9 @@ async def process_search_query(
     ]
 
     # Execute the aggregation pipeline
-    search_results = await MediaFusionMetaData.aggregate(pipeline).to_list(50)
+    search_results = (
+        await MediaFusionMetaData.get_motor_collection().aggregate(pipeline).to_list(50)
+    )
 
     return {"metas": search_results}
 
@@ -912,7 +914,9 @@ async def process_tv_search_query(search_query: str, namespace: str) -> dict:
     ]
 
     # Execute the aggregation pipeline
-    search_results = await MediaFusionMetaData.aggregate(pipeline).to_list(50)
+    search_results = (
+        await MediaFusionMetaData.get_motor_collection().aggregate(pipeline).to_list(50)
+    )
 
     return {"metas": search_results}