Skip to content

Commit

Permalink
fix: fix async grpc info (#800)
Browse files Browse the repository at this point in the history
  • Loading branch information
joein committed Oct 7, 2024
1 parent 7225ee8 commit a204d36
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion qdrant_client/async_qdrant_remote.py
Original file line number Diff line number Diff line change
Expand Up @@ -2989,7 +2989,7 @@ async def delete_shard_key(

async def info(self) -> types.VersionInfo:
if self._prefer_grpc:
version_info = self.grpc_root.HealthCheck(grpc.HealthCheckRequest())
version_info = await self.grpc_root.HealthCheck(grpc.HealthCheckRequest())
return GrpcToRest.convert_health_check_reply(version_info)
version_info = await self.rest.service_api.root()
assert version_info is not None, "Healthcheck returned None"
Expand Down
4 changes: 2 additions & 2 deletions tools/async_client_generator/remote_generator.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@
import inspect
from typing import Dict, List, Optional

from qdrant_client.grpc import CollectionsStub, PointsStub, SnapshotsStub
from qdrant_client.grpc import CollectionsStub, PointsStub, SnapshotsStub, QdrantStub
from qdrant_client.http import AsyncApiClient
from qdrant_client.http.api.cluster_api import AsyncClusterApi
from qdrant_client.http.api.collections_api import AsyncCollectionsApi
Expand Down Expand Up @@ -94,7 +94,7 @@ def async_methods(self) -> List[str]:
):
self._async_methods.extend(self.get_async_methods(cls_))

for cls_ in (PointsStub, SnapshotsStub, CollectionsStub):
for cls_ in (PointsStub, SnapshotsStub, CollectionsStub, QdrantStub):
self._async_methods.extend(self._get_grpc_methods(cls_))

return self._async_methods
Expand Down

0 comments on commit a204d36

Please sign in to comment.