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

test: adjust tmqshow case

This commit is contained in:
Shengliang Guan 2022-11-27 16:15:58 +08:00
parent ecff9423bf
commit a8a75f33d7
2 changed files with 16 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
tests/parallel_test/cases.task
View File

@ -690,7 +690,7 @@
,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqCheckData.py
,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqCheckData1.py
,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqConsumerGroup.py
,,,system-test,python3 ./test.py -f 7-tmq/tmqShow.py
,,y,system-test,./pytest.sh python3 ./test.py -f 7-tmq/tmqShow.py
,,,system-test,python3 ./test.py -f 7-tmq/tmqAlterSchema.py
,,,system-test,python3 ./test.py -f 7-tmq/tmqConsFromTsdb.py
,,,system-test,python3 ./test.py -f 7-tmq/tmqConsFromTsdb1.py

23
tests/system-test/7-tmq/tmqShow.py
View File

@ -126,14 +126,21 @@ class TDTestCase:
pThread = tmqCom.asyncInsertData(paraDict)
tmqCom.getStartConsumeNotifyFromTmqsim()
#time.sleep(5)
tdLog.info("check show consumers")
tdSql.query("show consumers")
# tdLog.info(tdSql.queryResult)
rows = tdSql.getRows()
tdLog.info("show consumers rows: %d"%rows)
if rows != len(topicNameList):
tdLog.exit("show consumers rows error")
for i in range(0, 10, 1):
tdLog.info("check show consumers")
tdSql.query("show consumers")
# tdLog.info(tdSql.queryResult)
rows = tdSql.getRows()
tdLog.info("show consumers rows: %d" % rows)
if rows == len(topicNameList):
tdLog.info("show consumers rows not match %d:%d" %
(rows, len(topicNameList)))
time.sleep(1)
break
if (rows == 9):
tdLog.exit("show consumers rows error")
for i in range(0, 10, 1):
tdLog.info("check show subscriptions")