diff --git a/tests/pytest/functions/queryTestCases.py b/tests/pytest/functions/queryTestCases.py
index 8bdbee09e7f715384f048028e7cccd0010e5642b..e84479bafd535f07e60f7598642d131a81e28693 100644
--- a/tests/pytest/functions/queryTestCases.py
+++ b/tests/pytest/functions/queryTestCases.py
@@ -430,6 +430,51 @@ class TDTestCase:
         # tdDnodes.stop(dnode_index)
         # tdDnodes.start(dnode_index)
 
+        tdSql.query("show vgroups")
+        index = tdSql.getData(0,0)
+        tdSql.checkData(0, 6, 0)
+        tdSql.execute(f"compact vnodes in({index}) start with now-10s end with now+5s")
+        start_time = time.time()
+        while True:
+            tdSql.query("show vgroups")
+            if tdSql.getData(0, 6) != 0:
+                tdLog.printNoPrefix("show vgroups row:0 col:6 data:1 == expect:1")
+                break
+            run_time = time.time()-start_time
+            if run_time > 3:
+                tdLog.exit("compacting not occured")
+            # time.sleep(0.1)
+
+        tdSql.query("show vgroups")
+        index = tdSql.getData(0,0)
+        tdSql.checkData(0, 6, 0)
+        tdSql.execute(f"compact vnodes in({index}) start with now-100s")
+        start_time = time.time()
+        while True:
+            tdSql.query("show vgroups")
+            if tdSql.getData(0, 6) != 0:
+                tdLog.printNoPrefix("show vgroups row:0 col:6 data:1 == expect:1")
+                break
+            run_time = time.time()-start_time
+            if run_time > 3:
+                tdLog.exit("compacting not occured")
+            # time.sleep(0.1)
+
+        tdSql.query("show vgroups")
+        index = tdSql.getData(0,0)
+        tdSql.checkData(0, 6, 0)
+        tdSql.execute(f"compact vnodes in({index}) end with now-10s")
+        start_time = time.time()
+        while True:
+            tdSql.query("show vgroups")
+            if tdSql.getData(0, 6) != 0:
+                tdLog.printNoPrefix("show vgroups row:0 col:6 data:1 == expect:1")
+                break
+            run_time = time.time()-start_time
+            if run_time > 3:
+                tdLog.exit("compacting not occured")
+            # time.sleep(0.1)
+
         tdSql.query("show vgroups")
         index = tdSql.getData(0,0)
         tdSql.checkData(0, 6, 0)