Skip to content

Commit 938a2d1

Browse files
Merge pull request #99 from databio/dev
Release0.14.1
2 parents f03f1ba + d3a350e commit 938a2d1

2 files changed

Lines changed: 12 additions & 5 deletions

File tree

bbconf/_version.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
__version__ = "0.14.0"
1+
__version__ = "0.14.1"

bbconf/modules/bedfiles.py

Lines changed: 11 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -2114,7 +2114,6 @@ def reindex_hybrid_search(self, batch: int = 1000, purge: bool = False) -> None:
21142114
select(Bed)
21152115
.join(BedMetadata, Bed.id == BedMetadata.id)
21162116
.where(Bed.indexed == False)
2117-
.limit(batch)
21182117
)
21192118

21202119
with Session(self._sa_engine) as session:
@@ -2196,11 +2195,16 @@ def reindex_hybrid_search(self, batch: int = 1000, purge: bool = False) -> None:
21962195
operation_info = self.config.qdrant_client.upsert(
21972196
collection_name=self.config.config.qdrant.hybrid_collection,
21982197
points=points,
2198+
wait=False,
21992199
)
2200-
session.commit()
22012200
pbar.write("Uploaded batch to qdrant.")
22022201
points = []
2203-
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()
22042208

22052209
pbar.write(f"File: {result.id} successfully indexed.")
22062210
pbar.update(1)
@@ -2210,7 +2214,10 @@ def reindex_hybrid_search(self, batch: int = 1000, purge: bool = False) -> None:
22102214
collection_name=self.config.config.qdrant.hybrid_collection,
22112215
points=points,
22122216
)
2213-
assert operation_info.status == "completed"
2217+
assert (
2218+
operation_info.status == "completed"
2219+
or operation_info.status == "acknowledged"
2220+
)
22142221
session.commit()
22152222

22162223
return None

0 commit comments

Comments
 (0)