Update tmqCommon.py

This commit is contained in:
Hui Li 2023-02-24 15:37:21 +08:00 committed by GitHub
parent e667da1666
commit fb8ab642cb
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 2 deletions

View File

@ -151,7 +151,7 @@ class TMQCom:
if tdSql.getData(i, 1) == 0: if tdSql.getData(i, 1) == 0:
loopFlag = 0 loopFlag = 0
break break
time.sleep(0.1) time.sleep(0.02)
return return
def getStartCommitNotifyFromTmqsim(self,cdbName='cdb',rows=2): def getStartCommitNotifyFromTmqsim(self,cdbName='cdb',rows=2):
@ -165,7 +165,7 @@ class TMQCom:
if tdSql.getData(i, 1) == 1: if tdSql.getData(i, 1) == 1:
loopFlag = 0 loopFlag = 0
break break
time.sleep(0.1) time.sleep(0.02)
return return
def create_database(self,tsql, dbName,dropFlag=1,vgroups=4,replica=1): def create_database(self,tsql, dbName,dropFlag=1,vgroups=4,replica=1):