From 5044b89deb9e5d1fca3ed9eba7b6b3539ffa5823 Mon Sep 17 00:00:00 2001 From: plum-lihui Date: Wed, 5 Jul 2023 16:13:47 +0800 Subject: [PATCH] test: temp test case --- tests/system-test/7-tmq/tmqDropConsumer.py | 40 +++++++++++----------- 1 file changed, 20 insertions(+), 20 deletions(-) diff --git a/tests/system-test/7-tmq/tmqDropConsumer.py b/tests/system-test/7-tmq/tmqDropConsumer.py index b80cf10889..9da11c25cb 100644 --- a/tests/system-test/7-tmq/tmqDropConsumer.py +++ b/tests/system-test/7-tmq/tmqDropConsumer.py @@ -235,28 +235,28 @@ class TDTestCase: if (0 == existFlag): groupIdList.append(groupId) - # kill taosBenchmark - os.system("pkill -9 taosBenchmark") + # # kill taosBenchmark + # os.system("pkill -9 taosBenchmark") - # wait the status to "lost" - while (1): - exitFlag = 1 - tdSql.query('show consumers;') - consumerNUm = tdSql.queryRows - for i in range(consumerNUm): - status = tdSql.getData(i,3) - if (status != "lost"): - exitFlag = 0 - time.sleep(2) - break - if (1 == exitFlag): - break + # # wait the status to "lost" + # while (1): + # exitFlag = 1 + # tdSql.query('show consumers;') + # consumerNUm = tdSql.queryRows + # for i in range(consumerNUm): + # status = tdSql.getData(i,3) + # if (status != "lost"): + # exitFlag = 0 + # time.sleep(2) + # break + # if (1 == exitFlag): + # break - # drop consumer groups - for i in range(len(groupIdList)): - for j in range(len(topicNameList)): - sqlCmd = f"drop consumer group `%s` on %s"%(groupIdList[i], topicNameList[j]) - tdSql.execute(sqlCmd) + # # drop consumer groups + # for i in range(len(groupIdList)): + # for j in range(len(topicNameList)): + # sqlCmd = f"drop consumer group `%s` on %s"%(groupIdList[i], topicNameList[j]) + # tdSql.execute(sqlCmd) tmqCom.g_end_insert_flag = 1 tdLog.debug("notify sub-thread to stop insert data")