admin/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2026-01-07 19:31:51 +08:00
Code Issues Packages Projects Releases Wiki Activity

test: Upgrade pymilvus to 2.6.0rc166 (#43543)

Browse Source 
related issue: #40698

Signed-off-by: yanliang567 <yanliang.qiao@zilliz.com>
This commit is contained in:
yanliang567 2025-07-28 10:30:55 +08:00 committed by GitHub
parent 7b8bf6393b
commit 10ec3ce2bf
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
2 changed files with 11 additions and 8 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.6.0rc157
pymilvus[bulk_writer]==2.6.0rc157
pymilvus==2.6.0rc166
pymilvus[bulk_writer]==2.6.0rc166
# for protobuf
protobuf==5.27.2

15
tests/python_client/testcases/test_connection.py
View File

@ -444,12 +444,17 @@ class TestConnectionOperation(TestcaseBase):
target: connect with non existing params
method: 1. add connection with non existing params
2. try to connect
3. connect failure will remove connection alias in list connections
expected: raise an exception
"""
# add invalid default connection
self.connection_wrap.add_connection(default={'host': "host", 'port': port})
# list all connections and check the response
self.connection_wrap.list_connections(check_task=ct.CheckTasks.ccr,
check_items={ct.list_content: [(DefaultConfig.DEFAULT_USING, None)]})
# using default alias to create connection, the connection does not exist
err_msg = cem.FailConnect % ("host", str(port))
self.connection_wrap.connect(alias=DefaultConfig.DEFAULT_USING, check_task=ct.CheckTasks.err_res,
@ -457,13 +462,11 @@ class TestConnectionOperation(TestcaseBase):
ct.err_msg: "illegal connection params or server unavailable"})
# list all connections and check the response
self.connection_wrap.list_connections(check_task=ct.CheckTasks.ccr,
check_items={ct.list_content: [(DefaultConfig.DEFAULT_USING, None)]})
self.connection_wrap.list_connections(check_task=ct.CheckTasks.ccr, check_items={ct.list_content: []})
# get all addr of alias and check the response
self.connection_wrap.get_connection_addr(alias=DefaultConfig.DEFAULT_USING, check_task=ct.CheckTasks.ccr,
check_items={ct.dict_content: {"address": f"host:{port}",
"user": ""}})
check_items={ct.dict_content: {}})
@pytest.mark.tags(ct.CaseLabel.L0)
def test_connection_connect_default_alias_effective(self, host, port):
@ -883,8 +886,8 @@ class TestConnect(TestcaseBase):
"""
self.connection_wrap.connect(alias=connect_name, host=host, port=port, user=ct.default_user,
password=ct.default_password, check_task=ct.CheckTasks.ccr)
res = self.utility_wrap.list_collections()[0]
assert len(res) == 0
res = self.connection_wrap.list_connections()[0]
assert len(res) == 1
class TestConnectIPInvalid(TestcaseBase):