From 6517f59a851209c7fc2f3e33ab21dc23177f96d9 Mon Sep 17 00:00:00 2001 From: bitcapybara Date: Wed, 26 Jun 2024 07:12:17 +0000 Subject: [PATCH] test: Update TDTestCase in tmq_taosx.py to include additional data checks --- tests/system-test/7-tmq/tmq_taosx.py | 14 ++++++++++++++ 1 file changed, 14 insertions(+) diff --git a/tests/system-test/7-tmq/tmq_taosx.py b/tests/system-test/7-tmq/tmq_taosx.py index d15c9d61b8..d30d88bb1c 100644 --- a/tests/system-test/7-tmq/tmq_taosx.py +++ b/tests/system-test/7-tmq/tmq_taosx.py @@ -553,15 +553,25 @@ class TDTestCase: tdSql.query(f'show subscriptions') tdSql.checkRows(2) + tdSql.checkData(0, 0, "t2") + tdSql.checkData(0, 1, 'g1') + tdSql.checkData(1, 0, 't1') + tdSql.checkData(1, 1, 'g1') tdSql.query(f'show consumers') tdSql.checkRows(1) + tdSql.checkData(0, 1, 'g1') + tdSql.checkData(0, 4, 't2') tdSql.execute(f'drop consumer group g1 on t1') tdSql.query(f'show consumers') tdSql.checkRows(1) + tdSql.checkData(0, 1, 'g1') + tdSql.checkData(0, 4, 't2') tdSql.query(f'show subscriptions') tdSql.checkRows(1) + tdSql.checkData(0, 0, "t2") + tdSql.checkData(0, 1, 'g1') index = 0 try: @@ -593,6 +603,8 @@ class TDTestCase: tdSql.query(f'show consumers') tdSql.checkRows(1) + tdSql.checkData(0, 1, 'g1') + tdSql.checkData(0, 4, 't2') tdSql.execute(f'insert into t4 using st tags(3) values(now, 1)') try: @@ -607,6 +619,8 @@ class TDTestCase: tdSql.query(f'show subscriptions') tdSql.checkRows(1) + tdSql.checkData(0, 0, "t2") + tdSql.checkData(0, 1, 'g1') tdSql.execute(f'drop topic t1') tdSql.execute(f'drop topic t2')