test: modify tmq test case

This commit is contained in:
plum-lihui 2023-03-30 16:38:43 +08:00
parent 32c262acc4
commit 8c9580f93e
1 changed files with 1 additions and 1 deletions

View File

@ -252,7 +252,7 @@ class TDTestCase:
resultList = tmqCom.selectConsumeResult(expectRows) resultList = tmqCom.selectConsumeResult(expectRows)
tdLog.info("expect consume rows: %d should less/equal than act consume rows: %d"%(expectRowsList[0], resultList[0])) tdLog.info("expect consume rows: %d should less/equal than act consume rows: %d"%(expectRowsList[0], resultList[0]))
if expectRowsList[0] <= resultList[0]: if expectRowsList[0] > resultList[0]:
tdLog.exit("0 tmq consume rows error!") tdLog.exit("0 tmq consume rows error!")
if expectRowsList[0] == resultList[0]: if expectRowsList[0] == resultList[0]: