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]Update deploy test (#22613)

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

8
tests/python_client/chaos/standalone-values.yaml
View File

@ -9,6 +9,14 @@ image:
repository: milvusdb/milvus
tag: master-latest
pullPolicy: IfNotPresent
standalone:
resources:
limits:
cpu: 4
memory: 10Gi
requests:
cpu: 2
memory: 8Gi
kafka:
enabled: false

14
tests/python_client/deploy/scripts/action_after_reinstall.py
View File

@ -43,10 +43,12 @@ if __name__ == '__main__':
host = args.host
data_size = args.data_size
logger.info(f"data size: {data_size}")
task_1(data_size, host)
task_2(data_size, host)
tasks = []
tasks.append(threading.Thread(target=task_1, args=(data_size, host)))
tasks.append(threading.Thread(target=task_2, args=(data_size, host)))
for task in tasks:
task.start()
for task in tasks:
task.join()
# tasks.append(threading.Thread(target=task_1, args=(data_size, host)))
# tasks.append(threading.Thread(target=task_2, args=(data_size, host)))
# for task in tasks:
# task.start()
# for task in tasks:
# task.join()

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

@ -105,14 +105,20 @@ if __name__ == '__main__':
logger.info("create index for flat start")
create_index_flat()
logger.info("create index for flat done")
tasks = []
tasks.append(threading.Thread(target=task_1, args=(data_size, host)))
tasks.append(threading.Thread(target=task_2, args=(data_size, host)))
task_1(data_size, host)
task_2(data_size, host)
if len(ms.query_nodes) >= NUM_REPLICAS:
tasks.append(threading.Thread(target=task_3, args=(data_size, host)))
tasks.append(threading.Thread(target=task_4, args=(data_size, host)))
tasks.append(threading.Thread(target=task_5, args=(data_size, host)))
for task in tasks:
task.start()
for task in tasks:
task.join()
task_3(data_size, host)
task_4(data_size, host)
task_5(data_size, host)
# tasks = []
# tasks.append(threading.Thread(target=task_1, args=(data_size, host)))
# tasks.append(threading.Thread(target=task_2, args=(data_size, host)))
# if len(ms.query_nodes) >= NUM_REPLICAS:
# tasks.append(threading.Thread(target=task_3, args=(data_size, host)))
# tasks.append(threading.Thread(target=task_4, args=(data_size, host)))
# tasks.append(threading.Thread(target=task_5, args=(data_size, host)))
# for task in tasks:
# task.start()
# for task in tasks:
# task.join()

2
tests/python_client/deploy/scripts/first_recall_test.py
View File

@ -196,6 +196,6 @@ if __name__ == "__main__":
args = parser.parse_args()
host = args.host
tasks = []
for index_type in all_index_types:
for index_type in ["HNSW"]:
milvus_recall_test(host, index_type)

2
tests/python_client/deploy/scripts/second_recall_test.py
View File

@ -99,5 +99,5 @@ if __name__ == "__main__":
args = parser.parse_args()
host = args.host
tasks = []
for index_type in all_index_types:
for index_type in ["HNSW"]:
search_test(host, index_type)

9
tests/python_client/deploy/standalone-values.yaml
View File

@ -8,6 +8,15 @@ image:
tag: master-latest
pullPolicy: IfNotPresent
standalone:
resources:
limits:
cpu: 4
memory: 10Gi
requests:
cpu: 2
memory: 8Gi
kafka:
enabled: false
name: kafka