aerospike-vector-search-client-0.6.1 release

docs/index.rst

@@ -11,7 +11,7 @@ This standard client (Client) specializes in performing database operations with
 Moreover, the standard client supports Hierarchical Navigable Small World (HNSW) vector searches,
 allowing users to find vectors similar to a given query vector within an index.
 
-This admin client (AdminClient) is designed to conduct Proximus administrative operation such
+This admin client (AdminClient) is designed to conduct AVS administrative operation such
 as creating indexes, querying index information, and dropping indexes.
 
 Please explore the modules below for more information on API usage and details.

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "setuptools.build_meta"
 
 [project]
 name = "aerospike-vector-search"
-description = "Aerospike Proximus Client Library for Python"
+description = "Aerospike Vector Search Client Library for Python"
 authors = [
     { name = "Aerospike, Inc.", email = "[email protected]" }
 ]
@@ -22,7 +22,7 @@ classifiers = [
     "Programming Language :: Python :: Implementation :: CPython",
     "Topic :: Database"
 ]
-version = "0.6.0"
+version = "0.6.1"
 requires-python = ">3.8"
 dependencies = [
     "grpcio",

src/aerospike_vector_search/aio/client.py

@@ -338,15 +338,10 @@ async def vector_search(
         )
 
         try:
-            results_stream = transact_stub.VectorSearch(vector_search_request)
+            return [self._respond_neighbor(result) async for result in transact_stub.VectorSearch(vector_search_request)]
         except grpc.RpcError as e:
             logger.error("Failed with error: %s", e)
             raise types.AVSServerError(rpc_error=e)
-        async_results = []
-        async for result in results_stream:
-            async_results.append(self._respond_neighbor(result))
-
-        return async_results
 
     async def wait_for_index_completion(
         self,

src/aerospike_vector_search/client.py

@@ -313,15 +313,10 @@ def vector_search(
         )
 
         try:
-            results_stream = transact_stub.VectorSearch(vector_search_request)
+            return [self._respond_neighbor(result) for result in transact_stub.VectorSearch(vector_search_request)]
         except grpc.RpcError as e:
             logger.error("Failed with error: %s", e)
             raise types.AVSServerError(rpc_error=e)
-        results = []
-        for result in results_stream:
-            results.append(self._respond_neighbor(result))
-
-        return results
 
     def wait_for_index_completion(
         self,

src/aerospike_vector_search/shared/base_channel_provider.py

@@ -22,7 +22,7 @@ def __init__(
 
 
 class BaseChannelProvider(object):
-    """Proximus Channel Provider"""
+    """AVS Channel Provider"""
 
     def __init__(
         self,