Replace combine_pipelines

Author: aclark4life

libs/langchain-mongodb/langchain_mongodb/pipelines.py

@@ -9,6 +9,8 @@
 
 from typing import Any, Dict, List, Optional, Union
 
+from pymongo_search_utils import combine_pipelines  # noqa: F401
+
 
 def text_search_stage(
     query: str,
@@ -91,16 +93,6 @@ def vector_search_stage(
     return {"$vectorSearch": stage}
 
 
-def combine_pipelines(
-    pipeline: List[Any], stage: List[Dict[str, Any]], collection_name: str
-) -> None:
-    """Combines two aggregations into a single result set in-place."""
-    if pipeline:
-        pipeline.append({"$unionWith": {"coll": collection_name, "pipeline": stage}})
-    else:
-        pipeline.extend(stage)
-
-
 def reciprocal_rank_stage(
     score_field: str, penalty: float = 0, weight: float = 1, **kwargs: Any
 ) -> List[Dict[str, Any]]: