milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[skip ci] Add gt of locust query func on benchmark (#12963) 

Signed-off-by: wangting0128 <ting.wang@zilliz.com>
pull/12964/head
wt 2021-12-08 13:37:05 +08:00 committed by GitHub
parent 9435e37bbd
commit ee97722cd3
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
tests/benchmark/milvus_benchmark/runners/locust_tasks.py
View File

@ -26,8 +26,12 @@ class Tasks(TaskSet):
filter_query.append(eval(filter["range"]))
if isinstance(filter, dict) and "term" in filter:
filter_query.append(eval(filter["term"]))
guarantee_timestamp = self.params[op]["guarantee_timestamp"] if "guarantee_timestamp" in self.params[op] else None
# logger.debug(filter_query)
self.client.query(vector_query, filter_query=filter_query, log=False, timeout=30)
self.client.query(vector_query, filter_query=filter_query, log=False, guarantee_timestamp=guarantee_timestamp,
timeout=30)
@task
def flush(self):