xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

TD-1287: fix failed test case

This commit is contained in:
Bomin Zhang 2020-10-26 18:47:33 +08:00
parent a030ea4f65
commit f80f4324b7
1 changed files with 14 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
tests/pytest/stream/new.py
View File

@ -26,7 +26,6 @@ class TDTestCase:
def run(self): def run(self):
rowNum = 200 rowNum = 200
totalNum = 200
tdSql.prepare() tdSql.prepare()
tdLog.info("=============== step1") tdLog.info("=============== step1")
@ -42,7 +41,9 @@ class TDTestCase:
tdSql.execute("create table st as select count(*), count(tbcol), count(tbcol2) from mt interval(10s)") tdSql.execute("create table st as select count(*), count(tbcol), count(tbcol2) from mt interval(10s)")
tdLog.info("=============== step3") tdLog.info("=============== step3")
start = time.time()
tdSql.waitedQuery("select * from st", 1, 120) tdSql.waitedQuery("select * from st", 1, 120)
delay = int(time.time() - start) + 20
v = tdSql.getData(0, 3) v = tdSql.getData(0, 3)
if v >= 51: if v >= 51:
tdLog.exit("value is %d, which is larger than 51" % v) tdLog.exit("value is %d, which is larger than 51" % v)
@ -54,11 +55,18 @@ class TDTestCase:
tdSql.execute("insert into tb%d values(now + %ds, %d, %d)" % (i, j, j, j)) tdSql.execute("insert into tb%d values(now + %ds, %d, %d)" % (i, j, j, j))
tdLog.info("=============== step5") tdLog.info("=============== step5")
tdLog.sleep(40) maxValue = 0
tdSql.waitedQuery("select * from st order by ts desc", 1, 120) for i in range(delay):
v = tdSql.getData(0, 3) time.sleep(1)
if v <= 51: tdSql.query("select * from st order by ts desc")
tdLog.exit("value is %d, which is smaller than 51" % v) v = tdSql.getData(0, 3)
if v > maxValue:
maxValue = v
if v > 51:
break
if maxValue <= 51:
tdLog.exit("value is %d, which is smaller than 51" % maxValue)
def stop(self): def stop(self):
tdSql.close() tdSql.close()