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

test: temp test case

This commit is contained in:
plum-lihui 2023-07-05 16:13:47 +08:00
parent fe568766ef
commit 5044b89deb
1 changed files with 20 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
tests/system-test/7-tmq/tmqDropConsumer.py
View File

@ -235,28 +235,28 @@ class TDTestCase:
if (0 == existFlag): if (0 == existFlag):
groupIdList.append(groupId) groupIdList.append(groupId)
# kill taosBenchmark # # kill taosBenchmark
os.system("pkill -9 taosBenchmark") # os.system("pkill -9 taosBenchmark")
# wait the status to "lost" # # wait the status to "lost"
while (1): # while (1):
exitFlag = 1 # exitFlag = 1
tdSql.query('show consumers;') # tdSql.query('show consumers;')
consumerNUm = tdSql.queryRows # consumerNUm = tdSql.queryRows
for i in range(consumerNUm): # for i in range(consumerNUm):
status = tdSql.getData(i,3) # status = tdSql.getData(i,3)
if (status != "lost"): # if (status != "lost"):
exitFlag = 0 # exitFlag = 0
time.sleep(2) # time.sleep(2)
break # break
if (1 == exitFlag): # if (1 == exitFlag):
break # break
# drop consumer groups # # drop consumer groups
for i in range(len(groupIdList)): # for i in range(len(groupIdList)):
for j in range(len(topicNameList)): # for j in range(len(topicNameList)):
sqlCmd = f"drop consumer group `%s` on %s"%(groupIdList[i], topicNameList[j]) # sqlCmd = f"drop consumer group `%s` on %s"%(groupIdList[i], topicNameList[j])
tdSql.execute(sqlCmd) # tdSql.execute(sqlCmd)
tmqCom.g_end_insert_flag = 1 tmqCom.g_end_insert_flag = 1
tdLog.debug("notify sub-thread to stop insert data") tdLog.debug("notify sub-thread to stop insert data")