test: modify test case
This commit is contained in:
parent
a186cc4491
commit
ad78407ea7
|
@ -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