xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Merge branch 'fix/TD-22671' of https://github.com/taosdata/TDengine into fix/TD-22671

This commit is contained in:
wangmm0220 2023-02-28 15:11:36 +08:00
parent 986ae9c4d0 2310dfca22
commit f08d17d2ff
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
tests/system-test/7-tmq/tmqDelete-1ctb.py
View File

@ -80,16 +80,16 @@ class TDTestCase:
tdLog.debug("del data ............ [OK]") tdLog.debug("del data ............ [OK]")
return return
def threadFunctionForDeletaData(self, **paraDict): def threadFunctionForDeletaData(self, paraDict):
# create new connector for new tdSql instance in my thread # create new connector for new tdSql instance in my thread
newTdSql = tdCom.newTdSql() newTdSql = tdCom.newTdSql()
self.delData(newTdSql,paraDict["dbName"],paraDict["ctbPrefix"],paraDict["ctbNum"],paraDict["startTs"],paraDict["endTs"],paraDict["ctbStartIdx"]) self.delData(newTdSql,paraDict["dbName"],paraDict["ctbPrefix"],paraDict["ctbNum"],paraDict["startTs"],paraDict["endTs"],paraDict["ctbStartIdx"])
return return
def asyncDeleteData(self, paraDict): # def asyncDeleteData(self, paraDict):
pThread = threading.Thread(target=self.threadFunctionForDeletaData, kwargs=paraDict) # pThread = threading.Thread(target=self.threadFunctionForDeletaData, kwargs=paraDict)
pThread.start() # pThread.start()
return pThread # return pThread
def tmqCase1(self): def tmqCase1(self):
tdLog.printNoPrefix("======== test case 1: ") tdLog.printNoPrefix("======== test case 1: ")
@ -340,7 +340,8 @@ class TDTestCase:
# del some data # del some data
rowsOfDelete = int(self.rowsPerTbl / 4 ) rowsOfDelete = int(self.rowsPerTbl / 4 )
paraDict["endTs"] = paraDict["startTs"] + rowsOfDelete - 1 paraDict["endTs"] = paraDict["startTs"] + rowsOfDelete - 1
pDeleteThread = self.asyncDeleteData(paraDict) # pDeleteThread = self.asyncDeleteData(paraDict)
self.threadFunctionForDeletaData(paraDict)
tdLog.info("start consume processor") tdLog.info("start consume processor")
tmqCom.startTmqSimProcess(pollDelay=paraDict['pollDelay'],dbName=paraDict["dbName"],showMsg=paraDict['showMsg'], showRow=paraDict['showRow'],snapshot=paraDict['snapshot']) tmqCom.startTmqSimProcess(pollDelay=paraDict['pollDelay'],dbName=paraDict["dbName"],showMsg=paraDict['showMsg'], showRow=paraDict['showRow'],snapshot=paraDict['snapshot'])