Skip to content

Commit 3534acb

Browse files
committed
fix project
1 parent dfb9cc2 commit 3534acb

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

veadk/integrations/ve_viking_db_memory/ve_viking_db_memory.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -290,8 +290,8 @@ def create_collection(
290290
res = self.json("CreateCollection", {}, json.dumps(params))
291291
return json.loads(res)
292292

293-
def get_collection(self, collection_name):
294-
params = {"CollectionName": collection_name}
293+
def get_collection(self, collection_name, project="default"):
294+
params = {"CollectionName": collection_name, "ProjectName": project}
295295
res = self.json("GetCollection", {}, json.dumps(params))
296296
return json.loads(res)
297297

veadk/memory/long_term_memory_backends/vikingdb_memory_backend.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -92,9 +92,9 @@ def precheck_index_naming(self):
9292

9393
def _collection_exist(self) -> bool:
9494
try:
95-
client = self._get_sdk_client()
95+
client = self._get_client()
9696
client.get_collection(
97-
collection_name=self.index, project_name=self.volcengine_project
97+
collection_name=self.index, project=self.volcengine_project
9898
)
9999
logger.info(f"Collection {self.index} exist.")
100100
return True

0 commit comments

Comments
 (0)