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

[skip e2e]fix deploy case (#24553)

Browse Source 
Signed-off-by: zhuwenxing <wenxing.zhu@zilliz.com>
This commit is contained in:
zhuwenxing 2023-05-31 15:37:29 +08:00 committed by GitHub
parent b341f43e68
commit ee45c79158
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tests/python_client/deploy/scripts/action_after_upgrade.py
View File

@ -15,7 +15,7 @@ def task_1(data_size, host):
prefix = "task_1_"
connections.connect(host=host, port=19530, timeout=60)
col_list = get_collections(prefix, check=True)
assert len(col_list) == len(all_index_types)
assert len(col_list) > 0
create_index(prefix)
load_and_search(prefix)
create_collections_and_insert_data(prefix, count=data_size)
@ -33,7 +33,7 @@ def task_2(data_size, host):
prefix = "task_2_"
connections.connect(host=host, port=19530, timeout=60)
col_list = get_collections(prefix, check=True)
assert len(col_list) == len(all_index_types)
assert len(col_list) > 0
load_and_search(prefix)
create_collections_and_insert_data(prefix, count=data_size)
release_collection(prefix)
@ -50,7 +50,7 @@ def task_3(data_size, host):
prefix = "task_3_"
connections.connect(host=host, port=19530, timeout=60)
col_list = get_collections(prefix, check=True)
assert len(col_list) == len(all_index_types)
assert len(col_list) > 0
load_and_search(prefix)
create_collections_and_insert_data(prefix, count=data_size)
release_collection(prefix)
@ -67,7 +67,7 @@ def task_4(data_size, host):
prefix = "task_4_"
connections.connect(host=host, port=19530, timeout=60)
col_list = get_collections(prefix, check=True)
assert len(col_list) == len(all_index_types)
assert len(col_list) > 0
load_and_search(prefix, replicas=NUM_REPLICAS)
create_collections_and_insert_data(prefix, flush=False, count=data_size)
load_and_search(prefix, replicas=NUM_REPLICAS)
@ -82,7 +82,7 @@ def task_5(data_size, host):
prefix = "task_5_"
connections.connect(host=host, port=19530, timeout=60)
col_list = get_collections(prefix, check=True)
assert len(col_list) == len(all_index_types)
assert len(col_list) > 0
create_index(prefix)
load_and_search(prefix, replicas=NUM_REPLICAS)
create_collections_and_insert_data(prefix, flush=True, count=data_size)

6
tests/python_client/deploy/scripts/utils.py
View File

@ -31,7 +31,11 @@ def filter_collections_by_prefix(prefix):
res = []
for col in col_list:
if col.startswith(prefix):
res.append(col)
if any(index_name in col for index_name in all_index_types):
res.append(col)
else:
logger.warning(f"collection {col} has no supported index, skip")
logger.info(f"filtered collections with prefix {prefix}: {res}")
return res