From 33e52c3dbeda4b34110cc858dec41731f4585e43 Mon Sep 17 00:00:00 2001
From: plum-lihui <huili@taosdata.com>
Date: Mon, 3 Jul 2023 11:41:42 +0800
Subject: [PATCH] test: add consumer.close

---
 tests/system-test/7-tmq/tmqMaxGroupIds.py | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/tests/system-test/7-tmq/tmqMaxGroupIds.py b/tests/system-test/7-tmq/tmqMaxGroupIds.py
index 8cac08bfad..5397a381da 100644
--- a/tests/system-test/7-tmq/tmqMaxGroupIds.py
+++ b/tests/system-test/7-tmq/tmqMaxGroupIds.py
@@ -113,6 +113,7 @@ class TDTestCase:
             "msg.with.table.name": "false"
         }
         
+        ret = 'success'
         consumer = Consumer(consumer_dict)
         # print("======%s"%(inputDict['topic_name']))
         try:
@@ -121,14 +122,18 @@ class TDTestCase:
             tdLog.info("consumer.subscribe() fail ")
             tdLog.info("%s"%(e))
             if (expectResult == "fail"):
+                consumer.close
                 return 'success'
             else: 
+                consumer.close
                 return 'fail'
     
         tdLog.info("consumer.subscribe() success ")
         if (expectResult == "success"):
+            consumer.close
             return 'success'
         else: 
+            consumer.close
             return 'fail'
 
     def tmqCase1(self):