Skip to content

Commit c41856f

Browse files
committed
hybrid reindexing fix
1 parent 631f09a commit c41856f

1 file changed

Lines changed: 11 additions & 3 deletions

File tree

bbconf/modules/bedfiles.py

Lines changed: 11 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -2195,11 +2195,16 @@ def reindex_hybrid_search(self, batch: int = 1000, purge: bool = False) -> None:
21952195
operation_info = self.config.qdrant_client.upsert(
21962196
collection_name=self.config.config.qdrant.hybrid_collection,
21972197
points=points,
2198+
wait=False,
21982199
)
2199-
session.commit()
22002200
pbar.write("Uploaded batch to qdrant.")
22012201
points = []
2202-
assert operation_info.status == "completed"
2202+
print(operation_info.status)
2203+
assert (
2204+
operation_info.status == "completed"
2205+
or operation_info.status == "acknowledged"
2206+
)
2207+
session.commit()
22032208

22042209
pbar.write(f"File: {result.id} successfully indexed.")
22052210
pbar.update(1)
@@ -2209,7 +2214,10 @@ def reindex_hybrid_search(self, batch: int = 1000, purge: bool = False) -> None:
22092214
collection_name=self.config.config.qdrant.hybrid_collection,
22102215
points=points,
22112216
)
2212-
assert operation_info.status == "completed"
2217+
assert (
2218+
operation_info.status == "completed"
2219+
or operation_info.status == "acknowledged"
2220+
)
22132221
session.commit()
22142222

22152223
return None

0 commit comments

Comments
 (0)