diff --git a/distributions/dependencies.json b/distributions/dependencies.json index c1450d97e..345a29f33 100644 --- a/distributions/dependencies.json +++ b/distributions/dependencies.json @@ -21,6 +21,7 @@ "pandas", "pillow", "psycopg2-binary", + "pymongo", "pypdf", "redis", "requests", @@ -54,6 +55,7 @@ "pandas", "pillow", "psycopg2-binary", + "pymongo", "pypdf", "redis", "requests", @@ -88,6 +90,7 @@ "pandas", "pillow", "psycopg2-binary", + "pymongo", "pypdf", "redis", "requests", @@ -122,6 +125,7 @@ "pandas", "pillow", "psycopg2-binary", + "pymongo", "pypdf", "redis", "requests", @@ -157,6 +161,7 @@ "pandas", "pillow", "psycopg2-binary", + "pymongo", "pypdf", "redis", "requests", @@ -192,6 +197,7 @@ "pandas", "pillow", "psycopg2-binary", + "pymongo", "pypdf", "redis", "requests", @@ -228,6 +234,7 @@ "pandas", "pillow", "psycopg2-binary", + "pymongo", "pypdf", "redis", "requests", @@ -269,6 +276,7 @@ "pandas", "pillow", "psycopg2-binary", + "pymongo", "pypdf", "redis", "requests", @@ -306,6 +314,7 @@ "pandas", "pillow", "psycopg2-binary", + "pymongo", "pypdf", "redis", "requests", @@ -340,6 +349,7 @@ "pandas", "pillow", "psycopg2-binary", + "pymongo", "pypdf", "redis", "requests", @@ -373,6 +383,7 @@ "pandas", "pillow", "psycopg2-binary", + "pymongo", "pypdf", "redis", "requests", @@ -403,6 +414,7 @@ "pandas", "pillow", "psycopg2-binary", + "pymongo", "pypdf", "redis", "requests", @@ -438,6 +450,7 @@ "pandas", "pillow", "psycopg2-binary", + "pymongo", "pypdf", "redis", "requests", @@ -471,6 +484,7 @@ "pandas", "pillow", "psycopg2-binary", + "pymongo", "pypdf", "redis", "requests", @@ -505,6 +519,7 @@ "pandas", "pillow", "psycopg2-binary", + "pymongo", "pypdf", "redis", "requests", diff --git a/llama_stack/providers/utils/kvstore/mongodb/mongodb.py b/llama_stack/providers/utils/kvstore/mongodb/mongodb.py index 625fce929..965b4e213 100644 --- a/llama_stack/providers/utils/kvstore/mongodb/mongodb.py +++ b/llama_stack/providers/utils/kvstore/mongodb/mongodb.py @@ -41,10 +41,7 @@ class MongoDBKVStoreImpl(KVStore): return key return f"{self.config.namespace}:{key}" - async def set( - self, key: str, value: str, expiration: Optional[datetime] = None - ) -> None: - + async def set(self, key: str, value: str, expiration: Optional[datetime] = None) -> None: key = self._namespaced_key(key) update_query = {"$set": {"value": value, "expiration": expiration}} self.collection.update_one({"key": key}, update_query, upsert=True)