Skip to content

Commit

Permalink
commit
Browse files Browse the repository at this point in the history
  • Loading branch information
liutao420 committed Sep 30, 2024
1 parent 39e80f0 commit c46a02a
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 2 deletions.
1 change: 1 addition & 0 deletions scripts/benchmarks/pysdk.py
Original file line number Diff line number Diff line change
Expand Up @@ -203,6 +203,7 @@ def process_upsert_data(items: tuple):
if rs.code != 0:
logger.info(rs.msg)
if len(rs.get_document_ids()) != size:
logger.info(rs.msg)
logger.info(rs.get_document_ids())
assert len(rs.get_document_ids()) == size

Expand Down
6 changes: 4 additions & 2 deletions sdk/python/vearch/core/space.py
Original file line number Diff line number Diff line change
Expand Up @@ -90,8 +90,10 @@ def upsert(self, data: Union[List, pd.DataFrame]) -> UpsertResult:
documents.append(record)
else:
return UpsertResult(CodeType.UPSERT_DOC, "data type has error: " + err_msg)

return self.client._upsert(self.database_name, self.name, documents)
logger.info(f"docs:{len(documents)}")
result = self.client._upsert(self.database_name, self.name, documents)
logger.info(f"success:{result.is_success()}, len:{len(result.document_ids)}")
return result

def _check_data_type(
self, data: Union[List, pd.DataFrame]
Expand Down

0 comments on commit c46a02a

Please sign in to comment.