未验证 提交 06da995a 编写于 作者: Z zhuwenxing 提交者: GitHub

[skip ci]Update code to get flush time cost (#11381)

Signed-off-by: Nzhuwenxing <wenxing.zhu@zilliz.com>
上级 50219ab2
from enum import Enum
from random import randint
import datetime
from time import sleep
from base.collection_wrapper import ApiCollectionWrapper
from common import common_func as cf
......@@ -99,7 +99,11 @@ class InsertFlushChecker(Checker):
sleep(constants.WAIT_PER_OP / 10)
else:
# call flush in property num_entities
if self.c_wrap.num_entities == (self.initial_entities + constants.DELTA_PER_INS):
t0 = datetime.datetime.now()
num_entities = self.c_wrap.num_entities
tt = datetime.datetime.now() - t0
log.info(f"flush time cost: {tt}")
if num_entities == (self.initial_entities + constants.DELTA_PER_INS):
self._succ += 1
self.initial_entities += constants.DELTA_PER_INS
else:
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册