diff --git a/pymilvus/milvus_client/async_milvus_client.py b/pymilvus/milvus_client/async_milvus_client.py index efb507158..ffa7ce201 100644 --- a/pymilvus/milvus_client/async_milvus_client.py +++ b/pymilvus/milvus_client/async_milvus_client.py @@ -372,7 +372,9 @@ async def query( if ids: try: - schema_dict = conn.describe_collection(collection_name, timeout=timeout, **kwargs) + schema_dict = await conn.describe_collection( + collection_name, timeout=timeout, **kwargs + ) except Exception as ex: logger.error("Failed to describe collection: %s", collection_name) raise ex from ex