admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2025-12-06 09:08:43 +08:00
Code Issues Packages Projects Releases Wiki Activity

test: Increase PyMilvus version to 2.7.0rc72 for master branch and fix async teardown logic (#45809)

Browse Source 
Signed-off-by: silas.jiang <silas.jiang@zilliz.com>
Co-authored-by: silas.jiang <silas.jiang@zilliz.com>
This commit is contained in:
jac 2025-11-25 11:01:07 +08:00 committed by GitHub
parent 256e073e8d
commit 97da6bd7e3
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
5 changed files with 16 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tests/python_client/requirements.txt
View File

@ -28,8 +28,8 @@ pytest-parallel
pytest-random-order
# pymilvus
pymilvus==2.7.0rc60
pymilvus[bulk_writer]==2.7.0rc60
pymilvus==2.7.0rc72
pymilvus[bulk_writer]==2.7.0rc72
# for protobuf
protobuf>=5.29.5

10
tests/python_client/testcases/async_milvus_client/test_collection_async.py
View File

@ -31,9 +31,8 @@ class TestAsyncMilvusClientCollectionInvalid(TestMilvusClientV2Base):
""" Test case of collection interface """
def teardown_method(self, method):
self.init_async_milvus_client()
loop = asyncio.get_event_loop()
loop.run_until_complete(self.async_milvus_client_wrap.close())
if self.async_milvus_client_wrap.async_milvus_client is not None:
asyncio.run(self.async_milvus_client_wrap.close())
super().teardown_method(method)
"""
@ -128,9 +127,8 @@ class TestAsyncMilvusClientCollectionValid(TestMilvusClientV2Base):
""" Test case of collection interface """
def teardown_method(self, method):
self.init_async_milvus_client()
loop = asyncio.get_event_loop()
loop.run_until_complete(self.async_milvus_client_wrap.close())
if self.async_milvus_client_wrap.async_milvus_client is not None:
asyncio.run(self.async_milvus_client_wrap.close())
super().teardown_method(method)
"""

5
tests/python_client/testcases/async_milvus_client/test_e2e_async.py
View File

@ -21,9 +21,8 @@ default_vector_name = "vector"
class TestAsyncMilvusClient(TestMilvusClientV2Base):
def teardown_method(self, method):
self.init_async_milvus_client()
loop = asyncio.get_event_loop()
loop.run_until_complete(self.async_milvus_client_wrap.close())
if self.async_milvus_client_wrap.async_milvus_client is not None:
asyncio.run(self.async_milvus_client_wrap.close())
super().teardown_method(method)
@pytest.mark.tags(CaseLabel.L0)

10
tests/python_client/testcases/async_milvus_client/test_index_async.py
View File

@ -30,9 +30,8 @@ class TestAsyncMilvusClientIndexInvalid(TestMilvusClientV2Base):
""" Test case of index interface """
def teardown_method(self, method):
self.init_async_milvus_client()
loop = asyncio.get_event_loop()
loop.run_until_complete(self.async_milvus_client_wrap.close())
if self.async_milvus_client_wrap.async_milvus_client is not None:
asyncio.run(self.async_milvus_client_wrap.close())
super().teardown_method(method)
"""
@ -206,9 +205,8 @@ class TestAsyncMilvusClientIndexValid(TestMilvusClientV2Base):
""" Test case of index interface """
def teardown_method(self, method):
self.init_async_milvus_client()
loop = asyncio.get_event_loop()
loop.run_until_complete(self.async_milvus_client_wrap.close())
if self.async_milvus_client_wrap.async_milvus_client is not None:
asyncio.run(self.async_milvus_client_wrap.close())
super().teardown_method(method)
@pytest.fixture(scope="function", params=["COSINE", "L2", "IP"])

10
tests/python_client/testcases/async_milvus_client/test_partition_async.py
View File

@ -31,9 +31,8 @@ class TestAsyncMilvusClientPartitionInvalid(TestMilvusClientV2Base):
""" Test case of partition interface """
def teardown_method(self, method):
self.init_async_milvus_client()
loop = asyncio.get_event_loop()
loop.run_until_complete(self.async_milvus_client_wrap.close())
if self.async_milvus_client_wrap.async_milvus_client is not None:
asyncio.run(self.async_milvus_client_wrap.close())
super().teardown_method(method)
"""
@ -582,9 +581,8 @@ class TestAsyncMilvusClientPartitionValid(TestMilvusClientV2Base):
""" Test case of partition interface """
def teardown_method(self, method):
self.init_async_milvus_client()
loop = asyncio.get_event_loop()
loop.run_until_complete(self.async_milvus_client_wrap.close())
if self.async_milvus_client_wrap.async_milvus_client is not None:
asyncio.run(self.async_milvus_client_wrap.close())
super().teardown_method(method)
"""