github/langchain
1
0
Fork 0
mirror of https://github.com/hwchase17/langchain.git synced 2025-08-17 16:39:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

mongodb: bson optional import (#24685)

Browse Source
This commit is contained in:
Erick Friis 2024-07-29 09:54:01 -07:00 committed by GitHub
parent c086410677
commit df78608741
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
libs/partners/mongodb/langchain_mongodb/utils.py
View File

@ -15,8 +15,6 @@ from datetime import date, datetime
from typing import Any, Dict, List, Union from typing import Any, Dict, List, Union
import numpy as np import numpy as np
from bson import ObjectId
from bson.errors import InvalidId
logger = logging.getLogger(__name__) logger = logging.getLogger(__name__)
@ -95,7 +93,7 @@ def maximal_marginal_relevance(
return idxs return idxs
def str_to_oid(str_repr: str) -> ObjectId | str: def str_to_oid(str_repr: str) -> Any | str:
"""Attempt to cast string representation of id to MongoDB's internal BSON ObjectId. """Attempt to cast string representation of id to MongoDB's internal BSON ObjectId.
To be consistent with ObjectId, input must be a 24 character hex string. To be consistent with ObjectId, input must be a 24 character hex string.
@ -108,6 +106,9 @@ def str_to_oid(str_repr: str) -> ObjectId | str:
Returns: Returns:
ObjectID ObjectID
""" """
from bson import ObjectId
from bson.errors import InvalidId
try: try:
return ObjectId(str_repr) return ObjectId(str_repr)
except InvalidId: except InvalidId:
@ -118,7 +119,7 @@ def str_to_oid(str_repr: str) -> ObjectId | str:
return str_repr return str_repr
def oid_to_str(oid: ObjectId) -> str: def oid_to_str(oid: Any) -> str:
"""Convert MongoDB's internal BSON ObjectId into a simple str for compatibility. """Convert MongoDB's internal BSON ObjectId into a simple str for compatibility.
Instructive helper to show where data is coming out of MongoDB. Instructive helper to show where data is coming out of MongoDB.
@ -136,6 +137,8 @@ def make_serializable(
obj: Dict[str, Any], obj: Dict[str, Any],
) -> None: ) -> None:
"""Recursively cast values in a dict to a form able to json.dump""" """Recursively cast values in a dict to a form able to json.dump"""
from bson import ObjectId
for k, v in obj.items(): for k, v in obj.items():
if isinstance(v, dict): if isinstance(v, dict):
make_serializable(v) make_serializable(v)