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

enhance: update test cases and increase timeout of rbac pipeline (#30549)

Browse Source 
issue: #29880

Signed-off-by: nico <cheng.yuan@zilliz.com>
This commit is contained in:
nico 2024-02-07 10:54:47 +08:00 committed by GitHub
parent 715f042965
commit 5bbace1094
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
11 changed files with 35 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ci/jenkins/Nightly.groovy
View File

@ -208,7 +208,7 @@ pipeline {
} else if("${MILVUS_SERVER_TYPE}" == "standalone-authentication") {
tag="RBAC"
parallel_num = 1
e2e_timeout_seconds = 1 * 60 * 60
e2e_timeout_seconds = 3 * 60 * 60
}
if ("${MILVUS_CLIENT}" == "pymilvus") {
sh """

6
tests/python_client/base/high_level_api_wrapper.py
View File

@ -515,14 +515,14 @@ class HighLevelApiWrapper:
return res, check_result
@trace()
def list_aliases(self, client, timeout=None, check_task=None, check_items=None, **kwargs):
def list_aliases(self, client, collection_name, timeout=None, check_task=None, check_items=None, **kwargs):
timeout = TIMEOUT if timeout is None else timeout
kwargs.update({"timeout": timeout})
func_name = sys._getframe().f_code.co_name
res, check = api_request([client.list_aliases], **kwargs)
res, check = api_request([client.list_aliases, collection_name], **kwargs)
check_result = ResponseChecker(res, func_name, check_task,
check_items, check,
check_items, check, collection_name=collection_name,
**kwargs).run()
return res, check_result

10
tests/python_client/milvus_client/test_milvus_client_alias.py
View File

@ -406,7 +406,8 @@ class TestMilvusClientAliasValid(TestcaseBase):
# 1. create collection
client_w.create_collection(client, collection_name, default_dim, consistency_level="Strong")
# 2. create alias
client_w.create_alias(collection_name, alias)
client_w.drop_alias(client, alias)
client_w.create_alias(client, collection_name, alias)
collection_name = alias
# 2. insert
rng = np.random.default_rng(seed=19530)
@ -431,7 +432,10 @@ class TestMilvusClientAliasValid(TestcaseBase):
"with_vec": True,
"primary_field": default_primary_key_field_name})
client_w.release_collection(client, collection_name)
client_w.drop_collection(client, collection_name)
client_w.drop_collection(client, collection_name, check_task=CheckTasks.err_res,
check_items={ct.err_code: 65535,
ct.err_msg: "cannot drop the collection via alias = collection_alias"})
client_w.drop_alias(client, alias)
@pytest.mark.tags(CaseLabel.L1)
@pytest.mark.xfail(reason="pymilvus issue 1891, 1892")
@ -491,7 +495,7 @@ class TestMilvusClientAliasValid(TestcaseBase):
client_w.alter_alias(client, collection_name, another_alias)
client_w.describe_alias(client, alias)
# 3. list alias
aliases = client_w.list_aliases(client)[0]
aliases = client_w.list_aliases(client, collection_name)[0]
# assert alias in aliases
# assert another_alias in aliases
# 4. assert collection is equal to alias according to partitions

11
tests/python_client/milvus_client/test_milvus_client_index.py
View File

@ -271,6 +271,7 @@ class TestMilvusClientIndexValid(TestcaseBase):
"""
@pytest.mark.tags(CaseLabel.L1)
@pytest.mark.skip("https://github.com/milvus-io/pymilvus/issues/1886")
@pytest.mark.parametrize("index, params",
zip(ct.all_index_types[:7],
ct.default_index_params[:7]))
@ -290,7 +291,7 @@ class TestMilvusClientIndexValid(TestcaseBase):
assert res == []
# 2. prepare index params
index_params = client_w.prepare_index_params(client)[0]
index_params.add_index(field_name = "vector", index_type=index, metric_type = metric_type)
index_params.add_index(field_name="vector", index_type=index, metric_type=metric_type)
# 3. create index
client_w.create_index(client, collection_name, index_params)
# 4. create same index twice
@ -319,7 +320,6 @@ class TestMilvusClientIndexValid(TestcaseBase):
"primary_field": default_primary_key_field_name})
client_w.drop_collection(client, collection_name)
@pytest.mark.tags(CaseLabel.L2)
@pytest.mark.skip(reason="pymilvus issue 1884")
@pytest.mark.parametrize("index, params",
@ -369,6 +369,7 @@ class TestMilvusClientIndexValid(TestcaseBase):
client_w.drop_collection(client, collection_name)
@pytest.mark.tags(CaseLabel.L2)
@pytest.mark.skip("wait for modification")
@pytest.mark.parametrize("index, params",
zip(ct.all_index_types[:7],
ct.default_index_params[:7]))
@ -414,6 +415,7 @@ class TestMilvusClientIndexValid(TestcaseBase):
client_w.drop_collection(client, collection_name)
@pytest.mark.tags(CaseLabel.L1)
@pytest.mark.skip("wait for modification")
def test_milvus_client_index_auto_index(self, scalar_index, metric_type):
"""
target: test search (high level api) normal case
@ -465,6 +467,7 @@ class TestMilvusClientIndexValid(TestcaseBase):
client_w.drop_collection(client, collection_name)
@pytest.mark.tags(CaseLabel.L2)
@pytest.mark.skip("wait for modification")
def test_milvus_client_index_multiple_vectors(self, scalar_index, metric_type):
"""
target: test search (high level api) normal case
@ -512,6 +515,7 @@ class TestMilvusClientIndexValid(TestcaseBase):
client_w.drop_collection(client, collection_name)
@pytest.mark.tags(CaseLabel.L2)
@pytest.mark.skip("wait for modification")
@pytest.mark.parametrize("index, params",
zip(ct.all_index_types[:7],
ct.default_index_params[:7]))
@ -563,6 +567,7 @@ class TestMilvusClientIndexValid(TestcaseBase):
client_w.drop_collection(client, collection_name)
@pytest.mark.tags(CaseLabel.L2)
@pytest.mark.skip("wait for modification")
@pytest.mark.parametrize("index, params",
zip(ct.all_index_types[:7],
ct.default_index_params[:7]))
@ -582,7 +587,7 @@ class TestMilvusClientIndexValid(TestcaseBase):
assert res == []
# 2. prepare index params
index_params = client_w.prepare_index_params(client)[0]
index_params.add_index(field_name = "vector", metric_type = metric_type)
index_params.add_index(field_name="vector", metric_type=metric_type)
# 3. create index
client_w.create_index(client, collection_name, index_params)
# 4. drop index

1
tests/python_client/milvus_client/test_milvus_client_search.py
View File

@ -130,6 +130,7 @@ class TestMilvusClientSearchInvalid(TestcaseBase):
check_task=CheckTasks.err_res, check_items=error)
@pytest.mark.tags(CaseLabel.L2)
@pytest.mark.skip("https://github.com/milvus-io/milvus/issues/29880")
def test_milvus_client_search_not_consistent_metric_type(self, metric_type):
"""
target: test search with inconsistent metric type (default is IP) with that of index

2
tests/python_client/requirements.txt
View File

@ -12,7 +12,7 @@ allure-pytest==2.7.0
pytest-print==0.2.1
pytest-level==0.1.1
pytest-xdist==2.5.0
pymilvus==2.4.0rc24
pymilvus==2.4.0rc33
pytest-rerunfailures==9.1.1
git+https://github.com/Projectplace/pytest-tags
ndg-httpsclient

16
tests/python_client/testcases/test_collection.py
View File

@ -4225,21 +4225,21 @@ class TestCollectionARRAY(TestcaseBase):
{"field_id": 101, "name": "float_vector", "description": "", "type": 101,
"params": {"dim": ct.default_dim}, "element_type": 0},
{"field_id": 102, "name": "int8_array", "description": "", "type": 22,
"params": {"max_capacity": "2000"}, "element_type": 2},
"params": {"max_capacity": 2000}, "element_type": 2},
{"field_id": 103, "name": "int16_array", "description": "", "type": 22,
"params": {"max_capacity": "2000"}, "element_type": 3},
"params": {"max_capacity": 2000}, "element_type": 3},
{"field_id": 104, "name": "int32_array", "description": "", "type": 22,
"params": {"max_capacity": "2000"}, "element_type": 4},
"params": {"max_capacity": 2000}, "element_type": 4},
{"field_id": 105, "name": "int64_array", "description": "", "type": 22,
"params": {"max_capacity": "2000"}, "element_type": 5},
"params": {"max_capacity": 2000}, "element_type": 5},
{"field_id": 106, "name": "bool_array", "description": "", "type": 22,
"params": {"max_capacity": "2000"}, "element_type": 1},
"params": {"max_capacity": 2000}, "element_type": 1},
{"field_id": 107, "name": "float_array", "description": "", "type": 22,
"params": {"max_capacity": "2000"}, "element_type": 10},
"params": {"max_capacity": 2000}, "element_type": 10},
{"field_id": 108, "name": "double_array", "description": "", "type": 22,
"params": {"max_capacity": "2000"}, "element_type": 11},
"params": {"max_capacity": 2000}, "element_type": 11},
{"field_id": 109, "name": "string_array", "description": "", "type": 22,
"params": {"max_length": "100", "max_capacity": "2000"}, "element_type": 21}
"params": {"max_length": 100, "max_capacity": 2000}, "element_type": 21}
]
assert res["fields"] == fields

1
tests/python_client/testcases/test_high_level_api.py
View File

@ -130,6 +130,7 @@ class TestHighLevelApi(TestcaseBase):
check_task=CheckTasks.err_res, check_items=error)
@pytest.mark.tags(CaseLabel.L2)
@pytest.mark.skip("https://github.com/milvus-io/milvus/issues/29880")
def test_high_level_search_not_consistent_metric_type(self, metric_type):
"""
target: test search with inconsistent metric type (default is IP) with that of index

2
tests/python_client/testcases/test_index.py
View File

@ -1788,7 +1788,7 @@ class TestIndexDiskann(TestcaseBase):
assert len(collection_w.indexes) == 1
collection_w.release()
collection_w.drop_index(index_name=index_name1)
assert collection_w.has_index(index_name=index_name1)[0] == False
assert collection_w.has_index(index_name=index_name1)[0] is False
@pytest.mark.tags(CaseLabel.L2)
def test_drop_diskann_index_and_create_again(self):

2
tests/python_client/testcases/test_insert.py
View File

@ -1455,7 +1455,7 @@ class TestInsertInvalid(TestcaseBase):
method: insert with nan value: list, number, string ...
expected: raise exception
"""
if isinstance(json_value, list):
if isinstance(json_value, list) or json_value is None:
pytest.skip("invalid in dataframe")
collection_name = cf.gen_unique_str(prefix)
collection_w = self.init_collection_wrap(name=collection_name)

3
tests/python_client/testcases/test_search.py
View File

@ -9838,7 +9838,8 @@ class TestSearchGroupBy(TestcaseBase):
err_code = 999
err_msg = "Unexpected index"
if index in ["IVF_FLAT", "IVF_SQ8", "IVF_PQ", "SCANN"]:
err_msg = "not supported for current index type"
err_code = 65535
err_msg = "Returned knowhere iterator has non-ready iterators inside, terminate group_by operation"
collection_w.search(data=search_vectors, anns_field=ct.default_float_vec_field_name,
param=search_params, limit=limit,
group_by_field=ct.default_int8_field_name,