[test]Update deploy test (#22611)

Signed-off-by: zhuwenxing <wenxing.zhu@zilliz.com>
pull/22622/head
zhuwenxing 2023-03-08 10:43:54 +08:00 committed by GitHub
parent 6f85aeaf29
commit a7076e4626
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
6 changed files with 43 additions and 18 deletions

View File

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

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()

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()

View File

@ -183,6 +183,6 @@ if __name__ == "__main__":
default="127.0.0.1", help='milvus server ip')
args = parser.parse_args()
host = args.host
for index_type in all_index_types:
for index_type in ["HNSW"]:
milvus_recall_test(host, index_type)

View File

@ -107,5 +107,5 @@ if __name__ == "__main__":
parser.add_argument('--host', type=str, default="127.0.0.1", help='milvus server ip')
args = parser.parse_args()
host = args.host
for index_type in all_index_types:
for index_type in ["HNSW"]:
search_test(host, index_type)

View File

@ -7,6 +7,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