Merge pull request #18228 from taosdata/lihui3.0/test
test: modify test case
This commit is contained in:
commit
7e010dcee9
|
@ -135,12 +135,21 @@ class TDTestCase:
|
||||||
if rows != len(topicNameList):
|
if rows != len(topicNameList):
|
||||||
tdLog.exit("show consumers rows error")
|
tdLog.exit("show consumers rows error")
|
||||||
|
|
||||||
tdLog.info("check show subscriptions")
|
for i in range(0, 10, 1):
|
||||||
tdSql.query("show subscriptions")
|
tdLog.info("check show subscriptions")
|
||||||
tdLog.debug(tdSql.queryResult)
|
tdSql.query("show subscriptions")
|
||||||
rows = tdSql.getRows()
|
tdLog.debug(tdSql.queryResult)
|
||||||
expectSubscriptions = paraDict['vgroups'] * len(topicNameList)
|
rows = tdSql.getRows()
|
||||||
tdLog.info("show subscriptions rows: %d, expect Subscriptions: %d"%(rows,expectSubscriptions))
|
expectSubscriptions = paraDict['vgroups'] * len(topicNameList)
|
||||||
|
tdLog.info("show subscriptions rows: %d, expect Subscriptions: %d"%(rows,expectSubscriptions))
|
||||||
|
if rows != expectSubscriptions:
|
||||||
|
# tdLog.exit("show subscriptions rows error")
|
||||||
|
tdLog.info("continue retry[%d] to show subscriptions"%(i))
|
||||||
|
time.sleep(1)
|
||||||
|
continue
|
||||||
|
else:
|
||||||
|
break
|
||||||
|
|
||||||
if rows != expectSubscriptions:
|
if rows != expectSubscriptions:
|
||||||
tdLog.exit("show subscriptions rows error")
|
tdLog.exit("show subscriptions rows error")
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue