test/milvus
1
0
Fork 0
mirror of https://gitee.com/milvus-io/milvus.git synced 2024-12-02 03:48:37 +08:00
Code Issues Actions 12 Packages Projects Releases Wiki Activity

[skip ci]Adjust log level (#12943)

Browse Source 
Signed-off-by: zhuwenxing <wenxing.zhu@zilliz.com>
This commit is contained in:
zhuwenxing 2021-12-08 13:24:06 +08:00 committed by GitHub
parent e3758a05c6
commit ea9f6d870c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
tests/python_client/chaos/checker.py
View File

@ -81,7 +81,7 @@ class SearchChecker(Checker):
if result:
self.average_time = ((t1 - t0) + self.average_time * self._succ) / (self._succ + 1)
self._succ += 1
log.info(f"search success, time: {t1 - t0}, average_time: {self.average_time}")
log.debug(f"search success, time: {t1 - t0:.4f}, average_time: {self.average_time:.4f}")
else:
self._fail += 1
sleep(constants.WAIT_PER_OP / 10)
@ -106,7 +106,7 @@ class InsertFlushChecker(Checker):
if insert_result:
self.average_time = ((t1 - t0) + self.average_time * self._succ) / (self._succ + 1)
self._succ += 1
log.info(f"insert success, time: {t1 - t0}, average_time: {self.average_time}")
log.debug(f"insert success, time: {t1 - t0:.4f}, average_time: {self.average_time:.4f}")
else:
self._fail += 1
sleep(constants.WAIT_PER_OP / 10)
@ -118,7 +118,7 @@ class InsertFlushChecker(Checker):
if num_entities == (self.initial_entities + constants.DELTA_PER_INS):
self.average_time = ((t1 - t0) + self.average_time * self._succ) / (self._succ + 1)
self._succ += 1
log.info(f"flush success, time: {t1 - t0}, average_time: {self.average_time}")
log.debug(f"flush success, time: {t1 - t0:.4f}, average_time: {self.average_time:.4f}")
self.initial_entities += constants.DELTA_PER_INS
else:
self._fail += 1
@ -141,12 +141,12 @@ class CreateChecker(Checker):
if result:
self.average_time = ((t1 - t0) + self.average_time * self._succ) / (self._succ + 1)
self._succ += 1
log.info(f"create success, time: {t1 - t0}, average_time: {self.average_time}")
log.debug(f"create success, time: {t1 - t0:.4f}, average_time: {self.average_time:4f}")
self.c_wrap.drop(timeout=timeout)
else:
self._fail += 1
log.info(f"create failed, time: {t1 - t0}")
log.error(f"create failed, time: {t1 - t0:.4f}")
sleep(constants.WAIT_PER_OP / 10)
class IndexChecker(Checker):
@ -170,12 +170,12 @@ class IndexChecker(Checker):
if result:
self.average_time = ((t1 - t0) + self.average_time * self._succ) / (self._succ + 1)
self._succ += 1
log.info(f"index success, time: {t1 - t0}, average_time: {self.average_time}")
log.debug(f"index success, time: {t1 - t0:.4f}, average_time: {self.average_time:.4f}")
self.c_wrap.drop_index(timeout=timeout)
else:
self._fail += 1
log.info(f"index failed, time: {t1 - t0}")
log.error(f"index failed, time: {t1 - t0}")
class QueryChecker(Checker):
"""check query operations in a dependent thread"""
@ -197,7 +197,7 @@ class QueryChecker(Checker):
if result:
self.average_time = ((t1 - t0) + self.average_time * self._succ) / (self._succ + 1)
self._succ += 1
log.info(f"query success, time: {t1 - t0}, average_time: {self.average_time}")
log.debug(f"query success, time: {t1 - t0:.4f}, average_time: {self.average_time:.4f}")
else:
self._fail += 1
sleep(constants.WAIT_PER_OP / 10)

8
tests/python_client/chaos/test_chaos.py
View File

@ -26,13 +26,13 @@ def assert_statistic(checkers, expectations={}):
total = checkers[k].total()
average_time = checkers[k].average_time
if expectations.get(k, '') == constants.FAIL:
log.info(f"Expect Fail: {str(k)} succ rate {succ_rate}, total: {total}, average time: {average_time}")
log.info(f"Expect Fail: {str(k)} succ rate {succ_rate}, total: {total}, average time: {average_time:.4f}")
expect(succ_rate < 0.49 or total < 2,
f"Expect Fail: {str(k)} succ rate {succ_rate}, total: {total}, average time: {average_time}")
f"Expect Fail: {str(k)} succ rate {succ_rate}, total: {total}, average time: {average_time:.4f}")
else:
log.info(f"Expect Succ: {str(k)} succ rate {succ_rate}, total: {total}, average time: {average_time}")
log.info(f"Expect Succ: {str(k)} succ rate {succ_rate}, total: {total}, average time: {average_time:.4f}")
expect(succ_rate > 0.90 or total > 2,
f"Expect Succ: {str(k)} succ rate {succ_rate}, total: {total}, average time: {average_time}")
f"Expect Succ: {str(k)} succ rate {succ_rate}, total: {total}, average time: {average_time:.4f}")
def record_results(checkers):