Skip to content

Commit

Permalink
fix: regen async
Browse files Browse the repository at this point in the history
  • Loading branch information
joein committed Jan 19, 2024
1 parent a49227b commit f2c7814
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 8 deletions.
2 changes: 0 additions & 2 deletions qdrant_client/async_qdrant_client.py
Original file line number Diff line number Diff line change
Expand Up @@ -1757,7 +1757,6 @@ def upload_records(
max_retries=max_retries,
wait=wait,
shard_key_selector=shard_key_selector,
**kwargs,
)

async def upload_points(
Expand Down Expand Up @@ -1859,7 +1858,6 @@ def upload_collection(
max_retries=max_retries,
wait=wait,
shard_key_selector=shard_key_selector,
**kwargs,
)

async def create_payload_index(
Expand Down
9 changes: 3 additions & 6 deletions qdrant_client/local/async_qdrant_local.py
Original file line number Diff line number Diff line change
Expand Up @@ -658,18 +658,15 @@ async def recreate_collection(
async def upload_points(
self, collection_name: str, points: Iterable[types.PointStruct], **kwargs: Any
) -> None:
self._upload_points(collection_name, points, **kwargs)
self._upload_points(collection_name, points)

def upload_records(
self, collection_name: str, records: Iterable[types.Record], **kwargs: Any
) -> None:
self._upload_points(collection_name, records, **kwargs)
self._upload_points(collection_name, records)

def _upload_points(
self,
collection_name: str,
points: Iterable[Union[types.PointStruct, types.Record]],
**kwargs: Any,
self, collection_name: str, points: Iterable[Union[types.PointStruct, types.Record]]
) -> None:
collection = self._get_collection(collection_name)
collection.upsert(
Expand Down

0 comments on commit f2c7814

Please sign in to comment.