diff --git a/tests/pytest/query/query.py b/tests/pytest/query/query.py
index 756aa0eda998aaa0aad30e94b2a7192d7d53bb65..8cec38780e5e873cb07d8ade45ef56b5d4ee43f7 100644
--- a/tests/pytest/query/query.py
+++ b/tests/pytest/query/query.py
@@ -111,6 +111,18 @@ class TDTestCase:
         tdSql.query("select * from tb where c5 = 'true' ")
         tdSql.checkRows(5)
 
+        # For jira: https://jira.taosdata.com:18080/browse/TD-2850
+        tdSql.execute("create database 'Test' ")
+        tdSql.execute("use 'Test' ")
+        tdSql.execute("create table 'TB'(ts timestamp, 'Col1' int) tags('Tag1' int)")
+        tdSql.execute("insert into 'Tb0' using tb tags(1) values(now, 1)")
+        tdSql.query("select * from tb")
+        tdSql.checkRows(1)
+
+        tdSql.query("select * from tb0")
+        tdSql.checkRows(1)
+        
+
     def stop(self):
         tdSql.close()
         tdLog.success("%s successfully executed" % __file__)
diff --git a/tests/pytest/stable/insert.py b/tests/pytest/stable/insert.py
index 3d37e6726c965a8963f728fdd1d8dc89e1cee339..0ef816da8d02fc6dcb48954435aad51342248e56 100644
--- a/tests/pytest/stable/insert.py
+++ b/tests/pytest/stable/insert.py
@@ -47,6 +47,40 @@ class TDTestCase:
         tdSql.query("select * from db.st where dev='dev_02'")
         tdSql.checkRows(1)
 
+        #For: https://jira.taosdata.com:18080/browse/TD-2671
+        print("==============step3")
+        tdSql.execute(
+            "create stable if not exists stb (ts timestamp, tagtype int) tags(dev nchar(50))")
+        tdSql.execute(
+            'CREATE TABLE if not exists dev_01 using stb tags("dev_01")')
+        tdSql.execute(
+            'CREATE TABLE if not exists dev_02 using stb tags("dev_02")')
+
+        print("==============step4")
+
+        tdSql.execute(
+            """INSERT INTO dev_01(ts, tagtype) VALUES('2020-05-13 10:00:00.000', 1),
+            ('2020-05-13 10:00:00.001', 1)
+             dev_02 VALUES('2020-05-13 10:00:00.001', 1)""")
+
+        tdSql.query("select * from db.stb where dev='dev_01'")
+        tdSql.checkRows(2)
+
+        tdSql.query("select * from db.stb where dev='dev_02'")
+        tdSql.checkRows(1)
+
+        tdSql.query("describe db.stb")
+        tdSql.checkRows(3)
+
+        tdSql.execute("alter stable db.stb add tag t1 int")
+        tdSql.query("describe db.stb")
+        tdSql.checkRows(4)
+
+        tdSql.execute("drop stable db.stb")
+        tdSql.query("show stables")
+        tdSql.checkRows(1)
+
+
     def stop(self):
         tdSql.close()
         tdLog.success("%s successfully executed" % __file__)
diff --git a/tests/pytest/tools/taosdemoTest2.py b/tests/pytest/tools/taosdemoTest2.py
index 7d5627be4363467e5e736760eea1e9f0799437d9..4d7e871e66b87c4c3ff8c46f68f00426d117d956 100644
--- a/tests/pytest/tools/taosdemoTest2.py
+++ b/tests/pytest/tools/taosdemoTest2.py
@@ -31,10 +31,18 @@ class TDTestCase:
 
     def insertDataAndAlterTable(self, threadID):
         if(threadID == 0):
-            os.system("yes | taosdemo -t %d -n %d" % (self.numberOfTables, self.numberOfRecords))
+            os.system("yes | taosdemo -t %d -n %d -x" % (self.numberOfTables, self.numberOfRecords))
         if(threadID == 1):
             print("use test")
             tdSql.execute("use test")
+            while True:
+                print("query started")
+                tdSql.query("select * from test.t9")
+                rows = tdSql.queryRows
+                print("rows %d" % rows)
+                if(rows > 0):
+                    break
+                time.sleep(1)      
             print("alter table test.meters add column f4 int")
             tdSql.execute("alter table test.meters add column f4 int")
             print("insert into test.t0 values (now, 1, 2, 3, 4)")
@@ -46,8 +54,8 @@ class TDTestCase:
         t1 = threading.Thread(target=self.insertDataAndAlterTable, args=(0, ))
         t2 = threading.Thread(target=self.insertDataAndAlterTable, args=(1, ))
 
-        t1.start()
-        time.sleep(2)
+        t1.start() 
+        time.sleep(2)     
         t2.start()
         t1.join()
         t2.join()