test:modify case
This commit is contained in:
parent
bba6686148
commit
5d853b11ab
|
@ -138,8 +138,9 @@ class TDTestCase:
|
||||||
tdSql.query("show subscriptions")
|
tdSql.query("show subscriptions")
|
||||||
# tdLog.debug(tdSql.queryResult)
|
# tdLog.debug(tdSql.queryResult)
|
||||||
rows = tdSql.getRows()
|
rows = tdSql.getRows()
|
||||||
tdLog.info("show subscriptions rows: %d"%rows)
|
expectSubscriptions = paraDict['vgroups'] * len(topicNameList)
|
||||||
if rows != 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.exit("show subscriptions rows error")
|
||||||
|
|
||||||
pThread.join()
|
pThread.join()
|
||||||
|
|
Loading…
Reference in New Issue